Shopify/sarama issues and pull requests

#2474 - DNS resolution for broker address

Issue - State: open - Opened by ShrirAm-cse over 1 year ago

#2473 - Metadata check returns nil leader

Issue - State: closed - Opened by franmoore05 over 1 year ago - 1 comment

#2472 - feature: return KError instead of errors in AlterConfigs and DescribeConfig

Pull Request - State: open - Opened by zhuliquan over 1 year ago
Labels: cla-needed

#2471 - saram async produce msg successfully,but no msg in kafka

Issue - State: closed - Opened by go-slark over 1 year ago

#2470 - SASL connection to Eventhubs using kafka fails 1.38.0 onwards

Issue - State: open - Opened by DeepanshuA over 1 year ago - 1 comment

#2469 - backoff param in idempotent producer has no effect when broker unavailable

Issue - State: open - Opened by cch123 over 1 year ago

#2468 - updated example to the newest version

Pull Request - State: open - Opened by mehrdad-khojastefar over 1 year ago - 1 comment
Labels: cla-needed

#2467 - Add context to interceptor interfaces

Issue - State: open - Opened by mashail over 1 year ago

#2466 - Allow to implement a custom SASL mechanism

Pull Request - State: open - Opened by bpaquet over 1 year ago - 3 comments

#2465 - Add support for IAM MSK auth

Pull Request - State: open - Opened by bpaquet over 1 year ago - 11 comments

#2464 - sarama consumer client can not return to leader when the client fetch from follower which is outed of isr

Issue - State: open - Opened by mtj075 over 1 year ago

#2463 - SyncProducer.SendMessages mock behavior does not match actual implementation

Issue - State: open - Opened by svitcov over 1 year ago

#2462 - broker.Produce sporadically fails with network errors

Issue - State: open - Opened by gfazenda over 1 year ago

#2461 - Transition sarama ownership

Issue - State: open - Opened by dmariassy over 1 year ago - 2 comments
Labels: help wanted

#2460 - loopCheckPartitionNumbers function some problem

Issue - State: open - Opened by cheaster062211 over 1 year ago

#2459 - loopCheckPartitionNumbers function something doubt

Issue - State: closed - Opened by cheaster062211 over 1 year ago

#2457 - Added support for Kerberos authentication with a credentials cache.

Pull Request - State: open - Opened by mrogaski over 1 year ago

#2455 - https://shopify.github.io/sarama website is 404

Issue - State: closed - Opened by beihai0xff over 1 year ago - 1 comment

#2454 - ConsumeClaim: if message is received as nil, the next line would run into nil pointer exception

Issue - State: open - Opened by nbajaj90 over 1 year ago

#2453 - fix: prevent data race in balance strategy

Pull Request - State: closed - Opened by napallday over 1 year ago - 1 comment
Labels: fix

#2452 - chore(deps): bump golang.org/x/net from 0.5.0 to 0.7.0

Pull Request - State: closed - Opened by dependabot[bot] over 1 year ago
Labels: dependencies

#2451 - fix: use version 4 of DescribeGroupsRequest only if kafka broker vers… …ion is >= 2.4

Pull Request - State: closed - Opened by faillefer over 1 year ago - 2 comments
Labels: fix

#2450 - Ask about transaction producer example

Issue - State: closed - Opened by toannhu96 over 1 year ago - 1 comment

#2449 - fix reset offset not work in starting

Pull Request - State: open - Opened by yexinhua1998 over 1 year ago

#2448 - Added support for Kerberos authentication with a credentials cache.

Pull Request - State: closed - Opened by mrogaski over 1 year ago - 2 comments
Labels: cla-needed

#2447 - Fix HighWaterMarkOffset of mocks partition consumer

Pull Request - State: closed - Opened by gr8web over 1 year ago - 1 comment
Labels: fix

#2446 - How consumer group support multiple consumers consume the same group?

Issue - State: open - Opened by yitian108 over 1 year ago - 3 comments

#2445 - not returning non-existent topic error when auto create topic is enabled

Pull Request - State: open - Opened by thangnt294 over 1 year ago - 1 comment

#2444 - Sarama reports error for non-existent topic even though topic-auto-create option is on

Issue - State: open - Opened by thangnt294 over 1 year ago

#2443 - Error when using DescribeConsumerGroups with cluster version 2.3.X

Issue - State: closed - Opened by faillefer over 1 year ago - 1 comment

#2442 - Kafka is not consuming properly

Issue - State: closed - Opened by mtmibjas over 1 year ago

#2441 - commit offset manually doesn't work when using consumer group

Issue - State: closed - Opened by yanmxa over 1 year ago - 1 comment

#2440 - Cannot Receive Message for some specific GroupID

Issue - State: closed - Opened by yitian108 almost 2 years ago - 1 comment

#2439 - DATA RACE

Issue - State: open - Opened by why444216978 almost 2 years ago

#2438 - asyncproducer fails with topic does not exist when consecutive messages are published to different topics in the same millisecond

Issue - State: open - Opened by dineshudayakumar almost 2 years ago

#2437 - support user-defined spn by kerberos authentication method

Pull Request - State: open - Opened by YUUKKY almost 2 years ago

#2436 - SARAMA could not support the user-defined spn for kerberos authentication process

Issue - State: open - Opened by YUUKKY almost 2 years ago

#2435 - remove duplicate line

Pull Request - State: open - Opened by giulianopz almost 2 years ago
Labels: cla-needed

#2434 - chore: add kafka 3.3.2

Pull Request - State: closed - Opened by dnwe almost 2 years ago

#2433 - shopify.github.io/sarama is 404

Issue - State: closed - Opened by intel352 almost 2 years ago - 1 comment

#2432 - Error Comment for Function PauseAll() of the interface ConsumerGroup in the file consumer_group.go

Issue - State: open - Opened by yitian108 almost 2 years ago

#2431 - Encounter two questions about calling ResetOffset

Issue - State: open - Opened by yitian108 almost 2 years ago

#2430 - Crc32 Partitioning Scheme Incompatible with librdkafka

Issue - State: open - Opened by csm8118 almost 2 years ago

#2429 - How to make sure all messages sent by `SendMessages` is succeed or fail at once?

Issue - State: open - Opened by longit644 almost 2 years ago

#2428 - fix(metrics): fix race condition when calling Broker.Open() twice

Pull Request - State: closed - Opened by vincentbernat almost 2 years ago - 1 comment
Labels: fix

#2427 - fix(consumer): don't retry FindCoordinator forever

Pull Request - State: closed - Opened by dnwe almost 2 years ago
Labels: fix

#2426 - [Bug] Infinity loop in Consume() method

Issue - State: closed - Opened by vitalygudza almost 2 years ago - 2 comments

#2425 - Broker abandoning subscription because consuming is taking too long.

Issue - State: open - Opened by rhammonds1-kr almost 2 years ago - 2 comments

#2424 - fix: use newConsumer method in newConsumerGroup method

Pull Request - State: closed - Opened by Lumotheninja almost 2 years ago
Labels: fix

#2423 - fix: remove NewConsumerFromClient method call in newConsumerGroup method

Pull Request - State: closed - Opened by Lumotheninja almost 2 years ago - 3 comments
Labels: cla-needed

#2422 - BalanceStrategySticky panic with concurrent map writes error

Issue - State: closed - Opened by insulaire almost 2 years ago - 5 comments

#2421 - Feature: Support for Kerberos authentication using a credentials cache.

Issue - State: open - Opened by mrogaski almost 2 years ago

#2420 - fix(example): correct `records-number` param in txn producer readme

Pull Request - State: closed - Opened by ghost almost 2 years ago - 2 comments
Labels: fix

#2419 - How to skip ssl_hostname check

Issue - State: closed - Opened by xiaonuoz almost 2 years ago - 1 comment

#2418 - chore(deps): bump github.com/eapache/go-xerial-snappy digest to bf00bc1

Pull Request - State: closed - Opened by dnwe almost 2 years ago
Labels: dependencies, bump/digest

#2417 - How can I identify a commit operation is successful?

Issue - State: open - Opened by ZzIris almost 2 years ago - 3 comments

#2416 - chore(deps): bump go to 1.18

Pull Request - State: closed - Opened by dnwe almost 2 years ago
Labels: dependencies, bump/minor

#2415 - chore(deps): bump module go to 1.19

Pull Request - State: closed - Opened by dnwe almost 2 years ago - 1 comment
Labels: dependencies, bump/minor

#2414 - chore(deps): bump module golang.org/x/sync to v0.1.0

Pull Request - State: closed - Opened by dnwe almost 2 years ago
Labels: dependencies, bump/minor

#2413 - chore(deps): bump module golang.org/x/net to v0.5.0

Pull Request - State: closed - Opened by dnwe almost 2 years ago
Labels: dependencies, bump/minor

#2412 - chore(deps): bump module github.com/xdg-go/scram to v1.1.2

Pull Request - State: closed - Opened by dnwe almost 2 years ago
Labels: dependencies, bump/patch

#2411 - chore(deps): bump module github.com/stretchr/testify to v1.8.1

Pull Request - State: closed - Opened by dnwe almost 2 years ago
Labels: dependencies, bump/patch

#2408 - Consider switching default Kafka version to at least 2.1

Issue - State: open - Opened by ijuma almost 2 years ago - 2 comments

#2398 - when i use demo of consumergroup got panic err

Issue - State: open - Opened by pengtianyue025 almost 2 years ago - 2 comments

#2387 - fix: add nil check while producer is retrying

Pull Request - State: closed - Opened by hsweif about 2 years ago - 2 comments
Labels: fix

#2381 - Panic on ConsumerGroup.Consume() error

Issue - State: open - Opened by billygout about 2 years ago - 2 comments

#2379 - ResetOffset not working when start up using local checkpoint

Issue - State: open - Opened by npsables about 2 years ago - 2 comments

#2371 - feat: add metadata-age metric

Pull Request - State: closed - Opened by auntan about 2 years ago - 1 comment

#2365 - Sarama should implement KIP-320

Issue - State: closed - Opened by dajac about 2 years ago - 1 comment

#2358 - Breaking API change in a minor version release (v1.34.0)

Issue - State: open - Opened by Jeffail about 2 years ago - 2 comments

#2344 - Sarama API about consumer groups are not idiot-proof enough.

Issue - State: open - Opened by fdejaeger about 2 years ago - 1 comment

#2326 - Increase in huge number of goroutines during every metadata refresh

Issue - State: open - Opened by iamnaman863 about 2 years ago - 4 comments

#2325 - error: kafka: client has run out of available brokers to talk to: EOF

Issue - State: open - Opened by lianglinhuan about 2 years ago - 5 comments

#2324 - SASL_SSL settings are not working with sarama pkg

Issue - State: open - Opened by vjakka-intel about 2 years ago - 2 comments

#2321 - Broker connection shut down too early and follower broker is not becoming leader during broker shutdown

Issue - State: open - Opened by iamnaman863 over 2 years ago - 4 comments

#2320 - Data race in broker v1.36.0

Issue - State: closed - Opened by samuelhewitt over 2 years ago - 9 comments

#2271 - Feat: Add GetOffset for Consumer and ConsumerGroup

Pull Request - State: closed - Opened by haoxins over 2 years ago

#2270 - Feat: Add Partitions for ConsumerGroup

Pull Request - State: closed - Opened by haoxins over 2 years ago - 1 comment

#2237 - panic: kafka server: In the middle of a leadership election, there is currently no leader for this partition and hence it is unavailable for writes

Issue - State: open - Opened by dybxin over 2 years ago - 1 comment

#2219 - Consumer stops consuming a single partition in a topic

Issue - State: open - Opened by nearih over 2 years ago - 1 comment

#2207 - The GitHub Pages link returns `404 File not found`

Issue - State: open - Opened by techeverri over 2 years ago - 3 comments

#2192 - add support for aws mks iam

Pull Request - State: open - Opened by sethpollack over 2 years ago - 15 comments
Labels: cla-needed

#2173 - Sync Producer stalled - Unable to send messages to Kafka after a write tcp: broken pipe error

Issue - State: closed - Opened by shweta-fourkites over 2 years ago - 17 comments

#2156 - Implement resolve_canonical_bootstrap_servers_only

Pull Request - State: open - Opened by gebn almost 3 years ago - 1 comment

#2132 - consumer group can not consume

Issue - State: open - Opened by go-slark almost 3 years ago - 3 comments

#2106 - fix: Added broker connection check in metadata refresh loop. Closes broken broker connections

Pull Request - State: open - Opened by doxsch almost 3 years ago - 5 comments

#2102 - Question about MaxProcessingTime timeouts

Issue - State: open - Opened by gmaz42 almost 3 years ago - 2 comments

#2087 - AWS MSK Kafka migration -- error connecting to kafka: kafka: client has run out of available brokers to talk to (Is your cluster reachable?

Issue - State: open - Opened by johnson101119 almost 3 years ago - 9 comments

#2071 - regression: enabling rackawareness causes severe throughput drops

Issue - State: closed - Opened by lizthegrey almost 3 years ago - 8 comments

#2049 - Not able to find the consumer setting max.poll.records

Issue - State: open - Opened by sameershah25 about 3 years ago - 6 comments

#2036 - alibabacloud recommends against using Sarama?

Issue - State: open - Opened by KeenCN about 3 years ago - 6 comments

#1961 - Sticky producer partitioning

Issue - State: open - Opened by seizethedave over 3 years ago - 1 comment

#1878 - syncProducer hangs forever when Idempotent is enabled

Issue - State: open - Opened by YunNeverMore almost 4 years ago - 5 comments

#1750 - Adds missing mock responses for mocking consumer group

Pull Request - State: closed - Opened by krantideep95 over 4 years ago - 6 comments

#1690 - Is there a way to set batch.size and max.block.ms for kafka version V2.5.x in producer?

Issue - State: open - Opened by al8n over 4 years ago - 7 comments

#1578 - fixed ConsumerGroup flooding logs with client/metadata update req #1544

Pull Request - State: closed - Opened by antsbean almost 5 years ago - 13 comments

#1568 - client has run out of available brokers to talk to

Issue - State: closed - Opened by leo-zj almost 5 years ago - 4 comments
Labels: stale

#1565 - producer write broken pipe

Issue - State: open - Opened by chowyu08 almost 5 years ago - 21 comments

#1399 - Read from a particular offset

Issue - State: closed - Opened by korjavin over 5 years ago - 5 comments
Labels: question

#1351 - consumer group deadlock on close: consumer group shutdown hangs

Issue - State: open - Opened by sitano over 5 years ago - 17 comments
Labels: bug :-(, To be reproduced, help wanted

GitHub / Shopify/sarama issues and pull requests