Search results

If consumer isn't started,getmany() fails withAttributeError

Status: Open.

#1102 In aio-libs/aiokafka;

·MrCreosote openedon Mar 27, 2025

AIOKafkaProducer appears to hang forever if Kafka is down forsend_and_wait andstop()

Status: Open.

#1101 In aio-libs/aiokafka;

·MrCreosote openedon Mar 25, 2025

Using aiokafka with opentelemetry-instrumentation cause memory leak

Status: Open.

#1100 In aio-libs/aiokafka;

·yonathan-wolloch-lendbuzz openedon Mar 25, 2025

[QUESTION] How to remove warning:"aiokafka sending username and password in the clear"

question

Status: Open.

#1099 In aio-libs/aiokafka;

·achilou openedon Mar 25, 2025

KeyError when trying to commit offsets using Transactional Producer

Status: Open.

#1098 In aio-libs/aiokafka;

·marcosschroh openedon Mar 11, 2025

AIOKafkaConsumer throws corrupted message exceptions on big-endian OS

Status: Open.

#1097 In aio-libs/aiokafka;

·ChupaCabre openedon Mar 10, 2025

[QUESTION] In AIOKafkaProducer.__init__ is acks=-1 exactly the same as acks="all" ?

question

Status: Open.

#1096 In aio-libs/aiokafka;

·hellocoldworld openedon Feb 27, 2025

UnknownTopicOrPartitionError cause infinite loop inside aiokafka.consumer.group_coordinator GroupCoordinator class, commit_offsets function

Status: Open.

#1095 In aio-libs/aiokafka;

·moranmoshe openedon Feb 26, 2025

Not compatible with kafka-python 2.0.4

Status: Open.

#1094 In aio-libs/aiokafka;

·VF-Eylers openedon Feb 24, 2025

StaleLeaderEpochCodeError renamed/removed, error code 13 is NetworkExceptionError

Status: Open.

#1093 In aio-libs/aiokafka;

·miloaissatu openedon Feb 24, 2025

Transactional Example not working

Status: Open.

#1091 In aio-libs/aiokafka;

·marcosschroh openedon Feb 7, 2025

[KIP 932] Share Groups Support

enhancement

Status: Open.

#1089 In aio-libs/aiokafka;

·rupurt openedon Jan 28, 2025