Confluent Demonstration - Tuong-Nguyen/Angular-D3-Cometd GitHub Wiki

Confluent is a platform which bases on Kafka and add more functionalities on it.

This is similar to Kafka Demonstration

Start/Stop the server

• Single shell for starting 4 services (Zookeeper - Kafka - Schema - Rest Proxy):
  .bin\confluent-zookeeper-kafka-schema-rest-start

• Stop services:
  .bin\confluent-zookeeper-kafka-schema-rest-stop

• Zookeeper

./bin/zookeeper-server-start ./etc/kafka/zookeeper.properties

• Kafka

./bin/kafka-server-start ./etc/kafka/server.properties

• Schema

./bin/schema-registry-start ./etc/schema-registry/schema-registry.properties

• Rest Proxy

./bin/kafka-rest-start ./etc/kafka-rest/kafka-rest.properties

Send and Receive data

• Producer

bin/kafka-console-producer --broker-list localhost:9092 --topic my_topic

• Consumer

bin/kafka-console-consume --bootstrap-server localhost:9092 --topic my_topic --from-beginning --zookeeper localhost:2181

Script for starting and stop multiple services

• confluent-zookeeper-kafka-schema-rest-start.sh:

base_dir=$(dirname $(dirname $0))
$base_dir/bin/zookeeper-server-start $base_dir/etc/kafka/zookeeper.properties &
$base_dir/bin/kafka-server-start $base_dir/etc/kafka/server.properties &
$base_dir/bin/kafka-rest-start $base_dir/etc/kafka-rest/kafka-rest.properties &
$base_dir/bin/schema-registry-start $base_dir/etc/schema-registry/schema-registry.properties &

• confluent-zookeeper-kafka-schema-rest-stop.sh

base_dir=$(dirname $(dirname $0))
$base_dir/bin/zookeeper-server-stop ; $base_dir/bin/kafka-server-stop ; $base_dir/bin/schema-registry-stop ; $base_dir/bin/kafka-rest-stop