aiokafka

aiokafka copied to clipboard

[QUESTION] Unable to request metadata from node with id 0: Unable to update metadata from [0]

15

Hello, I have problem with producer. I am using ```aiokafka==0.6.0 and kafka-2.5.0 (Commit:66563e712b0b9f84)``` First I connect and send data to kafka in AWS server successfully. Then I wait 10 minutes...

tnusraddinov

Add Producer waitlist for pending send() items

1

### Changes Fixes #528 ### Checklist - [X] I think the code is well written - [X] Unit tests for the changes exist - [X] Documentation reflects the changes -...

tvoinarovskyi

add test for sasl ssl

2

### Changes Hello! Thank you for great library! Just wanted to test if sasl_ssl auth method is working correctly while setting it up for my project. Realised that this scenario...

LizardWizzard

`assert assignment is not None and assignment.active` raising incorrectly

6

**Describe the bug** I have a program that runs two listener consumers that are told when to start command, and alert when one is finished. The start command consumer will...

cdgriffith

SASL connect fails with `RuntimeError: await wasn't used with future`

6

I'm trying to connect to my Kafka cluster (confluent cloud) using a modified version of the `ssl_consume_produce.py` example from the `AIOKafka` repo at . I've configured my `AIOKafkaConsumer` and `AIOKafkaProducer`...

galen211

how to handle UnknownTopicOrPartitionError?

4

What I want to do is subscribing topics that have name with specific pattern like `email.service.*` dynamically. that dynamically means that while it is consuming I should be able to...

dongho-jung

### Changes Really small logging change that confused me for a long time, until I realized it's a bug :-)

ran-ka

Stopping multiple consumers in a short window freezes on GroupCoordinator._heartbeat_routine()

6

**Describe the bug** I have several hundred consumers all connected to the same singular topic with autocommit disabled. Each consumer is part of a unique individual group. When I call...

RyanSept

Stop consumer raises CancelledError

2

Hello. I am using kafka consumer only for getting partitions for topic. And after that, I try to close consumer, but got CancelledError. It seems, that it might be some...

easysugar

[QUESTION] Which Partition to use when Performing a Offset Seek using AIOKafkaConsumer?

6

When trying to let an `AIOKafkaConsumer` start reading messages from a specific offset `starting_offset`, how do we know which partition to be used? I am trying to use the [`AIOKafkaConsumer.seek`][1]...

athenawisdoms