Issues
- 4
- 1
- 4
[QUESTION] Restarting `AIOKafkaConsumer` after `AIOKafkaConsumer.stop()`
#1010 opened by dom-gunstone - 0
- 0
Admin client: list offsets per topic/partition
#1045 opened by noamta-gloat - 13
Proposal to Add Type Hints
#980 opened by alm0ra - 1
[QUESTION] Is there a way to monitor the heartbeat state?
#1041 opened by simonzhlx - 0
[QUESTION] Is there a way to monitor the heartbeat state?
#1040 opened by simonzhlx - 0
- 0
- 5
- 4
IncompatibleBrokerVersion: Kafka broker does not support the 'CreateTopicsRequest_v0' Kafka protocol.
#1008 opened by mjunaidca - 4
Losing Messages Between Producer and Consumer
#1031 opened by hakan458 - 10
- 0
- 7
- 3
A large and controversial proposal: replace protocol implementation with kio
#1027 opened by antonagestam - 0
Add client.rack configuration option to support consumer fetching from closest replica (KIP-392)
#1016 opened by trentbitterman - 1
Connection errors are spamming
#1020 opened by legau - 1
- 1
- 0
Can't Recover From NotLeaderForPartitionError
#1018 opened by oferda4 - 0
[QUESTION] Is there support to refresh OAuth tokens automatically based on token expiration duration?
#1015 opened by sara-han - 0
[QUESTION] How to close connection if Kafka server isn't responding?
#1013 opened by conradogarciaberrotaran - 9
I keep getting MessageSizeTooLargeError, error message gives size much bigger than actual message were given to producer.
#966 opened by ant0nk - 8
- 1
Unexpected error during batch delivery
#1004 opened by KPull - 0
- 3
- 4
[QUESTION] How to get old messages from topics?
#998 opened by solidguy7 - 0
[QUESTION] Unable connect to node with id: X: [Errno 111]: Connection refused
#992 opened by OlehDziuba - 0
High Incoming request sum on Azure Event Hub
#990 opened by jmd9019 - 0
invalid Type AioKafkaAdminClient create_partitions
#977 opened by alm0ra - 0
Regarding Kafka Connection
#976 opened by Vishvshah16 - 0
asyncio.exceptions.CancelledError
#974 opened by spff - 1
Can't connect to kafka docker
#968 opened by vladimircape - 5
Add delete_records to the admin client
#967 opened by vmaurin - 3
- 0
Add create_acls function for kafka admin client
#955 opened by reidmeyer - 1
- 16
Python 3.12.0 compatibility issue
#928 opened by pawel-swiecki-saucelabs - 1
- 1
Can I use Azure Event Hubs with `aiokafka`?
#945 opened by junyeong-huray - 1
AIOKafkaAdminClient.create_topics fails randomly because it selects a node at random
#939 opened by y4n9squared - 0
Inconsistent producer start/stop
#938 opened by valq7711 - 1
[QUESTION] Perfomance producer with large messages
#924 opened by YraganTron - 0
- 1
- 0
Snappy package doesn't support Python 3.11
#930 opened by ahmetanbar - 1