java-code

all kinds of java code in different topics or fields

kafka

run and test a kafka cluster

run a kafka code, please install docker and docker-compose

sudo docker-compose run target

then, the docker will give a bash back.run below command to start a producer

mvn install
mvn exec:java -Dexec.mainClass="com.sky.code.kafka.CustomPartitionProducer"

open another terminal,and run

sudo docker-compose run target

in the returned bash, run below command to start a consumer.

mvn exec:java -Dexec.mainClass="com.sky.code.kafka.CustomPartitionConsumer"

you will see the both processes, one produce a message then another will consume it.

destroy a cluster

sudo docker-compose down