diff --git a/_posts/2023-03-20-apache-kafka-skim-through-kafka-connect.md b/_posts/2023-03-20-apache-kafka-skim-through-kafka-connect.md index 1524d6b..dc89435 100644 --- a/_posts/2023-03-20-apache-kafka-skim-through-kafka-connect.md +++ b/_posts/2023-03-20-apache-kafka-skim-through-kafka-connect.md @@ -17,7 +17,9 @@ tags: [kafka] ![ingest-data-upstream-systems](https://github.com/taehyeok-jang/taehyeok-jang.github.io/assets/31732943/1262f09a-5c1f-49b5-b5b3-1538c196112d) -![kafka_connect_architecture](/Users/jth/Desktop/Screenshot/kafka_connect_architecture.png) +![kafka_connect_architecture](https://github.com/taehyeok-jang/taehyeok-jang.github.io/assets/31732943/3bbde458-0427-4c7b-ba60-b743a3bc747b) + + Kafka Connect는 Apache Kafka의 컴포넌트들 중 하나로, database, 클라우드 서비스, 검색 인덱스, 파일 시스템, 키-값 저장소와 같은 다른 시스템과의 streaming을 수행하는 데 사용됩니다. @@ -195,7 +197,7 @@ curl --request POST 'localhost:8083/connectors' \ 파일에 텍스트를 입력합니다. -```java +```shell > echo hello >> test.txt > echo world >> test.txt > echo !!! >> test.txt @@ -206,7 +208,7 @@ curl --request POST 'localhost:8083/connectors' \ 데이터가 source로부터 잘 입력되었는지 확인합니다. -``` +```shell > ./kafka-console-consumer.sh --bootstrap-server ec2-kafka:9092 --topic connect-test --from-beginning {"schema":{"type":"string","optional":false},"payload":"hello"} {"schema":{"type":"string","optional":false},"payload":"world"}