sarama

sarama copied to clipboard

This PR addresses [this issue](https://github.com/Shopify/sarama/issues/2316). Signed-off-by: Panos Koutsovasilis

pkoutsovasilis

##### Versions *Please specify real version numbers or git SHAs, not just "Latest" since that changes fairly regularly.* | Sarama | Kafka | Go | |--------|-------|----| | v1.34.1 | 7.2.1-ccs...

pkoutsovasilis

Paused Consumer still sends FetchRequest (with empty blocks)

6

Whilst trying out the new "pause consumer" support (https://github.com/Shopify/sarama/pull/2005) on main, I noticed that Sarama will submit empty FetchRequests if all of the assigned partitions are paused. This is because...

dnwe

vulnerability [CVE-2022-27191]

6

##### Versions 1.34.1 | Sarama | Kafka | Go | |--------|-------|----| | | | | ##### Configuration What configuration values are you using for Sarama and Kafka? ``` go ```...

mohit-angelone

It took 5 seconds for a consumer group to start

10

##### Versions *Please specify real version numbers or git SHAs, not just "Latest" since that changes fairly regularly.* | Sarama | Kafka | Go | |--------|-------|----| | v1.34.0 | |...

Siyu-silvia

Inspired from https://github.com/Shopify/sarama/pull/1527 Fix: * https://github.com/Shopify/sarama/issues/1829 * https://github.com/Shopify/sarama/issues/1760 Changes: * Add BeginTxn/CommitTxn/AbortTxn/AddOffsetsToTxn/AddMessageToTxn to Sync/Async Producer Example usage: (for more complete examples see examples/txn_producer && examples/exactly_once) * Simple transaction producer ```go...

ryarnyah

Feat: Add Partitions for ConsumerGroup

1

Add the `Partitions()` method for `ConsumerGroup`, the same as `Client.Partitions()` and `Consumer.Partitions()`.

haoxins

@dnwe can you have a look at this small change?

haoxins

[Question] How does SendMessages() work when some messages in the batch failed?

1

Let's imagine I'm sending 5 messages (1, 2, 3, 4, 5) using `SendMessages` method. According to the documentation: ``` // SendMessages produces a given set of messages and returns only...

kpeu3i

Hang on PartitionOffsetManager.Close sequence with AutoCommit.Enable = false

2

Calls to `PartitionOffsetManager.Close` seem to consistently hang for me when `Consumer.Offsets.AutoCommit.Enable==false`. They do not hang when the default value of true is used. ##### Versions | Sarama | Kafka |...

benweint