kafka 설치 및 터미널 실행

설치
https://dlcdn.apache.org/kafka/

1. 주키퍼 실행

bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

2. 카프카 실행

bin/kafka-server-start.sh -daemon config/server.properties

3. 카프카 토픽 생성

bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092

--create : 생성
--topic : topic 명
--bootstrap-server : 연결한 카프카 서버 주소
--partitions : 생성하는 토픽의 파티션 수
--replication-factor : 생성하는 토픽의 각 파티션의 replication-factor 개수
4. 확인

bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092

Producer 실행

bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092

Consumer 실행

bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092

https://javascript.plainenglish.io/a-beginners-introduction-to-kafka-with-typescript-using-nestjs-7c92fe78f638

실행안될때
config 폴더 내에 있는 zookeeper.properties를 열어서 포트를 바꾼다 server.properties도 열어서 포트를 바꾼다 주키퍼의 포트도 바꿔야함
Apache kafka: Failed to acquire lock on file .lock in tmp/kafka-logs 이런 에러가 나오면 터미널에 다음 명령어를 입력한다

rm /tmp/kafka-logs/.lock.

https://stackoverflow.com/questions/37294996/apache-kafka-failed-to-acquire-lock-on-file-lock-in-tmp-kafka-logs