Search results

Is KIP-345 supported by kafka-python?

consumer

Status: Open.

#2147 In dpkp/kafka-python;

· DenisKuplyakov opened on Oct 22, 2020

Support for KIP-429: Incremental rebalancing

consumer

Status: Open.

#2143 In dpkp/kafka-python;

· prathap-pft opened on Oct 16, 2020

KIP-392: Include client.rack property in Kafka Consumer

consumer

Status: Open.

#2131 In dpkp/kafka-python;

· ramperher opened on Sep 22, 2020

Make the consumer.close() graceful

consumer

Status: Open.

#1811 In dpkp/kafka-python;

· jeffwidman opened on May 23, 2019

Write tests to verify consumer can handle race conditions between metadata updates/ group rebalances

consumer

test coverage

Status: Open.

#1251 In dpkp/kafka-python;

· jeffwidman opened on Oct 9, 2017

Add <code>wakeup</code> to Consumer as in Java Client

consumer

enhancement

Status: Open.

#1148 In dpkp/kafka-python;

· tvoinarovskyi opened on Jul 14, 2017

Add a test that when groupcoordinator dies, the consumer will pick up the new coordinator

consumer

test coverage

Status: Open.

#1134 In dpkp/kafka-python;

· jeffwidman opened on Jun 30, 2017

Add context manager support to Consumers and producers

consumer

producer

Status: Open.

#1101 In dpkp/kafka-python;

· lyytinen opened on May 11, 2017

Consumer proceeds on when ConsumerRebalanceListener fails

consumer

Status: Open.

#917 In dpkp/kafka-python;

· braedon opened on Dec 20, 2016

KafkaConsumer.subscribe(topics='t', pattern='^t') should throw ValueError not AssertionError

consumer

Status: Open.

#891 In dpkp/kafka-python;

· jeffwidman opened on Nov 29, 2016