9장. Kafka 클라이언트
kafka-clients
JAR 파일에는 Kafka AdminClient API와 함께 Kafka Producer 및 Consumer API가 포함되어 있습니다.
- Producer API를 사용하면 애플리케이션이 Kafka 브로커에 데이터를 보낼 수 있습니다.
- Consumer API를 사용하면 애플리케이션이 Kafka 브로커의 데이터를 사용할 수 있습니다.
- AdminClient API는 주제, 브로커 및 기타 구성 요소를 포함하여 Kafka 클러스터를 관리하는 기능을 제공합니다.
9.1. Kafka 클라이언트를 Maven 프로젝트에 종속성으로 추가
다음 절차에서는 AMQ Streams Java 클라이언트를 Maven 프로젝트에 종속성으로 추가하는 방법을 보여줍니다.
사전 요구 사항
-
기존
pom.xml
이 있는 Maven 프로젝트입니다.
프로세스
pom.xml
파일의 <repositories
> 섹션에 Red Hat Maven 리포지토리를 추가합니다.<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <!-- ... --> <repositories> <repository> <id>redhat-maven</id> <url>https://maven.repository.redhat.com/ga/</url> </repository> </repositories> <!-- ... --> </project>
pom.xml
파일의<dependencies
> 섹션에 클라이언트를 추가합니다.<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <!-- ... --> <dependencies> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>3.1.0.redhat-00004</version> </dependency> </dependencies> <!-- ... --> </project>
- Maven 프로젝트를 빌드합니다.