191.2. 옵션

구성 (일반)

끝점에서 재사용할 공통 옵션으로 Kafka 구성 요소를 사전 구성할 수 있습니다.

KafkaConfiguration

브로커 (일반)

사용할 Kafka 브로커의 URL입니다. 형식은 host1:port1,host2:port2이며 목록은 브로커의 하위 집합 또는 브로커 서브 세트를 가리키는 VIP일 수 있습니다. 이 옵션을 Kafka 문서의 bootstrap.servers라고 합니다.

문자열

WorkerPool (advanced)

kafka 서버 이후에 Exchange를 계속 라우팅하기 위해 공유 사용자 지정 작업자 풀을 사용하려면 비동기 비 차단 처리를 사용하여 KafkaProducer에서 보낸 메시지를 승인합니다. 이 옵션을 사용하는 경우 더 이상 필요하지 않은 경우 풀을 종료하기 위해 스레드 풀의 라이프사이클을 처리해야 합니다.

ExecutorService

useGlobalSslContext 매개변수 (보안)

글로벌 SSL 컨텍스트 매개 변수의 사용을 활성화합니다.

false

boolean

breakOnFirstError (consumer)

이 옵션은 소비자가 교환을 처리하고 실패하는 경우 발생하는 상황을 제어합니다. 옵션이 false인 경우 소비자는 다음 메시지를 계속 처리하고 처리합니다. 옵션이 true인 경우 소비자는 오류를 초래한 메시지의 오프셋을 다시 검색한 다음 이 메시지를 처리하도록 다시 시도합니다. 그러나 이것은 언제든지 실패 할 때마다 동일한 메시지의 끝없는 처리로 이어질 수 있습니다, 예를 들면 독소 메시지. 따라서 예를 들어 Camel의 오류 처리기를 사용하여 이를 처리하는 것이 좋습니다.

false

boolean

allowManualCommit (consumer)

KafkaManualCommit를 통해 수동 커밋을 허용할지 여부입니다. 이 옵션을 활성화하면 KafkaManualCommit 인스턴스가 Exchange 메시지 헤더에 저장되므로 최종 사용자가 Kafka 소비자를 통해 수동 오프셋 커밋을 수행할 수 있습니다.

false

boolean

kafkaManualCommit Factory (consumer)

KafkaManualCommit 인스턴스 생성에 사용할 팩토리입니다. 이를 통해 사용자 지정 팩토리를 플러그인하여 사용자 정의 KafkaManualCommit 인스턴스를 생성할 수 있습니다. 이 인스턴스를 기본 구현에서 벗어나는 수동 커밋을 수행할 때 특수 논리가 필요합니다.

KafkaManualCommit Factory

resolveProperty Placeholders (advanced)

구성 요소가 시작 시 자체적으로 속성 자리 표시자를 확인해야 하는지 여부입니다. String 유형의 속성만 속성 자리 표시자를 사용할 수 있습니다.Only properties which are of String type can use property placeholders.

true

boolean

shutdownTimeout (common)

소비자 또는 생산자가 종료되고 작업자 스레드를 종료할 때까지 대기하는 시간(밀리초)입니다.

30000

int