Smriti comments

Results 6 comments of


                                            Smriti

Remove duplicates from topics

@dnwe Could you please review the issue and PR.

Issue could be tested by adding this testcase to balance_strategy_test.go: > { > name: "2 members, 1 topic, 8 partitions each", > members: map[string][]string{"M1": {"T1", "T1", "T1", "T1", "T1", "T1",...

Partitions are not divided evenly among consumers in a Consumer Group

Hi, Found the problem. If you pass duplicate topics in group.Consume(KafkaTopics) then it leads to an issue in Balance_Strategy.go and most of the time empty assignments are made to the...

Partitions are not divided evenly among consumers in a Consumer Group

Issue could be tested by adding this testcase to balance_strategy_test.go: > { > name: "2 members, 1 topic, 4 partitions each", > members: map[string][]string{"M1": {"T1", "T1", "T1", "T1", "T1", "T1",...

Partitions are not divided evenly among consumers in a Consumer Group

Fixed in: https://github.com/Shopify/sarama/pull/2285

Pool min size

Hi @brianc Is there any future roadmap to support this feature??