1장. 클라이언트 개발 개요

메시지를 생성하거나 메시지를 사용하거나 둘 다 수행할 수 있는 Streams for Apache Kafka 설치에 대한 Kafka 클라이언트 애플리케이션을 개발합니다. RHEL의 OpenShift에서 Streams for Apache Kafka 또는 Streams for Apache Kafka와 함께 사용할 클라이언트 애플리케이션을 개발할 수 있습니다.

메시지는 선택적 키와 메시지 데이터가 포함된 값과 헤더 및 관련 메타데이터로 구성됩니다. 키는 메시지의 제목 또는 메시지의 속성을 식별합니다. 전송된 것과 동일한 순서로 메시지 그룹을 처리해야 하는 경우 동일한 키를 사용해야 합니다.

메시지는 일괄 처리로 전달됩니다. 메시지에는 메시지의 타임스탬프 및 오프셋 위치와 같이 클라이언트별 필터링 및 라우팅에 유용한 세부 정보를 제공하는 헤더 및 메타데이터가 포함되어 있습니다.

Kafka는 클라이언트 애플리케이션을 개발하기 위한 클라이언트 API를 제공합니다. Kafka 생산자 및 소비자 API는 클라이언트 애플리케이션에서 Kafka 클러스터와 상호 작용하는 기본 수단입니다. API는 메시지 흐름을 제어합니다. 생산자 API는 Kafka 주제로 메시지를 보내는 반면 소비자 API는 주제에서 메시지를 읽습니다.

Apache Kafka용 스트림은 Java로 작성된 클라이언트를 지원합니다. 클라이언트를 개발하는 방법은 특정 사용 사례에 따라 다릅니다. 데이터 지속성은 우선 순위가거나 처리량이 높을 수 있습니다. 이러한 요구 사항은 클라이언트 및 브로커의 구성을 통해 충족될 수 있습니다. 그러나 모든 클라이언트는 지정된 Kafka 클러스터의 모든 브로커에 연결할 수 있어야 합니다.