/kafka-producer

Example of a Kafka Producer that is using Snappy Compression

Primary LanguageJava

kafka-producer

Example of a Kafka Producer that is using Snappy Compression

Setting Env Vars

export KAFKA_PRDCR_HOST=127.0.0.1 export KAFKA_PRDCR_PORT=2181 export KAFKA_TOPIC=test