66.18. Spring Boot Auto-Configuration

camel.component.kafka.additional-properties

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

Map

camel.component.kafka.allow-manual-commit

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

false

布尔值

camel.component.kafka.auto-commit-enable

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

true

布尔值

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

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

5000

整数

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

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

同步

字符串

camel.component.kafka.auto-offset-reset

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

latest

字符串

camel.component.kafka.autowired-enabled

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

true

布尔值

camel.component.kafka.batch-with-individual-headers

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

false

布尔值

camel.component.kafka.batching

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

false

布尔值

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

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

false

布尔值

camel.component.kafka.bridge-error-handler

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

false

布尔值

camel.component.kafka.brokers

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

字符串

camel.component.kafka.buffer-memory-size

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

33554432

整数

camel.component.kafka.check-crcs

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

true

布尔值

camel.component.kafka.client-id

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

字符串

camel.component.kafka.commit-timeout-ms

代码等待同步提交完成的最长时间（以毫秒为单位）。选项是一个 java.lang.Long 类型。

5000

Long

camel.component.kafka.compression-codec

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

none

字符串

camel.component.kafka.configuration

允许预先配置带有端点重复使用的通用选项的 Kafka 组件。选项是 org.apache.camel.component.kafka.KafkaConfiguration 类型。

KafkaConfiguration

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

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

540000

整数

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

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

40000

整数

camel.component.kafka.consumers-count

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

1

整数

camel.component.kafka.create-consumer-backoff-interval

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

5000

Long

camel.component.kafka.create-consumer-backoff-max-attempts

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

整数

camel.component.kafka.delivery-timeout-ms

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

120000

整数

camel.component.kafka.enable-idempotence

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

false

布尔值

camel.component.kafka.enabled

是否启用 kafka 组件的自动配置。这默认是启用的。

布尔值

camel.component.kafka.fetch-max-bytes

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

52428800

整数

camel.component.kafka.fetch-min-bytes

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

1

整数

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

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

500

整数

camel.component.kafka.group-id

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

字符串

camel.component.kafka.group-instance-id

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

字符串

camel.component.kafka.header-deserializer

使用自定义 KafkaHeaderDeserializer 来反序列化 kafka 标头值。选项是 org.apache.camel.component.kafka.serde.KafkaHeaderDeserializer 类型。

KafkaHeaderDeserializer

camel.component.kafka.header-filter-strategy

使用自定义 HeaderFilterStrategy 过滤到 Camel 消息的标头。选项是一个 org.apache.camel.spi.HeaderFilterStrategy 类型。

HeaderFilterStrategy

camel.component.kafka.header-serializer

使用自定义 KafkaHeaderSerializer 来序列化 kafka 标头值。选项是 org.apache.camel.component.kafka.serde.KafkaHeaderSerializer 类型。

KafkaHeaderSerializer

camel.component.kafka.health-check-consumer-enabled

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

true

布尔值

camel.component.kafka.health-check-producer-enabled

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

true

布尔值

camel.component.kafka.heartbeat-interval-ms

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

3000

整数

camel.component.kafka.interceptor-classes

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

字符串

camel.component.kafka.isolation-level

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

read_uncommitted

字符串

camel.component.kafka.kafka-client-factory

factory 用于创建 org.apache.kafka.clients.consumer.KafkaConsumer 和 org.apache.kafka.clients.producer.KafkaProducer 实例。这允许配置自定义工厂，创建带有扩展 vanilla Kafka 客户端的逻辑的实例。选项是 org.apache.camel.component.kafka.KafkaClientFactory 类型。

KafkaClientFactory

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

用于创建 KafkaManualCommit 实例的工厂。这允许在进行手动提交时，需要自定义 KafkaManualCommit 实例来插件自定义 KafkaManualCommit 实例。选项是 org.apache.camel.component.kafka.KafkaManualCommitFactory 类型。

KafkaManualCommitFactory

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

登录线程睡眠时间。

60000

整数

camel.component.kafka.kerberos-config-location

kerberos 配置文件的位置。

字符串

camel.component.kafka.kerberos-init-cmd

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

/usr/bin/kinit

字符串

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

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

DEFAULT

字符串

camel.component.kafka.kerberos-renew-jitter

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

�

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

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

�

camel.component.kafka.key

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

字符串

camel.component.kafka.key-deserializer

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

org.apache.kafka.common.serialization.StringDeserializer

字符串

camel.component.kafka.key-serializer

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

org.apache.kafka.common.serialization.StringSerializer

字符串

camel.component.kafka.lazy-start-producer

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

false

布尔值

camel.component.kafka.linger-ms

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

0

整数

camel.component.kafka.max-block-ms

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

60000

整数

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

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

5

整数

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

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

1048576

整数

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

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

Long

camel.component.kafka.max-poll-records

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

500

整数

camel.component.kafka.max-request-size

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

1048576

整数

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

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

300000

整数

camel.component.kafka.metric-reporters

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

字符串

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

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

30000

整数

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

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

2

整数

camel.component.kafka.offset-repository

使用偏移存储库来本地存储主题的每个分区的偏移量。定义一个将禁用自动提交。选项是一个 org.apache.camel.spi.StateRepository<java.lang.String, java.lang.String> 类型。

StateRepository

camel.component.kafka.partition-assignor

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

org.apache.kafka.clients.consumer.RangeAssignor

字符串

camel.component.kafka.partition-key

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

整数

camel.component.kafka.partitioner

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

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

字符串

camel.component.kafka.partitioner-ignore-keys

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

false

布尔值

camel.component.kafka.poll-exception-strategy

要将自定义策略与消费者一起使用，以控制如何在池消息时处理从 Kafka 代理抛出的异常。选项是一个 org.apache.camel.component.kafka.PollExceptionStrategy 类型。

PollExceptionStrategy

camel.component.kafka.poll-on-error

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

PollOnError

camel.component.kafka.poll-timeout-ms

轮询 KafkaConsumer 时使用的超时。选项是一个 java.lang.Long 类型。

5000

Long

camel.component.kafka.pre-validate-host-and-port

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

true

布尔值

camel.component.kafka.producer-batch-size

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

16384

整数

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

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

10000

整数

camel.component.kafka.receive-buffer-bytes

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

65536

整数

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

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

1000

整数

camel.component.kafka.reconnect-backoff-ms

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

50

整数

camel.component.kafka.record-metadata

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

true

布尔值

camel.component.kafka.request-required-acks

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

1

字符串

camel.component.kafka.request-timeout-ms

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

30000

整数

camel.component.kafka.resume-strategy

此选项允许用户设置自定义恢复策略。在分配分区时执行恢复策略（例如：连接或重新连接时）。它允许实施自定义如何恢复操作，并作为 seekTo 和 offsetRepository 机制的更灵活的替代选择。有关实现详情，请参阅 KafkaConsumerResumeStrategy。此选项不会影响自动提交设置。使用此设置的实现可能还希望使用手动提交选项来评估。选项是一个 org.apache.camel.component.kafka.consumer.support.KafkaConsumerResumeStrategy 类型。

KafkaConsumerResumeStrategy

camel.component.kafka.retries

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

0

整数

camel.component.kafka.retry-backoff-ms

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

100

整数

camel.component.kafka.sasl-jaas-config

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

字符串

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

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

字符串

camel.component.kafka.sasl-mechanism

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

GSSAPI

字符串

camel.component.kafka.schema-registry-u-r-l

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

字符串

camel.component.kafka.security-protocol

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

PLAINTEXT

字符串

camel.component.kafka.seek-to

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

字符串

camel.component.kafka.send-buffer-bytes

套接字写入缓冲区大小。

131072

整数

camel.component.kafka.session-timeout-ms

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

10000

整数

camel.component.kafka.shutdown-timeout

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

30000

整数

camel.component.kafka.specific-avro-reader

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

false

布尔值

camel.component.kafka.ssl-cipher-suites

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

字符串

camel.component.kafka.ssl-context-parameters

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

SSLContextParameters

camel.component.kafka.ssl-enabled-protocols

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

字符串

camel.component.kafka.ssl-endpoint-algorithm

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

https

字符串

camel.component.kafka.ssl-key-password

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

字符串

camel.component.kafka.ssl-keymanager-algorithm

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

SunX509

字符串

camel.component.kafka.ssl-keystore-location

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

字符串

camel.component.kafka.ssl-keystore-password

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

字符串

camel.component.kafka.ssl-keystore-type

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

JKS

字符串

camel.component.kafka.ssl-protocol

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

字符串

camel.component.kafka.ssl-provider

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

字符串

camel.component.kafka.ssl-trustmanager-algorithm

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

PKIX

字符串

camel.component.kafka.ssl-truststore-location

信任存储文件的位置。

字符串

camel.component.kafka.ssl-truststore-password

信任存储文件的密码。

字符串

camel.component.kafka.ssl-truststore-type

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

JKS

字符串

camel.component.kafka.subscribe-consumer-backoff-interval

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

5000

Long

camel.component.kafka.subscribe-consumer-backoff-max-attempts

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

整数

camel.component.kafka.synchronous

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

false

布尔值

camel.component.kafka.topic-is-pattern

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

false

布尔值

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

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

false

布尔值

camel.component.kafka.use-iterator

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

true

布尔值

camel.component.kafka.value-deserializer

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

org.apache.kafka.common.serialization.StringDeserializer

字符串

camel.component.kafka.value-serializer

用于消息的 serializer 类。

org.apache.kafka.common.serialization.StringSerializer

字符串

camel.component.kafka.worker-pool

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

ExecutorService

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

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

10

整数

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

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

20

整数