$ wget https://packages.confluent.io/archive/3.0/confluent-3.0.1-2.11.zip

$ unzip confluent-3.0.1-2.11.zip

$ cd confluent-3.0.1

# Lancer Zookeeper
$ bin/zookeeper-server-start ./etc/kafka/zookeeper.properties

# Lancer Kafka  (dans une nouvelle console)
$ bin/kafka-server-start ./etc/kafka/server.properties

# Lancer Schema Registry (dans une nouvelle console)
$ bin/schema-registry-start ./etc/schema-registry/schema-registry.properties

$ bin/kafka-topics  --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic mytopic

#Lister les topics
$ bin/kafka-topics --list --zookeeper localhost:2181

$ git clone https://github.com/oraclewalid/kafka-101.git

$ cd kafka-101

$ mvn clean package

# Lancer Consumer
$ mvn exec:java -Dexec.mainClass="com.fabulouslab.kafka.Consumer"

# Lancer Producer (dans une nouvelle console)
$ mvn exec:java -Dexec.mainClass="com.fabulouslab.kafka.Producer"