Kafka2 카프카 명령어 정리 Docker에서 실행법 docker-compose -f docker-compose.yml up -d 카프카 쉘 진입법(kafka는 docker에 올라간 컨테이너 이름) docker exec -it kafka /bin/sh cd /opt/kafka_2.13-2.8.1/bin 으로 진입 ls로 확인하면 여러 파일이 있어 여기서 토픽 관련 명령어 수행 가능합니다. 카프카 토픽 생성 kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic {topic_name} repication-factor는 브로커 1개이며 partition 1개로 생성하는 명령어입니다. 권장 브로커는 3개입니다. 카프카 토.. 2022. 2. 12. 스프링에서 카프카 시작하기 진행중인 프로젝트에 적용하기 전에 간단하게 카프카로 보내는 프로젝트를 만들어 보겠습니다. 1. 프로젝트 생성 start.spring.io에서 gradle, spring boot 2.5.9 버전 dependency에 spring web과 kafka, lombok, websocket을 추가해주세요. 2. 설정 값 생성 클래스 생성하셔서 아래 값을 기입해주세요. 토픽과 그룹 아이디, 주소를 주입해줄거에요. public class KafkaConstants { public static final String KAFKA_TOPIC = "kafka"; public static final String GROUP_ID = "test"; public static final String KAFKA_BROKER = "loc.. 2022. 2. 9. 이전 1 다음
