[
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)
