- apache-kafka : kafka_2.12-2.8.0
- java : 1.8
- maven : 3.6.3
application.yml
에서 local-kafka(개별 구축하신 kafka) 정보 입력
bootstrap-servers
, src-topic-name
, dest-topic-name
수정 필요
![image](https://user-images.githubusercontent.com/10006290/143025663-e71f66bc-2e3e-4eeb-9661-dcc2264e144a.png)
- maven 빌드 이후, java application 실행
mvn clean package
java -jar target/deview-2021-kafka-streams-0.0.1-SNAPSHOT.jar
- local-kafka 구동
$KAFKA_HOME/bin/kafka-server-start.sh start $KAFKA_HOME/config/server.properties
- 위 방법에 따른 demo app 빌드 및 수행
- local-kafka에서 다음과 같은 명령 수행
# src-topic produce, 임의의 문자열 유입
$KAFKA_HOME/bin/kafka-console-producer.sh --broker-list test-kafka:9092 --topic src-topic
# src-topic consume, src-topic 데이터 확인
$KAFKA_HOME/apps/kafka/bin/kafka-console-consumer.sh --bootstrap-server test-kafka:9092 --topic src-topic
# dest-topic consume, demo-app에 대해 가공된 데이터 확인
$KAFKA_HOME/apps/kafka/bin/kafka-console-consumer.sh --bootstrap-server test-kafka:9092 --topic dest-topic