MacBook M1에 Kafka 설치 및 테스트하기

### MacBook M1에 아파치 카프카 설치 및 테스트하기
* 💻 오늘은 많은 회사에서 고성능 데이터 파이프라인 스트리밍 분석을 위해 사용하는 오픈 소스 분산 이벤트 스트리밍 플랫폼인 **Kafka에 대한 소개**부터 시작하여 **MacBook M1에 Apache Kafka를 설치하는 방법**을 안내해드리겠습니다.
* 🔗 시작하려면 Google에서 "Kafka Apache"를 검색하여 공식 Apache Kafka 사이트를 방문하면 **기본 버전 및 Confluent Kafka와 같은 엔터프라이즈 버전**을 포함하여 Kafka를 다운로드할 수 있는 리소스를 찾을 수 있습니다.
* 📥 설치하려면 **G 형식 등 원하는 버전**을 다운로드할 수 있으며, 다운로드가 완료되면 원하는 폴더에 압축을 풀고 바이너리 폴더로 이동하여 Kafka 에코시스템을 실행하는 데 필요한 스크립트에 액세스합니다.
* ⚙ 다운로드 후 특정 줄을 주석 처리하고 로컬 사용에 적합한 IP 주소를 설정하고 터미널에서 **Confluent의 홈 경로**를 설정하여 `server.properties` 파일을 구성해야 합니다.
* ☕ Java 15와 같은 상위 버전은 지원되지 않으므로 성공적인 작동을 위해 **Java 11로 전환**해야 할 수 있으므로 **JDK 버전 1.8 또는 11**을 사용 중인지 확인하세요.
* 🛠 Java가 올바르게 설정되면 **`confluent local services start` 명령**을 사용하여 Kafka 서비스를 시작할 수 있으며, 그러면 **Zookeeper, Kafka 및 기타 에코시스템의 구성 요소**가 시작됩니다.
* 📊 서비스를 시작한 후 **`localhost:9021`로 제어 센터에 접속**하여 테스트 주제를 생성하고 메시지를 생성 및 소비하여 기능을 확인하여 설치가 성공적으로 완료되었는지 확인할 수 있습니다.
* 마지막으로, 모든 서비스를 중지하고 생성된 토픽을 정리하여 깔끔한 환경을 유지하여 **MacBook M1에서 원활한 Kafka 환경**을 보장하세요.

Kafka는 효율적인 데이터 파이프라인과 분석을 지원하는 강력한 오픈 소스 이벤트 스트리밍 플랫폼입니다.

How to install Confluent Kafka in mac m1

Shri Krishna Sankirtanam

Kafka는 고성능 데이터 파이프라인 및 분석에 사용되는 오픈 소스 분산 이벤트 스트리밍 플랫폼입니다.

엔터프라이즈 버전인 Confluent Kafka는 추가 구성 요소를 제공하며 다운로드하려면 라이선스가 필요합니다.

Kafka를 다운로드하고 압축을 풀면 바이너리 폴더에 Kafka를 시작하고 메시지를 생성/소비하기 위한 명령을 포함하여 로컬에서 Kafka 에코시스템을 실행하는 스크립트가 포함되어 있습니다.

MacBook M1에서 Confluent Kafka 설정하기

구성에서 특정 줄의 주석을 해제하여 Zookeeper 및 Kafka의 IP 주소와 프로토콜을 설정해야 합니다.

Confluent Kafka의 홈 경로를 설정하고 경로에 바이너리를 포함하세요.

상위 버전은 지원되지 않으므로 JDK 1.

11을 사용하고 있는지 확인하고 올바른 아키텍처 플래그를 사용하여 Kafka 시작 명령을 실행하세요.

Java 11로 전환하고 Kafka 서비스 시작하기

이 프로세스에는 Java 11로 전환하고 터미널의 Intel 아키텍처용 Rosetta 설정을 사용하는 것이 포함됩니다.

Java 11을 설정한 후, "confluent 로컬 서비스 시작" 명령을 실행하여 Zookeeper 및 제어 센터를 포함한 모든 Kafka 서비스를 시작합니다.

이 설정은 로컬 개발용이며, 프로덕션 사용에는 라이선스가 필요합니다.

카프카 테스트하기: 토픽 및 메시징 만들기

Kafka는 포트 9021에서 실행 중이며, 에코시스템은 브로커, 파티션 및 복제본을 자동으로 생성합니다.

"test"라는 이름의 테스트 항목이 기본 파티션으로 생성됩니다.

메시지는 Kafka의 콘솔 생산자 및 소비자 명령을 사용하여 생성 및 소비되며, 메시지는 즉시 교환됩니다.

생산자 서비스와 소비자 서비스가 모두 실행되어 Kafka 설정이 완료되었습니다.

서비스를 중지하려면 명령을 사용하여 서비스를 하나씩 종료합니다.

마지막으로 생성된 토픽을 정리하는 명령이 제공됩니다.