마지막으로 거래 주문 데이터를 전송할 토픽(orders)과 지표 데이터를 전송할 토픽(metrics)을 생성하자.

$ bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic orders
$ bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic metrics
$ bin/kafka-topics.sh --list --zookeeper localhost:2181
metrics
orders

 

이제 예제 프로그램이 파일 시스템 대신 카프카로 데이터를 읽고 쓰도록 변경할 수 있다.