confluent-kafka-go
confluent-kafka-go copied to clipboard
confluentinc
Confluent's Apache Kafka Golang client
Hello Maybe it is only question, but I expected another behavior suppose I have 2 topics with 3 partitions each and 3 consumers in one group when I call ```...
Closes https://github.com/confluentinc/confluent-kafka-go/issues/778 Adding the ability to use a concrete `Offset` type with the `NewOffset` func, by extension this also enables it through the `Offset.Set` func. An `Offset` is an `int64`...
Description =========== Hi team, We're currently using the latest version of the **confluent-kafka-go** package **(version 2.3.0)** in our project, accessible at **[github.com/confluentinc/confluent-kafka-go/v2:v2.3.0]**. However, it's important to note that this version...
I have a consumer group that contains several single-partition topics. There are times when I want to create a new consumer in this group, but have it read starting from...
Description =========== We have an enterprise use-case where one Producer produces to a list of topics that're programmatically created and then deleted shortly after. They're experiencing issues where our memory...
Go 1.19 introduced gofmt formatting changes. This change runs gofmt from Go 1.19, since commit 09f2d70be7d3 on 2023-07-14 updated to use that version. It also fixes bundle-import.sh to generate the...
This is a collection of minor API documentation edits I noticed while using ListOffsets. Notably: I had to look around to figure out that timestamps are Unix milliseconds. Detailed edits:...
Description =========== I am trying to use schema registry with my producer.go, which I followed up the instructions with [Kafka and Go](https://developer.confluent.io/get-started/go/#build-producer), but every time I run my producer I...
Metadata
Owner
Metadata
Confluent's Apache Kafka Golang client