confluent-kafka-go
confluent-kafka-go copied to clipboard
confluentinc
Confluent's Apache Kafka Golang client
Description =========== Reading the documentation for the resume and pause functions for consumers in librdkafka [here](https://docs.confluent.io/5.0.4/clients/librdkafka/classRdKafka_1_1Handle.html#a322d16d6786da2b4b20505f19325fcec), it seems as though the resume and pause functions that this library wraps always...
and used an exclusive lock The read lock alone is requested only when the key is not in cache and multiple Get requests are made concurrently. The ToMap method is...
I think there's a race condition when producing a message to `p.ProduceChannel()`, then immediately calling Flush. I think the following sequence is possible: message take from `produceChannel` here: https://github.com/confluentinc/confluent-kafka-go/blob/master/kafka/producer.go#L556 length...
Description =========== In "High-level balanced consumer" part of "Examples" section of README file, it's impossible to reach `c.Close` method because for loop doesn't have any conditions and will run for...
Description =========== Applications that uses `confluent-kafka-go` cannot be built on `linux/arm64` (aka `aarch64`) with the bundled `librdkafka` library. This includes: - Building an application natively on `linux/arm64` - Eg Linux...
Description =========== seek offset by time","offsets":[{"Topic":"xxx","Partition":0,"Offset":-1,"Metadata":null,"Error":null}] How to reproduce ================ //startTime unix time stamp seconds offsets, err := w.consumer.OffsetsForTimes([]kafka.TopicPartition{{ Topic: &topic, Partition: 0, Offset: kafka.Offset(startTime * 1000), }}, 200) Checklist...
Description =========== We are running into issues when shutting down consumers in our environment, where closing the consumer gets stuck and loops before our pod (we run in k8s) is...
Metadata
Owner
Metadata
Confluent's Apache Kafka Golang client