Apache Kafka 시작하기
Apache Kafka를 설치하기 전에 Java가 설치되어 있고 sudo 권한이 있는 사용자 계정이 있어야 합니다. 또한 Kafka를 제대로 실행하려면 2GB 이상의 RAM을 사용하는 것이 좋습니다.
다음 단계에서는 Apache Kafka를 설치하는 방법을 안내합니다.
자바 설치
Kafka를 설치하려면 Java가 필요합니다. 다음 명령을 사용하여 버전을 확인하여 Ubuntu에 Java가 설치되어 있는지 확인하십시오.
$ 자바 --버전
Java가 설치되지 않은 경우 다음 명령을 사용하여 Java OpenJDK를 설치하십시오.
$ 수도 적절한 설치 기본 jdk
사용자 계정 만들기
Java가 이미 설치된 상태에서 루트가 아닌 사용자 계정을 만듭니다. 또한 다음 명령을 사용하여 sudo 그룹에 사용자를 추가하여 일부 sudo 권한을 부여해야 합니다.
$ 수도 adduser 리눅스 힌트
$ 수도 adduser 리눅스 힌트 수도
새로 생성된 사용자 계정으로 로그인합니다.
카프카 설치
공식 다운로드 페이지에서 최신 Apache Kafka를 다운로드해야 합니다. 다음을 사용하여 바이너리 파일을 다운로드하십시오. wget 다음과 같이 명령합니다.
$ wget https: // // downloads.apache.org / 카프카 / 3.2.3 / 카프카_2.12-3.2.3.tgz 
바이너리 파일이 다운로드되면 다음을 사용하여 압축을 풉니다. 소요 명령을 실행하고 압축을 푼 디렉토리를 /opt/카프카.
다음으로 생성 시스템 스크립트 위해 사육사 그리고 카프카 서비스를 시작하고 중지하는 데 도움이 되는 서비스.
선택한 편집기를 사용하여 시스템 스크립트를 만들고 다음 내용을 붙여넣습니다. 사육사부터 시작:
$ 수도 나노 / 등 / 시스템 / 체계 / 사육사.서비스다음을 붙여넣습니다.
[ 단위 ]설명 =Apache Zookeeper 서버
선적 서류 비치 =http: // // Zookeeper.apache.org
필요 =network.target 원격 fs.target
후에 =network.target 원격 fs.target
[ 서비스 ]
유형 =단순
실행 시작 = / 고르다 / 카프카 / 큰 상자 / 사육사 서버 시작.sh / 고르다 / 카프카 / 구성 / 사육사.properties
ExecStop = / 고르다 / 카프카 / 큰 상자 / 사육사-서버-스톱.sh
재시작 =비정상
[ 설치 ]
원티드바이 =다중 사용자.대상
파일을 저장합니다. Kafka용 systemd 파일을 만들고 다음 내용을 붙여넣습니다.
붙여넣을 때 시스템에 설치한 Java의 올바른 경로를 설정했는지 확인하십시오.
[ 단위 ]설명 =아파치 카프카 서버
선적 서류 비치 =http: // // kafka.apache.org / 문서.html
필요 = 사육사.서비스
[ 서비스 ]
유형 =단순
환경 = 'JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64'
실행 시작 = / 고르다 / 카프카 / 큰 상자 / kafka-server-start.sh / 고르다 / 카프카 / 구성 / 서버.속성
ExecStop = / 고르다 / 카프카 / 큰 상자 / kafka-server-stop.sh
재시작 =비정상
[ 설치 ]
원티드바이 =다중 사용자.대상
완료되면 systemd 데몬을 다시 로드하여 변경 사항을 적용합니다.
다음으로 Zookeeper 서비스를 활성화하고 다음 명령을 사용하여 시작합니다.
$ 수도 systemctl 주키프 시작 < 강한 > 아르 자형 강한 >
Kafka에 대해서도 동일한 작업을 수행해야 합니다.
$ 수도 systemctl 시작 카프카
서비스를 시작하면 Kafka에서 주제를 생성하기 전에 서비스 상태를 확인할 수 있습니다.
Kafka의 좋은 점은 사용할 수 있는 스크립트가 여러 개 있다는 것입니다.
라는 이름의 새 주제를 만들어 보겠습니다. 리눅스힌트1 를 사용하여 kafka-topics.sh 하나의 파티션과 복제가 있는 스크립트. 다음 명령을 사용합니다.
$ 수도 -안에 리눅스힌트 / 고르다 / 카프카 / 큰 상자 / kafka-topics.sh --만들다 --부트스트랩-서버 로컬 호스트: 9092 --복제 인자 1 --파티션 1 --주제 리눅스힌트1 
주제가 생성되었습니다. 이를 확인하기 위해 이전 메시지를 볼 수 있습니다.
또는 다음을 사용하여 사용 가능한 주제를 나열할 수 있습니다. -목록 다음 명령의 옵션입니다. 우리가 만든 주제를 반환해야 합니다:S
$ 수도 -안에 리눅스힌트 / 고르다 / 카프카 / 큰 상자 / kafka-topics.sh --목록 --부트스트랩-서버 로컬 호스트: 9092 
Kafka 주제가 생성되면 스트림 데이터 쓰기를 시작할 수 있습니다. Kafka-console-producer.sh 그리고 그것이 당신의 소비자.sh.
셸을 열고 다음과 같이 생산자.sh를 사용하여 생성한 주제에 액세스합니다.
$ 수도 -안에 리눅스힌트 / 고르다 / 카프카 / 큰 상자 / kafka-console-producer.sh --브로커 목록 로컬 호스트: 9092 --주제 리눅스힌트1 
그런 다음 다른 셸을 열고 consumer.sh를 사용하여 Kafka 주제에 액세스합니다.
두 개의 셸을 연 상태에서 생산자 콘솔에서 메시지를 보낼 수 있습니다. 무엇을 입력하든 Apache Kafka가 실행 중임을 확인하는 소비자 콘솔에 반영됩니다.
결론
이 안내서를 사용하면 이제 Ubuntu 22.04에 Apache Kafka를 설치하기 위해 따를 수 있는 모든 단계가 있습니다. 각 단계를 수행하고 Apache Kafka를 설치하고 간단한 소비자 및 생산자 프로덕션을 실행하기 위한 주제를 생성했으면 합니다. 대량 생산에서도 동일하게 구현할 수 있습니다.