aiokafka
aiokafka copied to clipboard
aio-libs
asyncio client for kafka
fut = loop.create_task(consumer.commit()) fut.add_done_callback(on_commit_done)
**Describe the bug** If dev forgets to call `producer.start()`, the producer will gets stucked in some `await` on line `await self.force_metadata_update()` here: https://github.com/aio-libs/aiokafka/blob/master/aiokafka/client.py#L630 **Expected behaviour** I think there should be...
## Describe the bug If network was down during `await AIOKafkaConsumer.getone` the `await` will never get done. Even wrapping in `asyncio.wait_for` doesn't help. ## Expected behaviour Some kind of exception...
**Describe the bug** We received an alert from our error monitoring system. There are 3 log lines from `aiokafka` loggers at the time of the incident: ``` 2020-07-04T18:06:27.135 - Unable...
**Describe the bug** We are seeing this issue again with version 0.7.0 https://github.com/aio-libs/aiokafka/issues/261 Our consumer just stops after logging ```aiokafka.consumer.fetcher Fetch offset 2370539 is out of range for partition TopicPartition(topic='xxx-fxxxxx_hopping_table-changelog',...
Dear @asvetlov and @tvoinarovskyi, first things first: Thanks a bunch for conceiving and maintaining aiokafka during the last years. You know who you are. Now, I am humbly asking how...
### Changes Fixes #715 ### Checklist - [x] I think the code is well written - [x] Unit tests for the changes exist - [ ] Documentation reflects the changes...
**Describe the bug** After calling `await consumer.start()`, `AioKafkaConnection.__del__` calls `self._loop.call_exception_handler` after failing to connect to a Kafka node. If there is a failure during startup, but after the client is...
**Describe the bug** The consumer `end_offsets()` function checks the minimum Kafka API version is 0.10.0 claiming that "offsets_for_times API not supported". However, this is neither the "offsets_for_times API" and the...
**Describe the solution you'd like** It would be nice to have support for schema registry the way [confluent_kafka](https://github.com/confluentinc/confluent-kafka-python/blob/c32cd123264e010745ff3ccd245a1443aa057583/src/confluent_kafka/avro/serializer/message_serializer.py#L63) has it **Additional context** Avro has a JSON like data model, but...
