Skip to content

Running Java Based Kafka Producer & Consumer

Awantik Das edited this page Aug 18, 2020 · 4 revisions

Link of Application - https://github.com/edyoda/kafka-cassandra-tutorial/blob/master/kakfa-producer-consumer-new.zip

Steps 0. Run Zookeeper & Kafka Server

  1. Create Topic
  2. Unzip the above directory
  3. Import as maven project
  4. Explore & run the application
  5. Java version should be 1.8
  6. Update the maven project
  7. Create topic is Kafka
  8. Run producer, only
  9. Run consumer, only

Changing Java version - https://stackoverflow.com/questions/8122843/how-to-have-eclipse-use-jdk8-to-compile-a-project

Clone this wiki locally