Java 구현에서는 생산자의 IO 스레드에서 실행되므로 이 콜백에서 비용이 많이 드는 작업을 수행하지 않아야 합니다. ./bin/kafka-topics.sh–목록 –사육사 로컬 호스트:2181 . rd_kafka_produce에 대한 두 번째 인수를 사용하여 메시지에 대해 원하는 파티션을 설정할 수 있습니다. 이 경우와 같이 RD_KAFKA_PARTITION_UA로 설정된 경우 librdkafka는 기본 파티션을 사용하여 이 메시지의 파티션을 선택합니다. 세 번째 인수는 librdkafka 페이로드와 키를 복사해야한다는 것을 나타냅니다. 핵심 구성: 생산자가 Kafka 클러스터를 찾을 수 있도록 bootstrap.servers 속성을 설정해야 합니다. 필수는 아니지만 브로커의 요청을 만든 클라이언트 인스턴스와 쉽게 상호 연관시킬 수 있으므로 항상 client.id 설정해야 합니다. 이러한 설정은 Java, C/C++, 파이썬, Go 및 .NET 클라이언트에서 동일합니다. 2.
폴더 C:D소프트웨어kafka_2.12-1.0.1config 및 편집 server.properties StringSerializer와 유사, Kafka int 및 long 같은 다른 프리미티브에 대 한 직렬화기를 제공 합니다. 키 나 값에 대 한 사용자 지정 개체를 사용 하려면 org.apache.kafka.common.serialization.Serialization를 구현 하는 클래스를 만들어야 합니다. 그런 다음 논리를 추가하여 클래스를 바이트[]로 직렬화할 수 있습니다. 또한 소비자 코드에서 해당 직렬화기를 사용해야 합니다. 당신은 아파치 카프카가 상자 밖으로 작동하는 방법을 보았다. 다음으로 사용자 지정 생산자/소비자 응용 프로그램을 개발해 보겠습니다. 생산자는 콘솔에서 사용자 입력을 검색하고 각 새 줄을 Kafka 서버에 메시지로 보냅니다. 소비자는 지정된 토픽에 대한 메시지를 검색하여 콘솔에 인쇄합니다. 이 경우 생산자 및 소비자 구성 요소는 kafka-console-producer.sh 및 kafka-console-consumer.sh 고유한 구현입니다.
이 문서에서는 windows 로컬 컴퓨터에서 kafka를 설정하고 maven 프로젝트를 사용하여 Java에서 Kafka 소비자 및 생산자를 만드는 방법에 대해 설명했습니다. 아래의 코멘트 섹션에서 의견을 공유할 수 있습니다. Kafka 서버는 바이트[] 키,바이트[] 값 형식으로 메시지를 기대합니다. Kafka의 클라이언트 쪽 라이브러리는 모든 키와 값을 변환하는 대신 String 및 int와 같은 친숙한 형식을 사용하여 메시지를 보낼 수 있도록 합니다. 라이브러리는 이를 적절한 유형으로 변환합니다. 예를 들어 샘플 앱에는 메시지별 키가 없으므로 키에 null을 사용합니다. 값에 대 한 콘솔에서 사용자가 입력 하는 데이터는 문자열을 사용 합니다. 이 예제에서는 한 Kafka 토픽에서 사용하고 다른 Kafka 토픽으로 생성하는 방법을 보여 주었습니다. Java 생산자에는 send() API가 포함되어 있으며, 이 API는 전송 결과를 얻기 위해 폴링할 수 있는 미래를 반환합니다. 자바 프로젝트 빌드 경로에 다음 항아리를 추가합니다.참고 : 항아리는 https://kafka.apache.org/downloads 아파치 카프카 다운로드의 lib 폴더에서 사용할 수 있습니다. 예제에서 암시하는 것처럼 생산자당 하나의 열린 트랜잭션만 있을 수 있습니다.
beginTransaction() 및 commitTransaction() 호출 간에 전송된 모든 메시지는 단일 트랜잭션의 일부가 됩니다. transactional.id 지정되면 생산자가 보낸 모든 메시지가 트랜잭션의 일부여야 합니다. librdkafka의 배달 콜백은 rd_kafka_poll를 호출하여 사용자의 스레드에서 호출됩니다. 일반적인 패턴은 produce API를 호출할 때마다 이 함수를 호출하는 것이지만 메시지 생성 속도가 안정적이지 않은 경우 일반 배달 보고서를 확인하는 데 충분하지 않을 수 있습니다.
