GoogleCloudPlatform/pubsub
This repository contains open-source projects managed by the owners of Google Cloud Pub/Sub.
JavaApache-2.0
Issues
- 2
Support strimzi.io kafka and docker image
#286 opened by qafro1 - 0
pub a message with ordering key error, keep getting : "Execution cancelled because executing previous runnable failed"
#368 opened by wsyzwddsg111 - 8
Avro with Kafka Connect sink connector
#303 opened by OuesFa - 0
- 1
- 8
- 0
Load test framework doesn't use pagination when calling instanceGroupManagers.listManagedInstances
#336 opened by matt-kwong - 9
Connector shadow jar is too fat
#252 opened by mkuthan - 1
- 0
Ordering Key prober does not build
#331 opened by jannavarro - 0
Can't reach GCP PubSub Emulator
#330 opened by PabloRR100 - 0
loadtest: unable to connect to client
#323 opened by hongalex - 0
Question: How Can I enable encrypted transmission between the connector and On Premise Kafka
#321 opened by foward - 0
Intermittent error related to AuthMetadataPluginCallback : ValueError: None could not be converted to unicode
#320 opened by nguaman - 0
Kafka Connector [Quickstart - copy_tool.py] doesn't verify the integrity of the downloaded files
#319 opened by ikhvjs - 3
- 1
Receiving base64 encoded messages in kafka from pubsub
#309 opened by hitk6 - 2
- 0
- 0
Pub sub connector not working with 2.8.1
#305 opened by nsgeorgi - 1
netty dependency is too old to compile on aarch64
#301 opened by fingon - 3
- 1
- 0
- 4
Compress messages before publishing - Google Pub/Sub
#280 opened by kk2491 - 0
- 2
Sink mode delivery guarantees
#281 opened by OuesFa - 4
Commit of offsets timed out - Many thread exceptions
#221 opened by jonathanendy - 6
publish Kafka Connectors to maven central
#278 opened by ryannedolan - 2
External IP
#258 opened by Ryner51 - 2
- 1
kafka-connector not flushing messages (ack)
#277 opened by nicodds - 0
- 2
pubSubSource: Receving the same message twice
#261 opened by amit-k-yadav - 1
PubsubMessage data field is base64-encoded
#265 opened by GilbertGeliba - 0
Issue while trying to use ordering key
#255 opened by siddharthsbhadauria - 1
Caused by: java.lang.IllegalStateException: Could not find TLS ALPN provider; no working netty-tcnative, Conscrypt, or Jetty NPN/ALPN available
#259 opened by deeptibhardwaj24 - 0
- 4
Request payload size exceeds the limit
#253 opened by acbeni - 1
Question about cloud-pubsub-jms
#254 opened by oliverhenlich - 1
Query : Performance issues while using ordering key in CPS connector
#249 opened by siddharthsbhadauria - 0
- 1
Kafka Connector with Pub/Sub Lite
#228 opened by antonmry - 0
java.lang.NoClassDefFoundError: com/google/api/gax/rpc/TransportChannelProvider
#241 opened by ZackBarry - 1
Tag new release
#232 opened by dariocazas - 0
- 0
- 1
Message compression while publishing to GCP P/S
#229 opened by udaedrewip - 3
CloudPubSubConnector Message Aggregation
#227 opened by yaronworldwide - 11
java.lang.NoClassDefFoundError: Could not initialize class com.google.pubsub.v1.ProjectTopicName
#222 opened by smit-aterlo