65.4. 组件选项

additionalProperties (common)

在 Camel 配置中无法直接设置 kafka consumer 或 kafka producer 的额外属性（例如：还没有反映在 Camel 配置中的新 Kafka 属性），属性必须带有 additionalProperties 前缀。例如： additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro。

Map

代理 (common)

要使用的 Kafka 代理的 URL。格式为 host1:port1,host2:port2，列表可以是代理的子集，也可以是指向代理子集的 VIP。这个选项在 Kafka 文档中被称为 bootstrap.servers。

字符串

clientId (common)

客户端 ID 是在每个请求中发送的用户指定的字符串，以帮助跟踪调用。它应在逻辑上标识发出请求的应用程序。

字符串

configuration (common)

允许预先配置带有端点重复使用的通用选项的 Kafka 组件。

KafkaConfiguration

headerFilterStrategy (common)

使用自定义 HeaderFilterStrategy 过滤到 Camel 消息的标头。

HeaderFilterStrategy

reconnectBackoffMaxMs (common)

当重新连接到重复连接失败的代理时，等待的最大时间（毫秒）。如果提供，每个主机的 backoff 将为每个连续的连接失败指数增加，直到最高值。在计算 backoff 增加后，会添加 20% 的随机 jitter，以避免连接状态。

1000

整数

retryBackoffMaxMs (common)

在重试请求重复失败的代理时，等待的最长时间，以毫秒为单位。如果提供，每个客户端的 backoff 将为每个失败请求指数增加，最多可达到这个最大值。为防止所有客户端在重试时同步，一个具有 0.2 倍的随机 jitter 将应用到 backoff，从而导致 backoff 在计算值低于 20% 到 20% 之间的范围之内。如果将 retry.backoff.ms 设置为高于 retry.backoff.max.ms，则 retry.backoff.max.ms 将用作从开始没有指数增加的恒定 backoff。

1000

整数

retryBackoffMs (common)

尝试重试失败的请求到给定主题分区前等待的时间。这可避免在一些故障场景中在紧循环中重复发送请求。这个值是初始 backoff 值，并将为每个失败请求指数增加，最多为 retry.backoff.max.ms 值。

100

整数

shutdownTimeout (common)

超时时间（以毫秒为单位）会安全等待消费者或制作者关闭并终止其 worker 线程。

30000

int

allowManualCommit (consumer)

是否允许通过 KafkaManualCommit 进行手动提交。如果启用了这个选项，则 KafkaManualCommit 实例存储在 Exchange message 标头中，它允许最终用户访问此 API 并通过 Kafka 使用者执行手动偏移提交。

false

布尔值

autoCommitEnable (consumer)

如果为 true，请定期提交到 ZooKeeper，以偏移已由消费者获取的信息。当进程作为新消费者开始的位置失败时，将使用此提交偏移。

true

布尔值

autoCommitIntervalMs (consumer)

ms 中消费者偏移用于 zookeeper 的频率。

5000

整数

autoCommitOnStop (consumer)

当消费者停止以确保代理具有最近使用的消息提交时，是否执行显式自动提交。这要求打开 autoCommitEnable 选项。可能的值有： sync、sync 或 none。sync 是默认值。

Enum 值：

同步

字符串

autoOffsetReset (consumer)

当 ZooKeeper 中没有初始偏移时，或者偏移没有范围： earliest : 自动将偏移重置为最早的偏移量： 自动将偏移重置为最新的偏移失败： 向消费者抛出异常。

Enum 值：

latest

字符串

批处理 (consumer)

是否使用批处理来处理或流。默认值为 false，它使用 streaming。

false

布尔值

breakOnFirstError (consumer)

这个选项控制消费者处理交换时会发生什么，它会失败。如果选项为 false，则使用者将继续进入下一个消息并处理它。如果选项为 true，则消费者将中断，并且将看到导致失败的消息偏移，然后重新尝试处理此消息。但是，如果绑定到每次都失败，则可能会导致意外处理同一消息，例如 poison 信息。因此，建议您处理这个情况，例如使用 Camel 的错误处理程序。

false

布尔值

bridgeErrorHandler (consumer)

允许将消费者桥接到 Camel 路由错误处理程序，这意味着当消费者试图选择传入消息或类似信息时发生异常，现在将作为消息处理并由路由 Error Handler 处理。默认情况下，使用者将使用 org.apache.camel.spi.ExceptionHandler 来处理例外情况，该处理程序将被记录在 WARN 或 ERROR 级别，并忽略。

false

布尔值

checkCrcs (consumer)

自动检查消耗的记录的 CRC32。这样可确保没有对消息发生在线或者磁盘崩溃。这个检查会增加一些开销，因此在寻求极佳的性能时可能会禁用它。

true

布尔值

commitTimeoutMs (consumer)

代码等待同步提交完成的最长时间（以毫秒为单位）。

5000

Long

consumerRequestTimeoutMs (consumer)

配置控制客户端等待请求响应的最长时间。如果在超时前没有收到响应，客户端将在需要时重新发送请求，或者在重试用尽时失败请求。

40000

整数

consumersCount (consumer)

连接到 kafka 服务器的消费者数量。每个消费者都在单独的线程上运行，该线程检索和处理传入的数据。

1

int

fetchMaxBytes (consumer)

如果 fetch 请求的第一个非空分区中的第一个非空分区大于这个值，则服务器应返回的最大数据量。代理接受的最大消息大小通过 message.max.bytes (broker config)或 max.message.bytes (topic config)定义。请注意，消费者并行执行多个获取。

52428800

整数

fetchMinBytes (consumer)

服务器应该返回获取请求的最小数据量。如果数据不足，则请求会在回答请求前等待数据积累。

1

整数

fetchWaitMaxMs (consumer)

如果无法足够数据就可以满足 fetch.min.bytes，则服务器在回答获取请求前的最大时间量。

500

整数

GroupId (consumer)

唯一标识此消费者所属的消费者进程组的字符串。通过设置同一组 id 多个进程，表示它们都是同一消费者组的一部分。消费者需要这个选项。

字符串

groupInstanceId (consumer)

最终用户提供的消费者实例的唯一标识符。只允许非空字符串。如果设置，消费者将被视为静态成员，这意味着任何时候都只允许具有此 ID 的一个实例。这可以与更大的会话超时结合使用，以避免由临时不可用（如进程重启）导致的组重新平衡。如果没有设置，消费者会将组加入为动态成员，这是传统行为。

字符串

headerDeserializer (consumer)

使用自定义 KafkaHeaderDeserializer 来反序列化 kafka 标头值。

KafkaHeaderDeserializer

heartbeatIntervalMs (consumer)

在使用 Kafka 的组管理工具时，将心跳到消费者协调器之间的预期时间。心跳用于确保消费者的会话保持活跃状态，并在新用户加入或离开组时促进重新平衡。该值必须小于 session.timeout.ms，但设置的值通常不应超过该值的 1/3。它可以调整甚至较低，以控制正常重新平衡的预期时间。

3000

整数

keyDeserializer (consumer)

实现 Deserializer 接口的密钥的反序列化器类。

org.apache.kafka.common.serialization.StringDeserializer

字符串

maxPartitionFetchBytes (consumer)

服务器将返回的每个分区的最大数据量。用于请求的最大内存总量为 #partitions max.partition.fetch.bytes。此大小必须至少与服务器允许的最大消息大小相同，或者生产者可以发送消息大于消费者是否可以获取。如果发生这种情况，消费者会卡住在某个分区上获取大型消息。

1048576

整数

maxPollIntervalMs (consumer)

使用消费者组管理时调用 poll （）的最大延迟。这会对消费者在获取更多记录前可以闲置的时间上放置一个上限。如果在这个超时时间前没有调用 poll （），则消费者被视为失败，并且组将重新平衡，以便将分区重新分配给另一个成员。

Long

maxPollRecords (consumer)

在单个调用中返回的最大记录数（）。

500

整数

offsetRepository (consumer)

使用偏移存储库来本地存储主题的每个分区的偏移量。定义一个将禁用自动提交。

StateRepository

partitionAssignor (consumer)

使用组管理时，客户端将使用分区分配策略的类名称在消费者实例之间分发分区所有权。

org.apache.kafka.clients.consumer.RangeAssignor

字符串

pollOnError (consumer)

如果在轮询新消息时 kafka 延迟一个异常，则应该做什么。默认情况下，将使用组件配置中的值，除非端点级别上配置了显式值。DISCARD 将丢弃消息，并继续轮询下一个消息。ERROR_HANDLER 将使用 Camel 的错误处理程序来处理异常，之后继续轮询下一个消息。RECONNECT 将重新连接消费者，然后再次尝试轮询消息，让消费者再次轮询同一消息，STOP 将停止消费者（如果消费者应能够再次使用消息，则必须手动重新启动/重新启动）。

Enum 值：

ERROR_HANDLER

PollOnError

pollTimeoutMs (consumer)

轮询 KafkaConsumer 时使用的超时。

5000

Long

preValidateHostAndPort (consumer)

是否希望验证代理 host:port 是否有效，可以在启动此消费者期间将 DNS 解析为已知主机。如果验证失败，则抛出异常，这会导致 Camel 失败。禁用此选项将在消费者启动后延迟验证，并且 Camel 会在验证或 DNS 解析错误时保持重新连接。

true

布尔值

seekTo (consumer)

设置 KafkaConsumer 将在 start: start: read from start: read from begin : read from end 开始读取时读取，这会替换之前的属性 seekToBeginning。

Enum 值：

字符串

sessionTimeoutMs (consumer)

使用 Kafka 组管理工具时用于检测故障的超时。

10000

整数

specificAvroReader (consumer)

这可让特定的 Avro 读取器与 Confluent Platform 模式 registry 和 io.confluent.kafka.serializers.KafkaAvroDeserializer 一起使用。这个选项只在 Confluent Platform （不是标准的 Apache Kafka）中可用。

false

布尔值

topicIsPattern (consumer)

主题是否为模式（正则表达式）。这可用于订阅与模式匹配的主题数量。

false

布尔值

valueDeserializer (consumer)

deserializer 类，用于实现 Deserializer 接口的值。

org.apache.kafka.common.serialization.StringDeserializer

字符串

createConsumerBackoffInterval (consumer (advanced))

在尝试再次创建 kafka 使用者(kafka-client)前等待延迟(millis 秒)。

5000

long

createConsumerBackoffMaxAttempts (consumer (advanced))

最终放弃和失败前，创建 kafka 消费者(kafka-client)的最大尝试。创建消费者期间的错误可能是严重的，因为配置无效，因此无法进行恢复。但是，验证的一个部分是 bootstrap 代理主机名的 DNS 解析。这可能是一个临时网络问题，可能会恢复。虽然其他错误是致命的，如一些无效的 kafka 配置。不幸的是，kafka-client 不分隔此类错误。默认情况下，Camel 将永久重试，因此永远不会放弃。如果您要在多次尝试设定此选项后放弃，那么当放弃终止消费者时，Camel 将会被设置此选项。要重试，您可以通过停止并启动路由来手动重启消费者。

int

isolationLevel (consumer (advanced))

控制如何以事务方式读取消息。如果设置为 read_committed，则 consumer.poll （）将只返回已提交的事务消息。如果设置为 read_uncommitted （默认），则 consumer.poll （）将返回所有消息，即使被中止的事务消息。非事务消息将在任一模式中无条件返回。消息始终以偏移顺序返回。因此，在 read_committed 模式中，consumer.poll （）将只返回最新稳定偏移(LSO)的消息，它小于第一个打开事务的偏移量。特别是，在属于持续事务的消息之后，任何消息都会停留在相关的事务中，直到相关的事务完成为止。因此，当出现 flight 事务时，read_committed 用户将无法最多读取高水位线。另外，在 read_committed 中，seekToEnd 方法会返回 LSO。

Enum 值：

字符串

kafkaManualCommitFactory (consumer (advanced))

autowired Factory 用于创建 KafkaManualCommit 实例。这允许在进行手动提交时，需要自定义 KafkaManualCommit 实例来插件自定义 KafkaManualCommit 实例。

KafkaManualCommitFactory

pollExceptionStrategy (consumer (advanced))

Autowired 使用带有消费者的自定义策略来控制如何在池信息时处理从 Kafka 代理抛出异常。

PollExceptionStrategy

subscribeConsumerBackoffInterval (consumer (advanced))

在尝试再次订阅 kafka 代理前等待 millis 秒的延迟。

5000

long

subscribeConsumerBackoffMaxAttempts (consumer (advanced))

在最终放弃和失败前，kafka 使用者将尝试订阅 kafka 代理的最大数量。在订阅 kafka 主题期间的错误可能是因为网络问题而出现临时错误，并可能可以被恢复。默认情况下，Camel 将永久重试，因此永远不会放弃。如果要在多次尝试后放弃，则设置这个选项，然后在放弃终止消费者时 Camel 将进行。您可以通过停止并启动路由来手动重启消费者，以重试。

int

batchWithIndividualHeaders (producer)

如果启用了此功能，并且批处理的单个元素是 Exchange 或 Message，则生成者将使用批处理 Message 确定值来为它生成单独的 kafka 标头值。正常行为始终使用相同的标头值（由包含 Iterable 或 Iterator 的父交换决定）。

false

布尔值

bufferMemorySize (producer)

生成者可用于缓冲服务器的内存总量，记录等待发送到服务器。如果记录比将记录发送到服务器的速度快，生产者将根据 block.on.buffer.full.full 指定的首选项阻止或抛出异常。此设置应大致对应于制作者将使用的总内存，但不是硬绑定，因为生产者使用的所有内存都不用于缓冲。有些额外的内存将用于压缩（如果启用了压缩），以及维护动态请求。

33554432

整数

compressionCodec (producer)

这个参数允许您为此制作者生成的所有数据指定压缩 codec。有效值为 none、gzip 和 snappy。

Enum 值：

none

字符串

connectionMaxIdleMs (producer)

在此配置指定的毫秒数后关闭闲置连接。

540000

整数

deliveryTimeoutMs (producer)

在调用 send （）返回后，报告成功或失败的时间上限。这限制了在发送记录前会延迟记录的总时间、来自代理确认的时间（如预期），以及可重试发送失败的时间。

120000

整数

enableIdempotence (producer)

如果设置为 'true'，则生成者将确保每个消息的一个副本用流写入。如果 'false'，则生成者可能会重试流中重试消息的重复。如果设置为 true，这个选项需要 max.in.flight.requests.per.connection 设置为 1，并且重试不能为零，另外将 acks 设置为 'all'。

false

布尔值

headerSerializer (producer)

使用自定义 KafkaHeaderSerializer 来序列化 kafka 标头值。

KafkaHeaderSerializer

key (producer)

记录键（如果未指定密钥，则为 null）。如果配置了这个选项，则它优先于标头 KafkaConstants#KEY。

字符串

keySerializer (producer)

键的 serializer 类（如果没有提供，则默认为与消息相同）。

org.apache.kafka.common.serialization.StringSerializer

字符串

lazyStartProducer (producer)

生成者是否应懒惰启动 （在第一个消息中）。通过懒惰启动，您可以使用此选项来允许 CamelContext 和路由在生成者启动期间启动，并导致路由启动失败。通过懒惰启动，启动失败可以在路由信息时通过 Camel 的路由错误处理程序进行处理。请注意，在处理第一个消息时，创建并启动生成者可能需要稍等时间，并延长处理的总处理时间。

false

布尔值

lingerMs (producer)

生产者将任何在请求传输之间到达批处理请求的任何记录分组。通常，这只在记录到达速度快于可以发送的记录时发生负载。然而，在某些情况下，客户端可能希望减少请求数量，即使在中等负载下也是如此。此设置通过添加少量的 artificial delay 来达到此目的，而是立即发送记录，而是立即发送记录，以便生成者最多等待到给定的延迟，以便发送可以一起批处理。这可以被认为与 TCP 中的 Nagle 算法类似。此设置会使批处理延迟有上限：一旦我们获得 batch.size，对于一个分区而言，无论此设置如何立即发送，则无论此设置如何，我们会立即发送的记录数超过这个分区所累计的字节数，我们将"闲置"，等待更多记录显示。此设置默认为 0 （例如，无延迟）。例如，设置 linger.ms=5 会影响减少发送的请求数，但会对负载发送的记录最多增加 5ms 的延迟。

0

整数

maxBlockMs (producer)

配置控制发送到 kafka 的时长。这些方法可能会因为多种原因阻止。例如：缓冲区已满，元数据不可用。此配置对获取元数据、键和值序列化和值、分区和分配缓冲区内存的总时间施加最大限制，在执行 send （）时对缓冲区内存进行分区和分配。如果是 partitionsFor （），此配置会在等待元数据时产生最大时间阈值。

60000

整数

maxInFlightRequest (producer)

在阻止前，客户端在单个连接上发送的最大未确认请求数。请注意，如果此设置大于 1，且发送失败，则因为重试而出现消息重新排序的风险（例如，如果启用了重试）。

5

整数

maxRequestSize (producer)

请求的最大大小。这实际上也是最大记录大小的上限。请注意，服务器对记录大小有自己的上限，可能与此不同。此设置将限制制作者在单个请求中发送的记录批处理数量，以避免发送大量请求。

1048576

整数

metadataMaxAgeMs (producer)

我们强制刷新元数据的时间（毫秒），即使我们尚未看到任何分区领导权变化，以主动发现任何新的代理或分区。

300000

整数

metricReporters (producer)

用作指标报告器的类列表。实施 MetricReporter 接口允许插入新指标创建通知的类。对于注册 JMX 统计数据，始终包含 JmxReporter。

字符串

metricsSampleWindowMs (producer)

为计算指标维护的示例数量。

30000

整数

noOfMetricsSample (producer)

为计算指标维护的示例数量。

2

整数

partitioner (producer)

在子主题间分区消息的分区类。默认分区器基于密钥的哈希。

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

字符串

partitionerIgnoreKeys (producer)

计算分区时是否应忽略消息键。此设置仅在未设置 partitioner 时生效。

false

布尔值

PartitionKey ( producer)

将记录发送到的分区（如果没有指定分区，则为 null）。如果配置了这个选项，则它优先于标头 KafkaConstants#PARTITION_KEY。

整数

producerBatchSize (producer)

每当将多个记录发送到同一分区时，生成者将尝试将记录一起批处理到较少的请求。这有助于在客户端和服务器上性能。此配置控制默认的批处理大小，以字节为单位。对于大于此 size.Requests 的批处理记录不会进行任何尝试。发送到代理的请求将包含多个批处理，每个分区一个可用数据。小批处理大小将较少的批处理，并且可能会降低吞吐量（批量大小为零将完全禁用批处理）。一个非常大的批处理大小可能会更频繁地使用内存，因为我们将始终在额外的记录中分配指定批处理大小的缓冲区。

16384

整数

queueBufferingMaxMessages (producer)

在使用 async 模式时，可以在生成者必须被阻止或数据丢弃前，可以排队生成者的最大未发送消息数。

10000

整数

receiveBufferBytes (producer)

读取数据时使用的 TCP 接收缓冲区(SO_RCVBUF)的大小。

65536

整数

reconnectBackoffMs (producer)

尝试重新连接给定主机前需要等待的时间。这可避免在紧循环中重复连接到主机。此 backoff 适用于消费者向代理发送的所有请求。

50

整数

RecordMetadata ( producer)

制作者是否应该存储发送到 Kafka 的 RecordMetadata 结果。结果存储在包含 RecordMetadata 元数据的列表中。该列表存储在带有键 KafkaConstantsKAFKA_RECORDMETA 的标头中。

true

布尔值

requestRequiredAcks (producer)

在考虑请求完成前，生成者需要收到该领导人的确认数量。这控制要发送的记录的持久性。以下设置是常见的：acks=0 如果设为零，则生成者不会等待服务器中的任何确认。该记录将立即添加到套接字缓冲区中并考虑发送。在这种情况下，不能保证服务器收到记录，重试配置不会生效（因为客户端通常不知道任何故障）。每个记录返回的偏移量始终设置为 -1 acks=1，这意味着领导机会将记录写入到其本地日志，但不会等待所有后续者的完全确认。在这种情况下，领导机在确认记录后马上失败，但在后续者复制记录之前，该记录将会丢失。acks=all 意味着领导机将等待全部同步副本确认记录。这样可确保记录不会丢失，只要至少有一个同步副本保持活动状态。这是最强的可用保证。

Enum 值：

1

字符串

requestTimeoutMs (producer)

代理在向客户端发送错误前尝试满足 request.required.acks 要求的时间长度。

30000

整数

retries (producer)

设置大于零的值将导致客户端重新发送发送失败并显示可能的临时错误的任何记录。请注意，如果客户端在收到错误时重新发送记录，这个重试并没有不同。允许重试可能会更改记录顺序，因为如果将两个记录发送到单个分区，第一次失败并重试，但会成功，但第二个记录可能会首先出现。

0

整数

retryBackoffMs (producer)

在每个重试前，生成者会刷新相关主题的元数据，以查看是否选择了新的领导。由于领导选举需要一些时间，此属性指定制作者在刷新元数据前等待的时间。

100

整数

sendBufferBytes (producer)

套接字写入缓冲区大小。

131072

整数

useIterator (producer)

设置发送到 kafka 是否应该将消息正文作为单个记录发送，或者使用 java.util.Iterator 将多个记录发送到 kafka （如果可以迭代消息正文）。

true

布尔值

valueSerializer (producer)

用于消息的 serializer 类。

org.apache.kafka.common.serialization.StringSerializer

字符串

workerpool (producer)

要在 kafka 服务器确认使用异步非阻塞处理从 KafkaProducer 发送到它的消息后，使用自定义 worker 池来继续路由 Exchange。如果使用这个选项，则必须处理线程池的生命周期，以便在不再需要时关闭池。

ExecutorService

workerPoolCoreSize (producer)

kafka 服务器确认从 KafkaProducer 发送到 KafkaProducer 的消息后，用于继续路由 Exchange 的 worker 池的核心线程数量，使用异步非阻塞处理。

10

整数

workerPoolMaxSize (producer)

kafka 服务器确认从 KafkaProducer 发送到 KafkaProducer 的消息后，用于继续路由 Exchange 的 worker 池的最大线程数量。

20

整数

autowiredEnabled (advanced)

是否启用自动关闭。这用于自动关闭选项（选项必须标记为 autowired），方法是在 registry 中查找查找是否有单个匹配类型实例，然后在组件上配置。这可以用于自动配置 JDBC 数据源、JMS 连接工厂、AWS 客户端等。

true

布尔值

kafkaClientFactory (advanced)

autowired Factory 用于创建 org.apache.kafka.clients.consumer.KafkaConsumer 和 org.apache.kafka.clients.producer.KafkaProducer 实例。这允许配置自定义工厂，创建带有扩展 vanilla Kafka 客户端的逻辑的实例。

KafkaClientFactory

同步 （高级）

设置是否应严格使用同步处理。

false

布尔值

healthCheckConsumerEnabled (health)

用于启用或禁用此组件中的所有基于消费者的健康检查。

true

布尔值

healthCheckProducerEnabled (health)

用于启用或禁用此组件中的所有基于制作者的健康检查。注意：Camel 默认禁用所有基于制作者的健康检查。您可以通过设置 camel.health.producersEnabled=true 来全局打开制作者检查。

true

布尔值

interceptorClasses (monitoring)

为生成者或消费者设置拦截器。生产者拦截器必须是实施 org.apache.kafka.clients.producer.ProducerInterceptor Consumer 拦截器的类，必须是实现 org.apache.kafka.clients.consumer.ConsumerInterceptor.consumer.ConsumerInterceptor 注意，如果消费者使用 Producer 拦截器，它将在运行时引发类广播异常。

字符串

schemaRegistryURL (confluent)

要使用的 Confluent Platform 模式 registry 服务器的 URL。格式为 host1:port1,host2:port2。这在 Confluent Platform 文档中的 schema.registry.url 被称为 schema.registry.url。这个选项只在 Confluent Platform （不是标准的 Apache Kafka）中可用。

字符串

kerberosBeforeReloginMinTime (security)

登录线程睡眠时间。

60000

整数

kerberosInitCmd (security)

Kerberos kinit 命令路径。默认为 /usr/bin/kinit。

/usr/bin/kinit

字符串

kerberosPrincipalToLocalRules (security)

从主体名称映射到短名称的规则列表（通常是操作系统用户名）。规则按顺序评估，第一个与主体名称匹配的规则用于将它映射到短名称。列表中的任何后续规则都会被忽略。默认情况下，{username}/{hostname}{REALM} 格式的主体名称映射到 {username}。有关格式的详情，请查看安全授权和 acls 文档。可以使用逗号分隔多个值。

DEFAULT

字符串

kerberosRenewJitter (security)

添加到续订时间的随机 jitter 百分比。

0.05

�

kerberosRenewWindowFactor (security)

登录线程将睡眠，直到指定的窗口因时间从上次刷新到票据的过期而达到，此时将尝试续订票据。

0.8

�

saslJaasConfig (security)

公开 kafka sasl.jaas.config 参数示例： org.apache.kafka.common.security.plain.PlainLoginModule required username=USERNAME password=PASSWORD;。

字符串

saslKerberosServiceName (security)

Kafka 运行的 Kerberos 主体名称。这可以在 Kafka 的 JAAS 配置或 Kafka 的配置中定义。

字符串

saslMechanism (security)

使用简单身份验证和安全层(SASL)机制。有关有效值，请参阅。

GSSAPI

字符串

securityProtocol (security)

用于与代理通信的协议。支持 SASL_PLAINTEXT、PLAINTEXT 和 SSL。

PLAINTEXT

字符串

sslCipherSuites (security)

密码套件列表。这是用来使用 TLS 或 SSL 网络协议协商网络连接的安全设置的身份验证、加密、MAC 和密钥交换算法的命名组合。只要默认支持所有可用的密码套件。

字符串

sslContextParameters (security)

使用 Camel SSLContextParameters 对象的 SSL 配置。如果配置在其他 SSL 端点参数之前应用。注意： Kafka 只支持从文件位置加载密钥存储，因此在 KeyStoreParameters.resource 选项中使用 file: 前缀。

SSLContextParameters

sslEnabledProtocols (security)

为 SSL 连接启用的协议列表。TLSv1.2、TLSv1.1 和 TLSv1 会被默认启用。

字符串

sslEndpointAlgorithm (security)

使用服务器证书验证服务器主机名的端点识别算法。

https

字符串

sslKeymanagerAlgorithm (security)

密钥管理器工厂用于 SSL 连接的算法。默认值是为 Java 虚拟机配置的主要管理器工厂算法。

SunX509

字符串

sslKeyPassword (security)

密钥存储文件中私钥的密码。这对客户端是可选的。

字符串

sslKeystoreLocation (security)

密钥存储文件的位置。这对客户端是可选的，可用于客户端双向身份验证。

字符串

sslKeystorePassword (security)

密钥存储文件的存储密码。这对客户端是可选的，只有在配置了 ssl.keystore.location 时才需要。

字符串

sslKeystoreType (security)

密钥存储文件的文件格式。这对客户端是可选的。默认值为 JKS。

JKS

字符串

SSLProtocol ( security)

用于生成 SSLContext 的 SSL 协议。默认设置为 TLS，对于大多数情况来说是正常的。最近 JVM 中允许的值是 TLS、TLSv1.1 和 TLSv1.2。较旧的 JVM 中可能会支持 SSL、SSLv2 和 SSLv3，但由于已知的安全漏洞，不建议使用它们。

字符串

sslProvider (security)

用于 SSL 连接的安全供应商名称。默认值是 JVM 的默认安全提供程序。

字符串

sslTrustmanagerAlgorithm (security)

信任管理器工厂用于 SSL 连接的算法。默认值是为 Java 虚拟机配置的信任管理器工厂算法。

PKIX

字符串

sslTruststoreLocation (security)

信任存储文件的位置。

字符串

sslTruststorePassword (security)

信任存储文件的密码。

字符串

sslTruststoreType (security)

信任存储文件的文件格式。默认值为 JKS。

JKS

字符串

useGlobalSslContextParameters (security)

启用使用全局 SSL 上下文参数。

false

布尔值