confluent-kafka-go
confluent-kafka-go copied to clipboard
confluentinc
Confluent's Apache Kafka Golang client
Description =========== overview of cpu usage percentiles etc  ----- going up the chain:  ----------------- seems to be a hotspot here:  How to reproduce ================ TBD
This PR combines https://github.com/confluentinc/confluent-kafka-go/pull/1181 and https://github.com/confluentinc/confluent-kafka-go/pull/1149
Description =========== My Golang service produces the data to the topic where all the data are fetched from the database. I implement the async producer, sometimes the logic works and...
Description =========== Is the producer client a keepalive connection? Cause I found some error from the producer eventChan: ' 2/2 all brokers are down`. Is that mean the producer keeps...
Description =========== Unsubscribing to 1 topic, but not all topics, for a consumer is currently _wonky_ I want this: ```golang err := consumer.UnsubscribeFromTopic(topicId) ``` but all we have is: ```golang...
Description =========== Trying to run the consumer example in the README on macos sonoma 14.4.1 produces a `signal: bus error` confluent-kafka-go v2.4.0 ``` $ clang --version Apple clang version 13.1.6...
Description =========== Library version github.com/confluentinc/confluent-kafka-go/v2 v2.0.2 Kakfa broker version: 2.8.2 (Commit:3146c6ff4a24cc24) Any input on the following would be greatly appreciated, I have various consumers in consumer group FOO. The consumers...
Description =========== Scenario: 1. I have a producer running for 4 days 2. No writes at all 3. Calling flush on this producer (timeout=10 seconds) results in 2 unflushed messages...
Metadata
Owner
Metadata
Confluent's Apache Kafka Golang client