image.png

타임리프 폼 → 스프링 컨트롤러(producer) → 카프카(broker) → 스프링 컨트롤러(consumer)

  1. 타임리프 폼 → 스프링 컨트롤러(producer)
    1. 폼 데이터 형식으로 전달
  2. 스프링 컨트롤러(producer) → 카프카(broker)
  3. 카프카(broker) → 스프링 컨트롤러(consumer)

KRaft 구성하기 & Spring Boot 로 들어온 메세지 카프카에 보내기

[Kafka] Docker로 Kafka 세팅하기 (Kraft 방식, M1 Mac)

[kafka] Spring실행 시 consumer 연결문제 해결

[Kafka] SpringBoot3.x.x에서 Kafka 연동하기

# kafka-compose.yml 실행
docker compose -f kafka-compose.yml up -d
# docer compose up -d

# 토픽 생성
kafka-topics.sh --create --topic order-request --bootstrap-server mooney-broker01:9092,mooney-broker02:9092,mooney-broker03:9092 --partitions 3 --replication-factor 2

# 컨테이너 실행 & bash 실행
docker exec -it mooney-broker01 /bin/bash

# 토픽 생성 (한 컨테이너에서만 해도 자동 적용)
kafka-topics.sh --create --topic order-request --bootstrap-server mooney-broker01:9092,mooney-broker02:9092,mooney-broker03:9092 --partitions 3 --replication-factor 2

# 토픽 프로듀서로 메세지 전송
kafka-console-producer.sh --topic order-request --bootstrap-server mooney-broker01:9092,mooney-broker02:9092,mooney-broker03:9092

# 토픽 컨슈머로 메세지 확인
kafka-console-consumer.sh --topic order-request --from-beginning --bootstrap-server mooney-broker01:9092,mooney-broker02:9092,mooney-broker03:9092

카프카 메세지 Spring Boot 에서 받기

springboot에 kafka 설치하기

타임리프 폼 데이터를 컨트롤러에서 받아오기