confluent-kafka-go
confluent-kafka-go copied to clipboard
confluentinc
Confluent's Apache Kafka Golang client
### Description Is there a way to turn off Ack or Nagle (TCP_NODELAY) for TCP connections? https://chat.openai.com/share/dba5c438-7bcd-41ed-8d14-f7c61199e531 I guess it would affect both sides of transmission? or can it be...
# Description We are trying to connect to azure eventhubs and we're seeing these ApiVersion errors. We're using broker version >`1.0.0` and have tried a variety of properties including these:...
Description =========== When serializing protobuf messages, the schema that is being published/checked against the registry (i.e. the [printed protobuf source file string](https://github.com/confluentinc/confluent-kafka-go/blob/d8d41367d60ed909847c82112755d412725ec7c8/schemaregistry/serde/protobuf/protobuf.go#L217)) does not seem to match the schema that...
This is a gap in the public methods provided by the schema registry client w.r.t. the REST API of Confluent Schema Registry. **In particular, it is not supported to list...
Description =========== When using the client.rack property to initialize the Kafka config map, we aren't able to see logs of this property actually connecting to the closest Kafka server possible....
Description =========== There are some high security alerts that originate from deps in this package. How to reproduce ================ You can generate this report with Snyk Checklist ========= Please provide...
Description =========== The application does not see the messages of a topic created after the subscription, putting as parameter a regex How to reproduce ================ On kafka, create a topic...
These changes deploy a producer and a consumer applications running as k8s deployments using SPIRE to acquire credentials to talk to a Kafka cluster that has native SPIRE support.
Description =========== We are unable to perform `go get` for confluent-kafka-go using the v2.2.0 tag since 3 Nov 2023. It appears that one of the dependency repositories [(https://github.com/mitchellh/osext)](https://github.com/mitchellh/osext) have either...
Description =========== When consumer with static subscription reconnect to kafka cluster then it can't subscribe to required topics. How to reproduce ================ Create consumer with group.instance.id "instance1" then subscribe to...
Metadata
Owner
Metadata
Confluent's Apache Kafka Golang client