You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Prashanto (Jira)" <ji...@apache.org> on 2021/07/16 06:10:00 UTC

[jira] [Resolved] (KAFKA-13047) KafkaConsumer is unable to consume messages from a topic created by confluent-kafka-python client

     [ https://issues.apache.org/jira/browse/KAFKA-13047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Prashanto resolved KAFKA-13047.
-------------------------------
    Resolution: Workaround

Got a cue from the confluent-kafka-python team - [https://github.com/confluentinc/confluent-kafka-python/issues/1158.] 
I was using a now deprecated consumer setting that read messages from latest. After removing the setting and recreating the topic, Kafka streams is able to consume message from a topic created using confluent-kafka-python library.

> KafkaConsumer is unable to consume messages from a topic created by confluent-kafka-python client
> -------------------------------------------------------------------------------------------------
>
>                 Key: KAFKA-13047
>                 URL: https://issues.apache.org/jira/browse/KAFKA-13047
>             Project: Kafka
>          Issue Type: Bug
>          Components: clients
>    Affects Versions: 2.8.0
>            Reporter: Prashanto
>            Priority: Blocker
>         Attachments: ApacheKafkaConsumer.txt
>
>
> I have a Python microservice that creates a Kafka topic using confluent-kafka-python client. I am writing a Java Kafka Streams client that is unable to retrieve any messages from this topic. To debug this issue, I wrote a simple KafkaConsumer client that is also unable to consume messages from the topic. I have attached the debug logs from the run. Any pointers will be sincerely appreciated.
> If I create a topic using kafka-topics.sh script, the consumer is able to successfully consume messages.
> Kafka broker version: 2.2.2



--
This message was sent by Atlassian Jira
(v8.3.4#803005)