카프카 스트리밍 플랫폼에 대한 카프카 자습서. 명령줄에서 몇 가지 작은 예제와 함께 Kafka 아키텍처를 다룹니다. 그런 다음 다중 서버 예제를 통해 이 작업을 확장합니다. 마지막으로, 우리는 카프카 생산자와 카프카 소비자에 대한 몇 가지 간단한 자바 클라이언트 예제를 추가했습니다. 우리는 카프카의 디자인 토론과 상관 관계를 맺기 위해 Java 예제를 확장하기 시작했습니다. 우리는 또한 카프카 디자인 섹션에 확장하고 참조를 추가했습니다. http://kafka.apache.org/downloads.html 가서 스칼라 2.12를 다운로드하십시오. 이 버전은 스칼라와 zookepper이미 포함되어 있습니다. 아래 단계에 따라 카프카를 설정합니다. 우선, 로컬 시스템에 아파치 카프카를 설치하고 구성하는 것을 시작하고 1 파티션으로 간단한 주제를 만들고 생산자와 소비자를위한 자바 프로그램을 작성합시다. 이 프로젝트는 메이븐 기반 프로젝트가 될 것입니다.

그런 다음 여러 파티션과 소비자 그룹의 소비자 수와 동등한 수의 다른 토픽을 만들어 파티션 간의 소비 균형을 조정합니다. 또한, 우리는 다른 소비자의 여러 자바 구현을 해야합니다. 1- 컴파일 및 예제 프로그램을 패키지포함다음 명령을 사용하여 저장소를 컴파일 : 다음은 예 카프카 응용 프로그램의 일부입니다 : 당신이 jdk 8 이미 설치한 가정은 우리가 설치 및 사육사를 구성 시작하자 에 윈도우.다운로드 사육사 에서 https://zookeeper.apache.org/releases.html. 나는 카프카 lib 디렉토리에서와 같이 사육사 버전 3.4.10을 다운로드한, 사육사의 기존 버전은 3.4.10.Once 다운로드, 다음 단계를 수행 : 소비자는 구성으로 속성 객체를 제공함으로써 인스턴스화된다. 생산자의 StringSerialization와 마찬가지로 소비자의 StringDeserializer가 바이트를 다시 Object.group.id 변환하는 것은 속성이 있어야 하며 여기에 임의의 값입니다. 이 값은 우리가 브로커의 소비자 그룹이있을 때 kafka 브로커에게 중요합니다. 이 그룹 ID를 사용하면 kafka 브로커는 동일한 메시지가 한 번 더 소비되지 않도록 하여 소비자 그룹 중 한 구성원만 메시지를 소비할 수 있음을 의미합니다. 3 단계: 예제 프로그램에 대 한 주제 만들기메시지는 생산자가 메시지를 게시하고 소비자가 메시지를 읽는 주제에 의해 구성됩니다. 샘플 응용 프로그램은 빠른 메시지와 요약 마커의 두 가지 주제를 사용합니다. 다음 명령은 주제를 만듭니다: 시작하기를 돕기 위해 Kafka 컨설팅을 제공합니다.

아파치 카프카 분산 스트리밍 플랫폼은 가장 강력하고 널리 사용되는 신뢰할 수있는 스트리밍 플랫폼 중 하나입니다. Kafka는 내결함성, 확장성이 높으며 로그 집계, 스트림 처리, 이벤트 소스 및 커밋 로그에 사용됩니다. 자바 프로젝트 빌드 경로에 다음 항아리를 추가합니다.참고 : 항아리는 https://kafka.apache.org/downloads 아파치 카프카 다운로드의 lib 폴더에서 사용할 수 있습니다.