Kafka Streams - Spring boot example
test topic 데이터를 consume하고, " "(공백)단위로 구분하여 test2 topic으로 produce하는 것을 목표로 하였다. 방법은 크게 두가지로 시도하였다. 1) Component로 선언하여 stream을 start해주는 방법 2) Autowired 어노테이션을 통해 StreamsBuilder을 주입받는 방법 → 참고: https://www.baeldung.com/spring-boot-kafka-streams (Topology: https://kafka.apache.org/0102/documentation/streams/core-concepts#streams_topology) 핵심은 Topology를 만드는 것인데, 1번의 경우 Topology를 만들고, stream을 start한 반면..
Spring
2022. 5. 17. 15:21
공지사항
최근에 올라온 글
최근에 달린 댓글
- Total
- Today
- Yesterday
링크