8 Releases published by 1 person

• 2.1.6

  published May 2, 2025

• 2.2.4

  published May 4, 2025

• 2.2.5

  published May 8, 2025

• 2.2.6

  published May 8, 2025

• 2.2.7

  published May 13, 2025

• 2.2.8

  published May 21, 2025

• 2.2.9

  published May 21, 2025

• 2.2.10

  published May 22, 2025

17 Pull requests merged by 3 people

• Add synchronized decorator; add lock to subscription state

  #2636 merged Jun 1, 2025

• Update build links in documentation

  #2634 merged May 24, 2025

• Set the current host in the SASL configs

  #2633 merged May 22, 2025

• Fix sasl gssapi plugin: do not rely on client_ctx.complete in auth_bytes()

  #2631 merged May 22, 2025

• More / updated debug logging for coordinator / consumer

  #2630 merged May 21, 2025

• Do not reset fetch positions if offset commit fetch times out

  #2629 merged May 21, 2025

• Fix timeout seconds error message in KafkaProducer

  #2627 merged May 21, 2025

• More coordinator / heartbeat logging

  #2621 merged May 15, 2025

• Update offset commit error handling; use RebalanceInProgressError if applicable

  #2623 merged May 15, 2025

• Wait for next heartbeat in thread loop; check for connected coordinator

  #2622 merged May 15, 2025

• Acquire client lock in heartbeat thread before sending requests

  #2620 merged May 15, 2025

• Minor Heartbeat updates: catch more exceptions / log configuration / raise KafkaConfigurationError

  #2618 merged May 13, 2025

• Only disable heartbeat thread once at beginning of join-group

  #2617 merged May 8, 2025

• Fix producer busy loop with no pending batches

  #2616 merged May 8, 2025

• 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

1 Pull request opened by 1 person

• KIP-345 Consumer group static membership

  #2625 opened May 16, 2025

11 Issues closed by 2 people

• TypeError: '<' not supported between instances of 'NoneType' and 'float'

  #2635 closed Jun 1, 2025

• Question: How to check to see if all brokers are healthy

  #2637 closed May 29, 2025

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

  #2610 closed May 26, 2025

• Kafka consumer stops processing messages

  #2605 closed May 22, 2025

• SaslMechanism uses empty host-config if sasl_kerberos_domain_name is not set

  #2632 closed May 22, 2025

• Kafka application consumer code fails with auth_bytes

  #2624 closed May 22, 2025

• Seems consumer is not fetching offsets correctly on start and during rebalance

  #2628 closed May 22, 2025

• kafka.errors.KafkaTimeoutError: KafkaTimeoutError: Failed to update metadata after 49999000.0 secs.

  #2626 closed May 21, 2025

• KafkaProducer hangs in busy loop after delivery timeout

  #2615 closed May 8, 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

1 Issue opened by 1 person

• SaslAuthenticate error: SaslAuthenticationFailedError

  #2638 opened May 31, 2025

1 Unresolved conversation

Sometimes conversations happen on old items that aren’t yet closed. Here is a list of all the Issues and Pull Requests with unresolved conversations.

• Integration with Confluent Schema Registry?

  #2233 commented on May 6, 2025 • 0 new comments