큐잉 제한: buffer.memory를 사용하여 보내지 않은 메시지를 수집하기 위해 Java 클라이언트에서 사용할 수 있는 총 메모리를 제한합니다. 이 제한에 도달하면 생산자는 예외를 발생하기 전에 max.block.ms 한 동안 추가 송신을 차단합니다. 또한 레코드대기열을 무기한 유지하지 않으려면 request.timeout.ms 사용하여 시간 시간을 설정할 수 있습니다. 메시지를 성공적으로 보내기 전에 이 시간 지정이 만료되면 큐에서 제거되고 예외가 throw됩니다. PARTITIONER_CLASS_CONFIG: 레코드가 이동하는 파티션을 결정하는 데 사용할 클래스입니다. 데모 항목에서는 파티션이 하나뿐이므로 이 속성을 주석으로 언급했습니다. 사용자 지정 파티셔인터페이스를 구현하여 사용자 지정 파티셔를 만들 수 있습니다. 예: 소비자 기록 API는 Kafka 클러스터에서 레코드를 수신하는 데 사용됩니다. 이 API는 레코드가 수신되는 토픽 이름, 파티션 번호및 Kafka 파티션의 레코드를 가리키는 오프셋으로 구성됩니다.
ConsumerRecord 클래스는 특정 주제 이름, 파티션 수 및 쌍을 사용하여 소비자 레코드를 만드는 데 사용됩니다. 다음 서명이 있습니다. 5. .binwindowskafka-server-start.bat.configserver.properties를 실행하여 카프카를 시작합니다. 이후, 우리는 기본 구성에 어떤 변경 하지 않은, Kafka 실행 해야 하 고 실행 http://localhost:9092 다음 우리는 주제를 구독 하는 간단한 소비자를 만들 거 야. 새 메시지가 토픽에 게시될 때마다 해당 메시지를 읽고 콘솔에 인쇄합니다. 소비자 코드는 생산자 코드와 매우 유사합니다. 먼저 java.util.Properties의 개체를 만들고 소비자 별 속성을 설정한 다음 이를 사용하여 KafkaConsumer의 새 개체를 만듭니다. ConsumerConfig 클래스는 설정할 수 있는 모든 속성을 정의합니다. 네 가지 필수 속성이 있습니다: KafkaProducerExample Kafka 레코드 키 직렬화로 구성 되 면 Long Serializer를 가져옵니다 및 레코드 값 serializer로 구성 되 면 StringSerializer를 가져옵니다. 상수 BOOTSTRAP_SERVERS는 localhost:9092,localhost:9093,localhost:9094로 설정되어 있으며, 마지막 단원에서 시작한 세 개의 Kafka 서버입니다.
세 개의 Kafka 서버가 모두 실행되고 있는지 확인하십시오. 상수 토픽은 방금 만든 복제된 Kafka 토픽으로 설정됩니다. 지난 몇 년 동안, 아파치 카프카는 다양한 사용 사례를 해결하기 위해 등장했다. 가장 간단한 경우 응용 프로그램 로그를 저장하기 위한 간단한 버퍼일 수 있습니다. Spark Streaming과 같은 기술과 결합하여 최종 목적지에 저장하기 전에 데이터 변경 사항을 추적하고 해당 데이터에 대한 조치를 취하는 데 사용할 수 있습니다.