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?