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

Name		Name	Last commit message	Last commit date
Latest commit History 7 Commits
src/main/java/kafka/example		src/main/java/kafka/example
.gitignore		.gitignore
README.md		README.md
example.csv		example.csv
pom.xml		pom.xml