5 Releases published by 1 person

• 2.2.1

  published Apr 29, 2025

• 2.2.2

  published May 1, 2025

• 2.2.3

  published May 1, 2025

• 2.1.6

  published May 2, 2025

• 2.2.4

  published May 4, 2025

7 Pull requests merged by 2 people

• Do not reset_generation after RebalanceInProgressError; improve CommitFailed error messages

  #2614 merged May 4, 2025

• Fix KafkaConsumer.poll() with zero timeout

  #2613 merged May 4, 2025

• Fix Fetch._reset_offsets_async() KeyError when fetching from multiple nodes

  #2612 merged May 4, 2025

• Ignore leading SECURITY_PROTOCOL:// in bootstrap_servers

  #2608 merged May 1, 2025

• Only create fetch requests for ready nodes

  #2607 merged May 1, 2025

• Always try ApiVersionsRequest v0, even on broker disconnect

  #2603 merged Apr 29, 2025

• Fix SubscriptionState AttributeError in KafkaConsumer

  #2599 merged Apr 29, 2025

8 Issues closed by 1 person

• CommitFailedError when there are very few messages to be read from topic

  #2610 closed May 4, 2025

• Kafka consumer not reading any message with zero timeout_ms poll value

  #2609 closed May 4, 2025

• KeyError in kafka/consumer/fetcher.py _reset_offsets_async()

  #2611 closed May 4, 2025

• Confluent's provided bootstrap endpoint from terraform causes parsing/casting error on broker.host

  #2606 closed May 1, 2025

• NodeNotReadyError on poll

  #2604 closed May 1, 2025

• check_version() fails on Azure Event Hubs since 2.1.3

  #2602 closed Apr 29, 2025

• error occurs when invoking seek_to_end

  #2600 closed Apr 29, 2025

• Nice to have: context managers

  #2601 closed Apr 29, 2025

1 Issue opened by 1 person

• Kafka consumer stops processing messages

  #2605 opened May 1, 2025