kafka-go
kafka-go copied to clipboard
segmentio
Kafka library in Go
Send Partial Batch will force partial batches to send right away when calling Writer.WriteMessages instead of blocking until a full batch is made or the timeout is seen. I have...
Azure Event Hubs provides optional Kafka protocol compatibility. In order to authenticate, an OAUTHBEARER SASL mechanism is provided that builds a SASL client response with an Azure Entra token. See...
This PR makes the 3 functions `Message.totalSize`, `Message.size`, and `Message.headerSize` public. This is helpful for applications which may need to add a buffer before calling `WriteMessages`, or for applications that...
**Describe the bug** The version mapping for RequestPartition.CommittedLeaderEpoch is set to v5, but this was not added until v6. https://kafka.apache.org/protocol#The_Messages_OffsetCommit
What will happen if one of the messages from the batch passed to `WriteMessages` fails to produce? Is there will be some rollback for the remaining messages? If not, is...
**Describe the bug** When using `ReadMessage` with `IsolationLevel` set to `ReadCommitted`, I appear to be getting back records from uncommitted transactions. **Kafka Version** Kafka 3.6/3.7 kafka-go 0.4.47 > * What...
Add configuration entry for the reader to define a callback function that collects rebalance events in the form of map[topic name:string][]PartitionAssignment This information is useful for consumers that need to...
This is a skeleton PR aiming for discussion related to https://github.com/segmentio/kafka-go/issues/1308 In that issue, I describe how rebalances can lead to a situation where the consumer receiving the partition does...
