Repository Issue Activity (beta)

#3122 KafkaTimeoutError: Timeout during ApiVersions check (HPE NonStop Python)

#3146 KafkaAdminClient.create_partitions with int total count fails with InvalidReplicationAssignmentError (sends empty assignments array instead of null)

#2610 CommitFailedError when there are very few messages to be read from topic (HPE NonStop Python)

#3138 ConsumerRebalanceListener: Problem of multiprocessing

#3131 Consumer stops returning records for specific partitions in version 3.0.7~8

#3112 Concurrency issues with custom assignors after 3.0.x

#3121 KafkaConsumer.commit() is ignoring timeout values

#3113 3.0.x no longer sends TLS SNI when ssl_check_hostname=False, breaking SNI-routed clusters (Strimzi ingress, TLS-passthrough LBs)

#3106 kafka-python 3.x consumer stalls after one fetched batch

#3104 IndexError: bytearray index out of range with describe_configs_request_v4 (regression in 3.0.4)

#3102 IndexError in UnsignedVarInt32.encode_into for large records

#2233 Integration with Confluent Schema Registry?

#2715 Enhance Consumer and Producer Documentation with More Practical Examples

#3094 Documentation: No Title

#3093 NetworkSelector._poll_once() can call a retired task and log RuntimeError: Task is already done!

#3090 ModuleNotFoundError: No module named 'kafka' with 3.0.2 in python 3.12 and kafka-python3.0.2

#3076 NetworkSelector.unschedule() leaks cancelled tasks in _pending_tasks

#3074 kafka-python 3.0.0 consumer fails with InvalidReceiveError

#2709 Help: AdminClient: SSL Connection failure after updating from 2.2.10 to 2.3

#2121 Create a pytest fixture for multi-threaded consumer group

#1251 Write tests to verify consumer can handle race conditions between metadata updates/ group rebalances

#2116 Help: AWS lambda cannot send message to Kafka running on EC2 instance (v2.x)

#632 kafka-python should package test module / fixtures

#1148 Add `wakeup` to Consumer as in Java Client

#1165 Add tests of `KafkaProducer` for various Acks levels