Kafka_Training_Python

KO | EN

gitlite — search

#python #react #typescript #golang #rust #deep-learning #linux #windows #cli #awesome-list #security #mcp #openai #open-source

Kafka_Training_Python

(★ 8)

Help's you get started with Kafka-Python

Kafka_Training_Python Latest Version Download

Download Latest Version (.zip)

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# Kafka_Training_Python

Here are well designed Python scripts which can help you get started with Kafka-Python.

Following are the list of topics that are covered with these examples:
 - Kafka Producer reading records from File.
 - Kafka Producer fetching records from MySql Database.
 - Kafka Consumer injecting records to MySql Database.
 - Encoding and Decoding Kafka messages in producer and consumer
 - Serialization and Deserialization of Kafka messages in Producer and Consumer.
 - Compression and Decompression of Kafka records in producer and consumer.

Following are the list of scripts present in the repo:

- FileAsSource.py : This is a producer file, which reads records from a file and send them as messages to consumer.
  - MysqlAsSource.py: This is a Producer file, which reads records from a MySql Database and send them as messages to consumer. The records are encoded when sent to consumer.
  - MysqlAsSink.py: This is a Consumer file, which injects the received records into MySql Database. The records are decoded at the consumer end.
  - ConsumerCompression.py: The records which are received are decompressed based on the compression type used in the Producer. 
  - ProducerCompression.py: The records are compressed using compressin type gZip. The compressed message are sent to consumer. 
Server.properties: This is kafka server properties file for reference.

Kafka_Training_Python

Kafka_Training_Python Latest Version Download

Today's picks

Was this content helpful?

Recent Feedback

Kafka_Training_Python

Kafka_Training_Python Latest Version Download

Today's picks

Was this content helpful?

Recent Feedback

Download README