Kafka-Python provides low-level protocol support for Apache Kafka as well as high-level consumer and producer classes.
I have a Kafka10 cluster with SASL_SSL (Authentication( JAAS ) and Authorization) enabled. Able to connect thru SASL using the …
python apache-kafka kafka-pythoni am using kafka-python to consume messages from a kafka queue (kafka version 0.10.2.0). In particular i am using KafkaConsumer type. …
python apache-kafka kafka-pythonI am trying to pass data from kafka to spark streaming. This is what I've done till now: Installed both …
apache-spark apache-kafka spark-streaming kafka-pythonI am getting this error when constructing KafkaProducer with the kafka-python package: [ERROR] UnrecognizedBrokerVersion: UnrecognizedBrokerVersion Traceback (most recent call last): …
python apache-kafka kafka-python aws-mskThis project is for real time search engine - log analysis performance. I have a live streaming data out from …
python flask socket.io flask-socketio kafka-pythonI am using the below code to read messages from a topic. I am facing two issues. Whenever i start …
python apache-kafka kafka-pythonWe have a message scheduler that generates a hash-key from the message attributes before placing it on a Kafka topic …
python unit-testing apache-kafka kafka-pythonI am trying to send a very simple JSON object through Kafka and read it out the other side using …
python json kafka-pythonI am trying to send a large CSV to kafka. The basic structure is to read a line of the …
python apache-spark apache-kafka pyspark kafka-pythonI am a fairly new in Python and starting with Kafka. I have a requirement where I need to send …
python python-3.x apache-kafka kafka-python