위의 코드 조각은 일부 속성을 가진 Kafka 소비자를 만듭니다. Kafka에서 클라이언트는 오프셋 수를 기억하고 메시지를 검색할 책임이 있습니다. Kafka 서버는 메시지 소비를 추적하거나 관리하지 않습니다. 기본적으로 Kafka 서버는 7일 동안 메시지를 유지합니다. 서버의 백그라운드 스레드는 7일 이상인 메시지를 확인하고 삭제합니다. 소비자는 서버에 있는 한 메시지에 액세스할 수 있습니다. 메시지를 여러 번 읽을 수 있으며 메시지를 역순으로 읽을 수도 있습니다. 그러나 소비자가 7일이 끝나기 전에 메시지를 검색하지 못하면 해당 메시지가 누락됩니다. 우리는 카프카와 아마존 AWS에 대한 철저한 이해를 가지고 있습니다. Aws에서 Kafka 스트리밍 플랫폼을 성공적으로 사용하고 AWS에 배포하여 프로덕션을 지원할 수 있는 배경이 있습니다.

카프카를 신속하게 스핀 업하고 생산에 지원해야하는 경우, 우리를 고용하십시오. 우리는 당신이 비용이 많이 드는 실수를 방지 할 수 있도록 할 수 있습니다. 우리는 또한 멘토링과 카프카 교육을 제공합니다. 카프카 뮤직 애플리케이션은 음악 장르당 최신 5곡 등 최신 차트를 실시간으로 실시간으로 계산하는 간단한 음원 차트 애플리케이션을 구축하는 방법을 보여줍니다. REST API를 통해 Kafka의 대화형 쿼리 기능을 통해 최신 처리 결과(최신 차트)를 노출합니다. 응용 프로그램의 입력 데이터는 Avro 형식으로, 따라서 Confluent 스키마 레지스트리의 사용, 그리고 두 소스에서 온다: 재생 이벤트의 스트림 (생각: “노래 X 재생 되었습니다”) 그리고 노래 메타 데이터의 스트림 (“노래 X 아티스트 Y에 의해 작성 되었습니다”). 이 예제에서는 구성이 속성 파일에 외부화되고 KEY_SERIALIZER_CLASS_CONFIG: 키 개체를 직렬화하는 데 사용할 클래스입니다. 이 예제에서는 키가 길기 때문에 Long Serializer 클래스를 사용하여 키를 직렬화할 수 있습니다. 사용 사례에서 다른 개체를 키로 사용하는 경우 Kafka의 serializer 인터페이스를 구현하고 serialize 메서드를 재정의하여 사용자 지정 serializer 클래스를 만들 수 있습니다.

생산자 클래스는 모든 Kafka 브로 커에 대한 생산자 풀 연결을 닫는 가까운 메서드를 제공합니다. 이제 다음과 같이 응용 프로그램 예제를 실행할 수 있습니다: 다음은 아파치 카프카에서 생산자의 작동을 보여주는 그림입니다. 이 섹션의 지침은 src/main/에서 응용 프로그램 예제를 대화형으로 테스트하려면 필요합니다. 현재 우리는 Kafka 클러스터에 메시지를 보낼 생산자를 만들었습니다. 이제 Kafka 클러스터를 형성하는 메시지를 소비하는 소비자를 만들어 보겠습니다. 카프카소비자 API는 카프카 클러스터의 메시지를 소비하는 데 사용됩니다. KafkaConsumer 클래스 생성자는 아래에 정의되어 있습니다. 카프카 스트리밍 플랫폼에 대한 카프카 자습서. 명령줄에서 몇 가지 작은 예제와 함께 Kafka 아키텍처를 다룹니다.

그런 다음 다중 서버 예제를 통해 이 작업을 확장합니다. 마지막으로, 우리는 카프카 생산자와 카프카 소비자에 대한 몇 가지 간단한 자바 클라이언트 예제를 추가했습니다. 우리는 카프카의 디자인 토론과 상관 관계를 맺기 위해 Java 예제를 확장하기 시작했습니다. 우리는 또한 카프카 디자인 섹션에 확장하고 참조를 추가했습니다. 메시지는 동기적으로 전송됩니다. isSync값을 true로 변경하여 비동기적으로 Kafka 클러스터로 메시지를 보낼 수 있습니다.