190.3. Spring Boot Auto-Configuration

camel.component.kafka.allow-manual-commit

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

false

부울

camel.component.kafka.break-on-first-error

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

false

부울

camel.component.kafka.brokers

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

문자열

camel.component.kafka.configuration.allow-manual-commit

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

false

부울

camel.component.kafka.configuration.auto-commit-enable

true인 경우 소비자가 이미 가져온 메시지의 오프셋을 주기적으로 ZooKeeper에 커밋합니다. 이 커밋된 오프셋은 프로세스가 새 소비자가 시작되는 위치로 실패할 때 사용됩니다.

true

부울

camel.component.kafka.configuration.auto-commit-interval-ms

소비자 오프셋이 zookeeper에 커밋되는 ms의 빈도입니다.

5000

정수

camel.component.kafka.configuration.auto-commit-on-stop

브로커가 마지막으로 소비된 메시지의 커밋을 보장하기 위해 소비자가 중지될 때 명시적 자동 커밋을 수행할지 여부입니다. 이를 위해서는 autoCommitEnable 옵션이 설정되어 있어야 합니다. 가능한 값은 sync, async 또는 none입니다. 그리고 sync는 기본값입니다.

sync

문자열

camel.component.kafka.configuration.auto-offset-reset

ZooKeeper에 초기 오프셋이 없거나 오프셋이 범위를 벗어나면 어떻게 해야 합니까 : 가장 빠른 오프셋으로 오프셋을 자동으로 재설정 : 자동으로 오프셋을 최신 오프셋 실패로 재설정합니다: 소비자에게 예외를 발생시킵니다.

latest

문자열

camel.component.kafka.configuration.break-on-first-error

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

false

부울

camel.component.kafka.configuration.bridge-endpoint

옵션이 true인 경우 KafkaProducer는 인바운드 메시지의 KafkaConstants.TOPIC 헤더 설정을 무시합니다.

false

부울

camel.component.kafka.configuration.brokers

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

문자열

camel.component.kafka.configuration.buffer-memory-size

생산자가 서버에 전송 대기 중인 레코드를 버퍼링하는 데 사용할 수 있는 총 메모리 바이트입니다. 레코드를 서버에 전달할 수 있는 경우, 생산자는 block.on.buffer.full에서 지정한 기본 설정에 따라 예외를 차단하거나 throw합니다. 이 설정은 생산자가 사용할 총 메모리에 대략적으로 대응해야 하지만 생산자가 버퍼링에 사용하는 모든 메모리를 사용하는 것은 아니므로 하드 바인딩되지는 않습니다. 압축( compression이 활성화된 경우) 및 진행 중인 요청을 유지하기 위해 일부 추가 메모리가 사용됩니다.

33554432

정수

camel.component.kafka.configuration.check-crcs

사용되는 레코드의 CRC32를 자동으로 확인합니다. 이렇게 하면 메시지에 대한 온-선 또는 디스크상의 손상이 발생하지 않습니다. 이 검사에서는 몇 가지 오버헤드가 추가되어 극단적인 성능을 찾는 경우 비활성화될 수 있습니다.

true

부울

camel.component.kafka.configuration.circular-topic-detection

옵션이 true인 경우 KafkaProducer는 메시지가 kafka 소비자에서 원래인 경우 메시지가 동일한 주제로 다시 전송되는지 여부를 감지합니다. KafkaConstants.TOPIC 헤더가 원래 kafka 소비자 주제와 동일한 경우 헤더 설정이 무시되고 생산자 끝점의 주제가 사용됩니다. 즉, 동일한 메시지를 다시 제공된 위치로 보내는 것을 방지할 수 있습니다. bridgeEndpoint 옵션이 true로 설정된 경우 이 옵션이 사용되지 않습니다.

true

부울

camel.component.kafka.configuration.client-id

클라이언트 ID는 호출 추적을 돕기 위해 각 요청에서 전송된 사용자 지정 문자열입니다. 요청을 수행하는 애플리케이션을 논리적으로 식별해야 합니다.

문자열

camel.component.kafka.configuration.compression-codec

이 매개변수를 사용하면 이 생산자가 생성한 모든 데이터에 대해 압축 코드를 지정할 수 있습니다. 유효한 값은 none, gzip 및 snappy입니다.

none

문자열

camel.component.kafka.configuration.connection-max-idle-ms

이 구성에서 지정한 시간(밀리초) 후에 유휴 연결을 종료합니다.

540000

정수

camel.component.kafka.configuration.consumer-request-timeout-ms

구성은 클라이언트가 요청 응답을 기다리는 최대 시간을 제어합니다. 시간 초과 시간이 경과하기 전에 응답이 수신되지 않으면 필요한 경우 클라이언트가 요청을 다시 보내거나 재시도가 소진된 경우 요청이 실패합니다.

40000

정수

camel.component.kafka.configuration.consumer-streams

소비자의 동시 소비자 수

10

정수

camel.component.kafka.configuration.consumers-count

kafka 서버에 연결하는 소비자 수

1

정수

camel.component.kafka.configuration.enable-idempotence

'true'로 설정하면 생산자가 각 메시지의 사본이 스트림에 정확히 하나 작성되도록 합니다. 'false'인 경우 생산자 재시도는 스트림에 재시도된 메시지의 중복을 작성할 수 있습니다. true로 설정하면 max.in.flight.requests.per.connection을 1로 설정하고 재시도를 0으로 설정할 수 없으며 추가로 ack을 'all'로 설정해야 합니다.

false

부울

camel.component.kafka.configuration.fetch-max-bytes

서버가 가져오기 요청에 대해 반환해야 하는 최대 데이터 양은 절대 최대값이 아닙니다. 가져오기의 첫 번째 메시지가 이 값보다 큰 경우 소비자가 진행할 수 있도록 메시지가 계속 반환됩니다. 브로커가 허용하는 최대 메시지 크기는 message.max.bytes(broker config) 또는 max.message.bytes(topic config)를 통해 정의됩니다. 소비자는 병렬로 여러 개의 가져오기를 수행합니다.

52428800

정수

camel.component.kafka.configuration.fetch-min-bytes

서버가 가져오기 요청에 대해 반환해야 하는 최소 데이터 양입니다. 데이터가 충분하지 않으면 요청에 응답하기 전에 많은 데이터가 누적될 때까지 요청은 기다립니다.

1

정수

camel.component.kafka.configuration.fetch-wait-max-ms

fetch.min.bytes를 즉시 충족할 데이터가 충분하지 않은 경우 서버가 가져오기 요청에 응답하기 전에 서버가 차단하는 최대 시간입니다.

500

정수

camel.component.kafka.configuration.group-id

이 소비자가 속한 소비자 프로세스 그룹을 고유하게 식별하는 문자열입니다. 동일한 그룹 id 여러 프로세스를 설정하면 모두 동일한 소비자 그룹의 일부임을 나타냅니다. 이 옵션은 사용자에게 필요합니다.

문자열

camel.component.kafka.configuration.header-filter-strategy

사용자 지정 HeaderFilterStrategy를 사용하여 Camel 메시지와의 헤더를 필터링합니다.

HeaderFilterStrategy

camel.component.kafka.configuration.heartbeat-interval-ms

Kafka의 그룹 관리 기능을 사용할 때 사용자 코디네이터로의 하트비트 사이의 예상 시간입니다. 하트비트는 고객의 세션이 활성 상태로 유지되고 새 소비자가 그룹에 참여하거나 나가는 경우 재조정을 용이하게 하는 데 사용됩니다. 이 값은 session.timeout.ms보다 작아야 하지만 일반적으로 해당 값의 1/3 이상을 설정해야 합니다. 정규 리밸런스에 대한 예상 시간을 제어하기 위해 더 낮게 조정할 수 있습니다.

3000

정수

camel.component.kafka.configuration.interceptor-classes

생산자 또는 소비자의 인터셉터를 설정합니다. 생산자 인터셉터는 org.apache.kafka.clients.producer.ProducerInterceptor Consumer 인터셉터를 구현하는 클래스여야 합니다. org.apache.kafka.clients.consumer.ConsumerInterceptor 참고: 소비자에서 Producer 인터셉터를 사용하는 경우 런타임에 클래스를 throw하게 됩니다.

문자열

camel.component.kafka.configuration.kafka-header-deserializer

deserialization kafka 헤더 값에 대해 사용자 정의 KafkaHeaderDeserializer를 설정합니다.

KafkaHeaderDeserializer

camel.component.kafka.configuration.kafka-header-serializer

serialization camel 헤더 값에 대한 사용자 정의 KafkaHeaderDeserializer를 kafka 헤더 값으로 설정합니다.

KafkaHeaderSerializer

camel.component.kafka.configuration.kerberos-before-relogin-min-time

새로 고침 시도 사이에 로그인 스레드 절전 시간입니다.

60000

정수

camel.component.kafka.configuration.kerberos-init-cmd

Kerberos kinit 명령 경로. 기본값은 /usr/bin/kinit입니다.

/usr/bin/kinit

문자열

camel.component.kafka.configuration.kerberos-principal-to-local-rules

보안 주체 이름에서 짧은 이름(일반적으로 운영 체제 사용자 이름)으로 매핑하는 규칙 목록입니다. 규칙은 순서대로 평가되며 보안 주체 이름과 일치하는 첫 번째 규칙은 짧은 이름으로 매핑하는 데 사용됩니다. 목록의 이후 규칙은 무시됩니다. 기본적으로 username/hostnameREALM 형식의 주체 이름은 사용자 이름에 매핑됩니다. 형식에 대한 자세한 내용은 보안 권한 부여 및 acls를 참조하십시오. 여러 값을 쉼표로 구분할 수 있습니다.

DEFAULT

문자열

camel.component.kafka.configuration.kerberos-renew-jitter

갱신 시간에 추가된 임의의 지터의 백분율입니다.

double

camel.component.kafka.configuration.kerberos-renew-window-factor

로그인 스레드는 마지막 새로 고침에서 티켓 만료에 도달한 시점까지 유휴 상태가 됩니다. 이 때 티켓 갱신을 시도합니다.

double

camel.component.kafka.configuration.key

레코드 키(또는 키가 지정되지 않은 경우 null)입니다. 이 옵션이 구성된 경우 헤더 KafkaConstants#KEY보다 우선합니다.

문자열

camel.component.kafka.configuration.key-deserializer

Deserializer 인터페이스를 구현하는 키에 대한 Deserializer 클래스입니다.

org.apache.kafka.common.serialization.StringDeserializer

문자열

camel.component.kafka.configuration.key-serializer-class

키의 serializer 클래스입니다(사용되지 않은 경우 메시지의 경우 기본 설정).

org.apache.kafka.common.serialization.StringSerializer

문자열

camel.component.kafka.configuration.linger-ms

생산자는 요청 전송 간에 들어오는 모든 레코드를 하나의 배치 요청으로 그룹화합니다. 일반적으로 이것은 레코드가 전송될 수 있는 것보다 더 빨리 도착한 경우에만 로드 중에 발생합니다. 그러나 경우에 따라 클라이언트는 중간 로드에서도 요청 수를 줄일 수 있습니다. 이 설정은 레코드를 즉시 보내는 대신 적은 양의 인공 지연을 추가하여 이를 수행합니다. 생산자는 다른 레코드를 보낼 수 있도록 지정된 지연까지 대기하여 전송이 함께 배치될 수 있도록 합니다. 이것은 TCP에서 Nagle의 알고리즘과 유사한 것으로 생각할 수 있습니다. 이 설정은 배치 지연에 대한 지연에 상한을 제공합니다. 즉, 파티션에 대한 레코드의 batch.size 가치가 있으면 이 설정에 관계없이 즉시 전송됩니다. 하지만 이 파티션에 대해 누적된 바이트 수보다 적은 경우 더 많은 레코드가 표시되도록 하는 지정된 시간 동안 'linger'을 'linger'합니다. 이 설정의 기본값은 0입니다(예: 지연 없음). 예를 들어, linger.ms=5를 설정하면 전송된 요청 수를 줄이는 효과가 있지만 부하 분산에서 전송된 레코드에는 최대 5ms의 대기 시간이 추가됩니다.

0

정수

camel.component.kafka.configuration.max-block-ms

설정은 kafka로 전송되는 시간을 제어합니다. 이러한 방법은 여러 가지 이유로 차단될 수 있습니다. 예를 들어 버퍼 전체 메타데이터는 사용할 수 없습니다. 이 구성은 메타데이터 가져오기, 키 및 값의 직렬화, send() 수행 시 버퍼 메모리의 분할 및 할당에 소요되는 총 시간에 최대 제한을 적용합니다. partitionsFor()의 경우 이 구성은 메타데이터 대기 시간에 대한 최대 시간 임계값을 적용합니다.

60000

정수

camel.component.kafka.configuration.max-in-flight-request

클라이언트가 차단하기 전에 단일 연결에서 보낼 수 있는 최대 확인되지 않은 요청 수입니다. 이 설정이 1보다 크게 설정되어 있고 전송에 실패한 경우 재시도 횟수로 인해 메시지 다시 정렬할 위험이 있습니다(예: 재시도가 활성화된 경우).

5

정수

camel.component.kafka.configuration.max-partition-fetch-bytes

서버가 반환할 파티션당 최대 데이터 양입니다. 요청에 사용된 최대 총 메모리는 #partitions max.partition.fetch.bytes입니다. 이 크기는 서버가 허용하는 최대 메시지 크기 또는 그 외에는 소비자가 가져올 수 있는 것보다 더 큰 메시지를 보낼 수 있어야 합니다. 이러한 경우 소비자는 특정 파티션에 큰 메시지를 가져 오기 위해 잠시 중지 할 수 있습니다.

1048576

정수

camel.component.kafka.configuration.max-poll-interval-ms

소비자 그룹 관리를 사용할 때 poll() 호출 사이의 최대 지연입니다. 이렇게 하면 더 많은 레코드를 가져오기 전에 소비자가 유휴 상태일 수 있는 시간을 상한하게 됩니다. 이 제한 시간 초과 전에 poll()을 호출하지 않으면 소비자는 실패로 간주되고 그룹이 파티션을 다른 멤버에 재할당하기 위해 리밸런스합니다.

long

camel.component.kafka.configuration.max-poll-records

poll()에 대한 단일 호출에서 반환된 최대 레코드 수입니다.

500

정수

camel.component.kafka.configuration.max-request-size

요청의 최대 크기입니다. 이는 실제로 최대 레코드 크기에 대한 제한이기도 합니다. 서버에는 레코드 크기와 다를 수 있는 자체 제한이 있습니다. 이 설정은 대규모 요청을 보내지 않도록 생산자가 전송하는 레코드 배치 수를 제한합니다.

1048576

정수

camel.component.kafka.configuration.metadata-max-age-ms

파티션 리더십 변경 사항이 표시되지 않은 경우에도 새로운 브로커 또는 파티션을 사전에 발견하기 위해 메타데이터의 새로 고침 시간(밀리초)입니다.

300000

정수

camel.component.kafka.configuration.metric-reporters

메트릭 보고자로 사용할 클래스 목록입니다. MetricReporter 인터페이스를 구현하면 새 지표 생성에 대한 알림을 받는 클래스를 연결할 수 있습니다. JMX 통계를 등록하기 위해 항상 JmxReporter가 포함되어 있습니다.

문자열

camel.component.kafka.configuration.metrics-sample-window-ms

메트릭을 계산하기 위해 유지되는 샘플 수입니다.

30000

정수

camel.component.kafka.configuration.no-of-metrics-sample

메트릭을 계산하기 위해 유지되는 샘플 수입니다.

2

정수

camel.component.kafka.configuration.offset-repository

주제의 각 파티션의 오프셋을 로컬로 저장하기 위해 사용할 오프셋 리포지토리입니다. 하나를 정의하면 자동 커밋이 비활성화됩니다.

StateRepository

camel.component.kafka.configuration.partition-assignor

그룹 관리를 사용할 때 클라이언트가 소비자 인스턴스에 파티션 소유권을 배포하는 데 사용할 파티션 할당 전략의 클래스 이름입니다.

org.apache.kafka.clients.consumer.RangeAssignor

문자열

camel.component.kafka.configuration.partition-key

레코드를 보낼 파티션(또는 파티션이 지정되지 않은 경우 null) 이 옵션을 구성한 경우 헤더 KafkaConstants#PARTITION_KEY보다 우선합니다.

정수

camel.component.kafka.configuration.partitioner

하위 주제 간 메시지를 분할하기 위한 partitioner 클래스입니다. 기본 파티션기는 키의 해시를 기반으로 합니다.

org.apache.kafka.clients.producer.internals.DefaultPartitioner

문자열

camel.component.kafka.configuration.poll-timeout-ms

KafkaConsumer를 폴링할 때 사용되는 시간 초과입니다.

5000

long

camel.component.kafka.configuration.producer-batch-size

생산자는 여러 레코드가 동일한 파티션으로 전송될 때마다 더 적은 요청으로 레코드를 배치하려고 합니다. 이렇게 하면 클라이언트와 서버 모두에서 성능이 향상됩니다. 이 구성은 기본 배치 크기(바이트)를 제어합니다. 이 크기보다 큰 레코드를 배치하려고 시도하지 않습니다. 브로커에 전송된 요청에는 여러 개의 배치가 포함됩니다. 데이터를 전송할 수 있는 파티션마다 하나씩 배치를 줄일 수 있습니다. 작은 배치 크기는 일괄 처리를 줄일 수 있으며 처리량을 줄일 수 있습니다(배치 배치 크기가 완전히 비활성화됨). 매우 큰 배치 크기는 메모리를 더 많이 사용할 수 있으며, 이는 추가 레코드를 예측할 때 항상 지정된 배치 크기의 버퍼를 할당하므로 메모리를 더 낭비할 수 있습니다.

16384

정수

camel.component.kafka.configuration.queue-buffering-max-messages

async 모드를 사용할 때 생산자를 차단하거나 데이터를 삭제해야 합니다.

10000

정수

camel.component.kafka.configuration.receive-buffer-bytes

데이터를 읽을 때 사용할 TCP 수신 버퍼(SO_RCVBUF)의 크기입니다.

65536

정수

camel.component.kafka.configuration.reconnect-backoff-max-ms

반복적으로 연결되지 않은 브로커에 다시 연결할 때 대기하는 최대 시간(밀리초)입니다. 제공되는 경우 연속된 각 연결 실패에 대해 호스트당 백오프가 이 최대값까지 기하급수적으로 증가합니다. 백오프 증가를 계산한 후 연결 폭풍을 피하기 위해 20 %의 난수 지터가 추가됩니다.

1000

정수

camel.component.kafka.configuration.reconnect-backoff-ms

지정된 호스트에 다시 연결하기 전에 대기하는 시간입니다. 이렇게 하면 긴밀한 루프에서 호스트에 반복적으로 연결하지 않아도 됩니다. 이 백오프는 소비자가 브로커로 보낸 모든 요청에 적용됩니다.

50

정수

camel.component.kafka.configuration.record-metadata

생산자가 RecordMetadata 결과를 Kafka로 전송할지 여부입니다. 결과는 RecordMetadata 메타데이터가 포함된 목록에 저장됩니다. 이 목록은 키 KafkaConstants#KAFKA_RECORDMETA를 사용하여 헤더에 저장됩니다.

true

부울

camel.component.kafka.configuration.request-required-acks

생산자가 인정하는 승인 수는 요청이 완료되기를 고려하기 전에 리더를 받아야 합니다. 이는 전송되는 레코드의 내구성을 제어합니다. 다음 설정은 일반적인 설정입니다. acks=0 If set to zero, the producer will not wait for any anowledgment from the server at all: acks=0 if set to zero, the producer will not wait for any anowledgment from the server at all. 이 레코드는 즉시 소켓 버퍼에 추가되고 전송된 것으로 간주됩니다. 이 경우 서버가 레코드를 수신했음을 보장할 수 없으며, 재시도 구성이 적용되지 않습니다(일반적으로 오류를 알 수 없기 때문입니다). 각 레코드에 대해 다시 지정된 오프셋은 항상 -1로 설정됩니다. acks=1은 관리자가 로컬 로그에 레코드를 기록하지만 모든 팔로어의 완전한 승인을 기다리지 않고 응답할 것입니다. 이 경우 관리자가 레코드를 인정한 직후에 실패하지만 팔로워가 복제되기 전에 레코드가 손실됩니다. acks=all: 리더는 레코드를 승인하기 위해 비동기 내 복제본의 전체 세트를 기다립니다. 이렇게 하면 하나 이상의 비동기 복제본이 활성 상태로 유지되는 한 레코드가 손실되지 않습니다.This guarantees that the record will not be lost as long as at least one in-sync replica remains alive. 이는 가장 강력한 보장입니다.

1

문자열

camel.component.kafka.configuration.request-timeout-ms

브로커가 요청.required.acks 요구 사항을 충족하기 위해 대기 중인 시간(시간)은 클라이언트에 오류를 보내기 전에 필요합니다.

305000

정수

camel.component.kafka.configuration.retries

0보다 큰 값을 설정하면 클라이언트가 잠재적으로 일시적인 오류로 전송에 실패하는 레코드를 다시 보냅니다. 이 재시도는 클라이언트가 오류를 수신할 때 레코드를 다시 보내는 경우와 다르지 않습니다. 재시도를 허용하면 두 레코드가 단일 파티션으로 전송되고 첫 번째 레코드가 실패하고 두 번째 레코드가 성공한 경우 두 번째 레코드가 먼저 표시될 수 있으므로 레코드 순서가 변경될 수 있습니다.

0

정수

camel.component.kafka.configuration.retry-backoff-ms

재시도마다 생산자가 관련 주제의 메타데이터를 새로 고침하여 새 리더가 선택되었는지 확인합니다. 리더 선택에는 약간의 시간이 걸리므로 이 속성은 메타데이터를 새로 고치기 전에 생산자가 대기하는 시간을 지정합니다.

100

정수

camel.component.kafka.configuration.sasl-jaas-config

kafka sasl.jaas.config 매개변수 예: org.apache.kafka.common.security.plain.PlainLoginModule 필수 username=USERNAME password=PASSWORD;

문자열

camel.component.kafka.configuration.sasl-kerberos-service-name

Kafka가 로 실행되는 Kerberos 사용자 이름입니다. 이는 Kafka의 JAAS 구성 또는 Kafka의 구성에서 정의할 수 있습니다.

문자열

camel.component.kafka.configuration.sasl-mechanism

SASL(Simple Authentication and Security Layer) Mechanism 사용 유효한 값은 http://www.iana.org/assignments/sasl-mechanisms/sasl-mechanisms.xhtml에서 참조하십시오.

GSSAPI

문자열

camel.component.kafka.configuration.security-protocol

브로커와 통신하는 데 사용되는 프로토콜입니다. 현재 PLAINTEXT 및 SSL만 지원됩니다.

일반 텍스트

문자열

camel.component.kafka.configuration.seek-to

KafkaConsumer가 시작 시 읽기 : 처음부터 읽기 : 결국 읽기는 이전 속성 seekToBeginning을 대체합니다.

문자열

camel.component.kafka.configuration.send-buffer-bytes

소켓 쓰기 버퍼 크기

131072

정수

camel.component.kafka.configuration.serializer-class

메시지의 serializer 클래스입니다.The serializer class for messages.

org.apache.kafka.common.serialization.StringSerializer

문자열

camel.component.kafka.configuration.session-timeout-ms

Kafka의 그룹 관리 기능을 사용할 때 오류를 감지하는 데 사용되는 시간 초과입니다.

10000

정수

camel.component.kafka.configuration.ssl-cipher-suites

암호화 제품군 목록입니다. 이는 TLS 또는 SSL 네트워크 프로토콜을 사용하여 네트워크 연결의 보안 설정을 협상하는 데 사용되는 인증, 암호화, MAC 및 키 교환 알고리즘의 명명된 조합입니다. 기본적으로 사용 가능한 모든 암호화 제품군이 지원됩니다.

문자열

camel.component.kafka.configuration.ssl-context-parameters

Camel SSLContextParameters 오브젝트를 사용한 SSL 구성. 구성된 경우 다른 SSL 끝점 매개변수보다 먼저 적용됩니다.

SSLContextParameters

camel.component.kafka.configuration.ssl-enabled-protocols

SSL 연결에 사용되는 프로토콜 목록입니다. TLSv1.2, TLSv1.1 및 TLSv1은 기본적으로 활성화되어 있습니다.

TLSv1.2,TLSv1.1,TLSv1

문자열

camel.component.kafka.configuration.ssl-endpoint-algorithm

서버 인증서를 사용하여 서버 호스트 이름을 검증하는 끝점 식별 알고리즘입니다.

문자열

camel.component.kafka.configuration.ssl-key-password

키 저장소 파일에 있는 개인 키의 암호입니다. 이는 클라이언트의 경우 선택 사항입니다.

문자열

camel.component.kafka.configuration.ssl-keymanager-algorithm

SSL 연결에 대한 키 관리자 팩토리에서 사용하는 알고리즘입니다. 기본값은 Java Virtual Machine에 대해 구성된 키 관리자 팩토리 알고리즘입니다.

SunX509

문자열

camel.component.kafka.configuration.ssl-keystore-location

키 저장소 파일의 위치입니다. 클라이언트의 경우 선택 사항이며 클라이언트의 양방향 인증에 사용할 수 있습니다.

문자열

camel.component.kafka.configuration.ssl-keystore-password

키 저장소 파일의 저장소 암호입니다. 클라이언트의 경우 선택 사항이며 ssl.keystore.location이 구성된 경우에만 필요합니다.

문자열

camel.component.kafka.configuration.ssl-keystore-type

키 저장소 파일의 파일 형식입니다. 이는 클라이언트의 경우 선택 사항입니다. 기본값은 JKS입니다.

JKS

문자열

camel.component.kafka.configuration.ssl-protocol

SSLContext를 생성하는 데 사용되는 SSL 프로토콜입니다. 기본 설정은 TLS로, 대부분의 경우에 적합합니다. 최근 JVM에서 허용되는 값은 TLS, TLSv1.1 및 TLSv1.2입니다. SSL, SSLv2 및 SSLv3은 이전 JVM에서 지원되지만 알려진 보안 취약점으로 인해 사용이 권장되지 않습니다.

TLS

문자열

camel.component.kafka.configuration.ssl-provider

SSL 연결에 사용되는 보안 공급자의 이름입니다. 기본값은 JVM의 기본 보안 공급자입니다.

문자열

camel.component.kafka.configuration.ssl-trustmanager-algorithm

SSL 연결에 대한 신뢰 관리자 팩토리에서 사용하는 알고리즘입니다. 기본값은 Java Virtual Machine에 대해 구성된 신뢰 관리자 팩토리 알고리즘입니다.

PKIX

문자열

camel.component.kafka.configuration.ssl-truststore-location

신뢰 저장소 파일의 위치입니다.

문자열

camel.component.kafka.configuration.ssl-truststore-password

신뢰 저장소 파일의 암호입니다.

문자열

camel.component.kafka.configuration.ssl-truststore-type

신뢰 저장소 파일의 파일 형식입니다. 기본값은 JKS입니다.

JKS

문자열

camel.component.kafka.configuration.topic

사용할 항목의 이름입니다. 소비자에서는 쉼표를 사용하여 여러 항목을 구분할 수 있습니다. 생산자는 단일 항목에만 메시지를 보낼 수 있습니다.

문자열

camel.component.kafka.configuration.topic-is-pattern

주제가 패턴(일반 표현식)인지 여부입니다. 이는 패턴과 일치하는 동적 주제 수를 서브스크립션하는 데 사용할 수 있습니다.

false

부울

camel.component.kafka.configuration.value-deserializer

Deserializer 인터페이스를 구현하는 값에 대한 Deserializer 클래스입니다.

org.apache.kafka.common.serialization.StringDeserializer

문자열

camel.component.kafka.configuration.worker-pool

kafka 서버 이후에 Exchange를 계속 라우팅하기 위해 사용자 지정 작업자 풀을 사용하려면 비동기 비 차단 처리를 사용하여 KafkaProducer에서 보낸 메시지를 승인합니다.

ExecutorService

camel.component.kafka.configuration.worker-pool-core-size

kafka 서버 이후에 Exchange를 계속 라우팅하기 위한 작업자 풀의 코어 스레드 수는 비동기 비 블록 처리를 사용하여 KafkaProducer에서 보낸 메시지를 승인합니다.

10

정수

camel.component.kafka.configuration.worker-pool-max-size

kafka 서버 이후에 Exchange를 계속 라우팅하기 위한 작업자 풀의 최대 스레드 수는 비동기 비 블록 처리를 사용하여 KafkaProducer에서 보낸 메시지를 승인합니다.

20

정수

camel.component.kafka.enabled

kafka 구성 요소 활성화

true

부울

camel.component.kafka.kafka-manual-commit-factory

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

문자열

camel.component.kafka.resolve-property-placeholders

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

true

부울

camel.component.kafka.shutdown-timeout

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

30000

정수

camel.component.kafka.use-global-ssl-context-parameters

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

false

부울

camel.component.kafka.worker-pool

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

문자열