confluent-kafka-go
confluent-kafka-go copied to clipboard
confluentinc
Confluent's Apache Kafka Golang client
Copying the functionality of a base implementation into the extending struct's implementation is a recipe for later bugs when changes are made in the base implementation that don't get copied...
Description =========== When a producer tries to publish a message to a non-existing topic (`auto.create.topics.enable` disabled) we do see errors in stderr (`"debug": "all"`), but the errors are not caught...
Description =========== I have set up a local kafka cluster with single topic having 3 partitions. I have written a standalone golang program using this API to seek and read...
Description =========== Hi, I have a topic where I need to keep the message order and it's not an option to have a "retry topic" or something like that. It's...
Description =========== I'm using [email protected] and I'm facing this issue while running my main.go file "# github.com/confluentinc/confluent-kafka-go/kafka In file included from ./select_rdkafka.h:26:0, from ..\..\pkg\mod\github.com\confluentinc\[email protected]\kafka\adminapi.go:28: ./librdkafka_vendor/rdkafka.h:66:17: error: conflicting types for 'size_t'...
Description =========== We want to upgrade confluent-kafka-go to 2.1.1. However, we encountered the following error during compilation in the Mac environment. It seems that the version of openssl is not...
Description =========== I accidentally passed `"bootstrap.servers": ""` to `kafka.NewConsumer`. I expected something would return an error with this misconfiguration. Nothing did. How to reproduce ================ Take the example from the...
Description =========== When the `auto.offset.reset` is set to `latest` and the `enable.auto.offset.store` is set to `false`, the reset offset should be committed to the broker in-order to report the correct...
I want to read batch of messages as following code works in java. ```try { while (true) { 1 ConsumerRecords records = consumer.poll(100); for (ConsumerRecord record : records) { log.debug("topic...
Description =========== Want to know if it is possible to use per partition queues librd provides using this Library? Will it improve overall performance when we seek messages from particular...
Metadata
Owner
Metadata
Confluent's Apache Kafka Golang client