commands.sh.txt

# List
docker-compose exec kafka /opt/kafka/bin/kafka-topics.sh --list --zookeeper zookeeper:2181

# Consumer
docker-compose exec kafka /opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic eventsim-topic --from-beginning

# Producer
docker-compose exec kafka /opt/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic eventsim-topic

# Event producer
cd eventsim
export JAVA_HOME=$(/usr/libexec/java_home)
bin/eventsim -c "examples/example-config.json" --from 2 --nusers 10 --kafkaTopic eventsim-topic --kafkaBrokerList localhost:9092

bin/eventsim -c "examples/example-config.json" --from 30 --nusers 1000 --kafkaTopic eventsim-topic --kafkaBrokerList localhost:9092

kafka_2.11-1.0.1/bin/connect-standalone.sh connect-standalone.properties elasticsearch-connect.properties

#logstash
logstash-5.6.8/bin/logstash -f kafka-elasticsearch.conf