5장. Kafka 브리지 인터페이스
Kafka 브리지는 HTTP 기반 클라이언트가 Kafka 클러스터와 상호 작용할 수 있는 RESTful 인터페이스를 제공합니다. 클라이언트 애플리케이션이 Kafka 프로토콜을 해석할 필요 없이 AMQ Streams에 웹 API 연결의 이점을 제공합니다.
API에는 Kafka 클러스터의 소비자 및 생산자와 상호 작용하기 위해 끝점을 통해 노출되고 액세스할 수 있는 두 가지 주요 리소스가 있습니다. 리소스는 Kafka에 직접 연결된 소비자 및 생산자가 아닌 Kafka 브릿지에만 관련이 있습니다.
5.1. HTTP 요청
Kafka 브리지는 다음을 수행하는 방법을 사용하여 Kafka 클러스터에 대한 HTTP 요청을 지원합니다.
- 메시지를 주제로 보냅니다.
- 주제에서 메시지 검색.
- 주제의 파티션 목록을 검색합니다.
- 소비자를 생성 및 삭제합니다.
- 소비자는 이러한 주제에서 메시지를 수신하기 시작할 수 있도록 주제를 구독하십시오.
- 소비자가 서브스크립션하는 주제 목록을 검색합니다.
- 주제에서 소비자의 구독을 취소합니다.
- 소비자에 파티션을 할당합니다.
- 소비자 오프셋 목록을 커밋합니다.
- 소비자가 첫 번째 또는 마지막 오프셋 위치 또는 지정된 오프셋 위치에서 메시지를 수신하기 시작하도록 파티션을 찾습니다.
이 방법은 JSON 응답 및 HTTP 응답 코드 오류 처리를 제공합니다. 메시지는 JSON 또는 바이너리 형식으로 보낼 수 있습니다.
클라이언트는 네이티브 Kafka 프로토콜을 사용해야 하는 요구 사항 없이 메시지를 생성하고 사용할 수 있습니다.
추가 리소스
- 요청 및 응답 예제를 포함하여 API 문서를 보려면 AMQ Streams Kafka Bridge 사용을 참조하십시오.