Skip to content

Latest commit

 

History

History
32 lines (25 loc) · 884 Bytes

README.md

File metadata and controls

32 lines (25 loc) · 884 Bytes
Raw

Start message bus and game-events topic

  1. Open terminal window and start the zookeeper service
cd ~/kafka/kafka_2.13-2.7.0/
bin/zookeeper-server-start.sh config/zookeeper.properties
  1. In a new terminal tab, start the broker service
bin/kafka-server-start.sh config/server.properties
  1. In a new terminal tab, create a game-events topic and publish event messages
bin/kafka-topics.sh --create --topic game-events --bootstrap-server localhost:9092
  1. Publish event messages
bin/kafka-console-producer.sh --topic game-events --bootstrap-server localhost:9092
  1. Add event messages at prompt

Sample event messages

  • BeginTeamCompetition 
    {"BeginTeamCompetition": {"home_team_id": 1, "away_team_id": 2, "venue_id": 1}}