Skip to content Skip to sidebar Skip to footer
Showing posts with the label Apache Kafka
Apache Flink: Kafka Connector In Python Streaming Api, "cannot Load User Class"

Apache Flink: Kafka Connector In Python Streaming Api, "cannot Load User Class"

Post a Comment
I am trying out Flink's new Python streaming API and attempting to run my script with ./flink-1… Read more Apache Flink: Kafka Connector In Python Streaming Api, "cannot Load User Class"
Kafka Consumer Losing State Of Messages After Shutdown

Kafka Consumer Losing State Of Messages After Shutdown

Post a Comment
Thanks for taking time to answer the question. I am using kafka with a python consumer. Everything … Read more Kafka Consumer Losing State Of Messages After Shutdown
Nobrokersavailable: Nobrokersavailable-kafka Error

Nobrokersavailable: Nobrokersavailable-kafka Error

Post a Comment
i have already started to learn Kafka. Trying basic operations on it. I have stucked on a point whi… Read more Nobrokersavailable: Nobrokersavailable-kafka Error
No Module Named 'pyspark.streaming.kafka' Even With Older Spark Version

No Module Named 'pyspark.streaming.kafka' Even With Older Spark Version

Post a Comment
In another similar question, they hint 'install older spark 2.4.5.' EDIT: the solution from… Read more No Module Named 'pyspark.streaming.kafka' Even With Older Spark Version
Kafka-python Consumer Start Reading From Offset (automatically)

Kafka-python Consumer Start Reading From Offset (automatically)

Post a Comment
I'm trying to build an application with kafka-python where a consumer reads data from a range o… Read more Kafka-python Consumer Start Reading From Offset (automatically)
How To Produce A Tombstone Avro Record In Kafka Using Python?

How To Produce A Tombstone Avro Record In Kafka Using Python?

Post a Comment
my sink properties : { 'name': 'jdbc-oracle', 'config': { 'conn… Read more How To Produce A Tombstone Avro Record In Kafka Using Python?
How To Consume Messages Using Beam's External Kafka Transform (locally)

How To Consume Messages Using Beam's External Kafka Transform (locally)

Post a Comment
I am trying to run an app that uses a kafka producer (Python client), and an apache beam pipeline t… Read more How To Consume Messages Using Beam's External Kafka Transform (locally)
Python Kafka Consumer Doesn't Receive The Message From Beginning?

Python Kafka Consumer Doesn't Receive The Message From Beginning?

Post a Comment
I installed Kafka on my Windows PC. Created a topic quickstart-events and sent some messages. Runni… Read more Python Kafka Consumer Doesn't Receive The Message From Beginning?