aiokafka

aiokafka copied to clipboard

KafkaConnectionError for Azure Event Hub during connect phase

5

We are using a Azure Event Hub as our Kafka compatible broker. We noticed, that occasionally the connection process does not complete successfully, but throws the following error: ``` DEBUG:aiokafka:Attempting...

TribuneX

admin client - failure to create topics or delete topics (error code 41)

31

* Use controller node for create and delete topic instead of random * Fixes error code 41 on create and delete topic

kbhatiya999

Consumer stopped consuming, task Fetcher._fetch_task has finished

5

**Describe the bug** Under unclear conditions, our consumer has stopped receiving messages. We investigated, when it happens, `_fetch_task` is finished, despite the `Fetcher` object is still alive (`Fetcher.close()` was not...

pavelschon

I am using Kafka in my software. It is consuming messages from kafka topic continuously. I am not closing the connection but starting and stopping the Kafka Consumer and Producer...

Vishvshah16

Try to reproduce error 41

1

### Changes The goal of this branch is to reproduce an error of not sending the create/delete topics command to the controller, and getting an error code 41, to then...

vmaurin

**Describe the bug** A clear and concise description of what the bug is. ``` Traceback (most recent call last): File "venv/lib/python3.9/site-packages/aiokafka/util.py", line 41, in wait_for return await fut asyncio.exceptions.CancelledError During...

spff

Can't connect to kafka docker

1

Here is my Docker for Kafka `version: "3" services: kafka-0: image: docker.io/bitnami/kafka:${KAFKA_VERSION} hostname: kafka-0 container_name: kafka-0 extra_hosts: - "host.docker.internal:host-gateway"` ports: - "9094:9094" environment: - KAFKA_BROKER_ID=0 - KAFKA_ENABLE_KRAFT=yes # KRaft settings...

ghost

I keep getting MessageSizeTooLargeError, error message gives size much bigger than actual message were given to producer.

9

I'm using avro serialization and nevertheless I'm receiving errors like "The message is 1699136 bytes when serialized which is larger than the maximum request size you have configured with the...

ant0nk

I'd like to see the AIOKafkaAdminClient have a create_acls function like kafka-python does. https://github.com/dpkp/kafka-python/blob/b68f61d49556377bf111bebb82f8f2bd360cc6f7/kafka/admin/client.py#L667

reidmeyer

Let's put `aiokafka` under the `aio-libs` org on PyPI

10

See the details @ https://github.com/orgs/aio-libs/discussions/26. For this, we'll need somebody with Owner privileges to either give me access on PyPI (the username there is the same — `webknjaz`) or be...

webknjaz