bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
bin/kafka-server-start.sh -daemon config/server.properties
tail -f logs/server.log
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic alerts
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic alerts
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic alerts
bin/kafka-server-stop.sh
bin/zookeeper-server-stop.sh
dmn-event-driven-quarkus の場合
$ docker-compose up -d
$ mvn clean compile quarkus:dev
$ cd /home/tkobayas/usr/local/Kafka/230/kafka_2.12-2.3.0
$ bin/kafka-console-producer.sh --broker-list localhost:9092 --topic dmn-event-driven-requests < sample2.json
http://localhost:9000 で topic の中身を確認
$ jq -rc . ./src/test/resources/events/evaluate_all/full_result/all/input.json | /home/tkobayas/usr/local/Kafka/230/kafka_2.12-2.3.0/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic dmn-event-driven-requests
もいける。
1行で渡すように
終了は
$ docker-compose down
