| queue.integration-downlink.poll-interval |
TB_IE_DOWNLINK_POLL_INTERVAL |
1000 |
轮询tbmq.ie.downlink主题消息的间隔（毫秒） |
| queue.integration-msg.poll-interval |
TB_IE_MSG_POLL_INTERVAL |
1000 |
轮询'tbmq.msg.ie'主题消息的间隔（毫秒） |
| queue.integration-msg.pack-processing-timeout |
TB_IE_MSG_PACK_PROCESSING_TIMEOUT |
30000 |
处理消息包的超时时间（毫秒） |
| queue.integration-msg.ack-strategy.type |
TB_IE_MSG_ACK_STRATEGY_TYPE |
SKIP_ALL |
'tbmq.msg.ie'主题的处理策略。可以是：SKIP_ALL、RETRY_ALL |
| queue.integration-msg.ack-strategy.retries |
TB_IE_MSG_ACK_STRATEGY_RETRIES |
5 |
重试次数，0表示无限。用于RETRY_ALL处理策略 |
| queue.integration-msg.ack-strategy.pause-between-retries |
TB_IE_MSG_ACK_STRATEGY_PAUSE_BETWEEN_RETRIES |
1 |
消费者线程在重试前等待的时间（秒） |
| queue.kafka.bootstrap.servers |
TB_KAFKA_SERVERS |
localhost:9092 |
用于建立连接的Kafka引导服务器列表 |
| queue.kafka.enable-topic-deletion |
TB_KAFKA_ENABLE_TOPIC_DELETION |
true |
控制TBMQ是否允许删除为集成创建的Kafka主题。
设置为'true'时，TBMQ可能在清理期间自动删除主题
（例如，当集成被删除时）。
设置为'false'时，TBMQ将跳过主题删除并停止使用它们。
这有助于防止生产环境中的意外数据丢失 |
| queue.kafka.default.consumer.partition-assignment-strategy |
TB_KAFKA_DEFAULT_CONSUMER_PARTITION_ASSIGNMENT_STRATEGY |
org.apache.kafka.clients.consumer.StickyAssignor |
支持的分区分配策略的类名或类型列表，按优先级排序，客户端在使用组管理时将使用该列表来在消费者实例之间分配分区所有权 |
| queue.kafka.default.consumer.session-timeout-ms |
TB_KAFKA_DEFAULT_CONSUMER_SESSION_TIMEOUT_MS |
10000 |
使用Kafka组管理功能时用于检测客户端故障的超时时间（毫秒） |
| queue.kafka.default.consumer.max-poll-interval-ms |
TB_KAFKA_DEFAULT_CONSUMER_MAX_POLL_INTERVAL_MS |
300000 |
使用消费者组管理时poll()调用之间的最大延迟（毫秒） |
| queue.kafka.default.consumer.max-poll-records |
TB_KAFKA_DEFAULT_CONSUMER_MAX_POLL_RECORDS |
2000 |
单个poll()调用返回的最大记录数 |
| queue.kafka.default.consumer.max-partition-fetch-bytes |
TB_KAFKA_DEFAULT_CONSUMER_MAX_PARTITION_FETCH_BYTES |
16777216 |
服务器将返回的每个分区的最大数据量（字节） |
| queue.kafka.default.consumer.fetch-max-bytes |
TB_KAFKA_DEFAULT_CONSUMER_FETCH_MAX_BYTES |
134217728 |
服务器应为获取请求返回的最大数据量（字节） |
| queue.kafka.default.consumer.heartbeat-interval-ms |
TB_KAFKA_DEFAULT_CONSUMER_HEARTBEAT_INTERVAL_MS |
3000 |
The expected time between heartbeats to the consumer coordinator when using Kafka’s group management facilities.
Heartbeats are used to ensure that the consumer’s session stays active and to facilitate rebalancing when new consumers join or leave the group.
The value must be set lower than TB_KAFKA_DEFAULT_CONSUMER_SESSION_TIMEOUT_MS, but typically should be set no higher than 1/3 of that value.
It can be adjusted even lower to control the expected time for normal rebalances. Value in milliseconds. Default is 3 sec |
| queue.kafka.default.producer.acks |
TB_KAFKA_DEFAULT_PRODUCER_ACKS |
1 |
生产者在认为请求完成前要求领导者收到的确认数 |
| queue.kafka.default.producer.retries |
TB_KAFKA_DEFAULT_PRODUCER_RETRIES |
1 |
将值设置为大于零将导致客户端重新发送发送失败的任何记录，该记录可能会因暂时错误而失败 |
| queue.kafka.default.producer.batch-size |
TB_KAFKA_DEFAULT_PRODUCER_BATCH_SIZE |
16384 |
当多个记录被发送到同一分区时，生产者将尝试将记录一起批处理为更少的请求。大小以字节为单位 |
| queue.kafka.default.producer.linger-ms |
TB_KAFKA_DEFAULT_PRODUCER_LINGER_MS |
5 |
生产者将在请求传输之间到达的任何记录分组为单个批处理请求，以毫秒为单位设置 |
| queue.kafka.default.producer.buffer-memory |
TB_KAFKA_DEFAULT_PRODUCER_BUFFER_MEMORY |
33554432 |
生产者可用于缓冲等待发送到服务器的记录的总字节内存 |
| queue.kafka.default.producer.compression-type |
TB_KAFKA_DEFAULT_COMPRESSION_TYPE |
none |
生产者生成的所有数据的压缩类型。有效值为`none`、`gzip`、`snappy`、`lz4`或`zstd` |
| queue.kafka.admin.config |
TB_KAFKA_ADMIN_CONFIG |
retries:1 |
用于创建admin Kafka客户端的分号分隔的配置列表 |
| queue.kafka.admin.command-timeout |
TB_KAFKA_ADMIN_COMMAND_TIMEOUT_SEC |
30 |
Kafka Admin客户端命令超时（以秒为单位）。适用于describeCluster、listTopics等操作 |
| queue.kafka.consumer-stats.enabled |
TB_KAFKA_CONSUMER_STATS_ENABLED |
true |
如果启用，打印Kafka主题中消费者组偏移与最后消息偏移之间的滞后时间 |
| queue.kafka.consumer-stats.print-interval-ms |
TB_KAFKA_CONSUMER_STATS_PRINT_INTERVAL_MS |
60000 |
Kafka消费者组统计的统计打印间隔（毫秒） |
| queue.kafka.consumer-stats.kafka-response-timeout-ms |
TB_KAFKA_CONSUMER_STATS_RESPONSE_TIMEOUT_MS |
1000 |
等待统计加载请求到Kafka完成的时间（毫秒） |
| queue.kafka.consumer-stats.consumer-config |
TB_KAFKA_CONSUMER_STATS_CONSUMER_CONFIG |
|
用于Kafka统计消费者的分号分隔的配置列表 |
| queue.kafka.integration-downlink.topic-prefix |
TB_KAFKA_IE_DOWNLINK_TOPIC_PREFIX |
tbmq.ie.downlink |
用于从tbmq向集成执行器发送集成配置和验证请求的主题的前缀 |
| queue.kafka.integration-downlink.http.topic-properties |
TB_KAFKA_IE_DOWNLINK_HTTP_TOPIC_PROPERTIES |
retention.ms:604800000;segment.bytes:26214400;retention.bytes:1048576000;partitions:6;replication.factor:1 |
`tbmq.ie.downlink.http`主题的Kafka主题属性（分号分隔） |
| queue.kafka.integration-downlink.http.additional-consumer-config |
TB_KAFKA_IE_DOWNLINK_HTTP_ADDITIONAL_CONSUMER_CONFIG |
|
`tbmq.ie.downlink.http`主题的额外Kafka消费者配置（分号分隔） |
| queue.kafka.integration-downlink.http.additional-producer-config |
TB_KAFKA_IE_DOWNLINK_HTTP_ADDITIONAL_PRODUCER_CONFIG |
|
`tbmq.ie.downlink.http`主题的额外Kafka生产者配置（分号分隔） |
| queue.kafka.integration-downlink.kafka.topic-properties |
TB_KAFKA_IE_DOWNLINK_KAFKA_TOPIC_PROPERTIES |
retention.ms:604800000;segment.bytes:26214400;retention.bytes:1048576000;partitions:6;replication.factor:1 |
`tbmq.ie.downlink.kafka`主题的Kafka主题属性（分号分隔） |
| queue.kafka.integration-downlink.kafka.additional-consumer-config |
TB_KAFKA_IE_DOWNLINK_KAFKA_ADDITIONAL_CONSUMER_CONFIG |
|
`tbmq.ie.downlink.kafka`主题的额外Kafka消费者配置（分号分隔） |
| queue.kafka.integration-downlink.kafka.additional-producer-config |
TB_KAFKA_IE_DOWNLINK_KAFKA_ADDITIONAL_PRODUCER_CONFIG |
|
`tbmq.ie.downlink.kafka`主题的额外Kafka生产者配置（分号分隔） |
| queue.kafka.integration-downlink.mqtt.topic-properties |
TB_KAFKA_IE_DOWNLINK_MQTT_TOPIC_PROPERTIES |
retention.ms:604800000;segment.bytes:26214400;retention.bytes:1048576000;partitions:6;replication.factor:1 |
`tbmq.ie.downlink.mqtt`主题的Kafka主题属性（分号分隔） |
| queue.kafka.integration-downlink.mqtt.additional-consumer-config |
TB_KAFKA_IE_DOWNLINK_MQTT_ADDITIONAL_CONSUMER_CONFIG |
|
`tbmq.ie.downlink.mqtt`主题的额外Kafka消费者配置（分号分隔） |
| queue.kafka.integration-downlink.mqtt.additional-producer-config |
TB_KAFKA_IE_DOWNLINK_MQTT_ADDITIONAL_PRODUCER_CONFIG |
|
`tbmq.ie.downlink.mqtt`主题的额外Kafka生产者配置（分号分隔） |
| queue.kafka.integration-uplink.topic |
TB_KAFKA_IE_UPLINK_TOPIC |
tbmq.ie.uplink |
用于从集成执行器向tbmq发送消息/事件的主题 |
| queue.kafka.integration-uplink.topic-properties |
TB_KAFKA_IE_UPLINK_TOPIC_PROPERTIES |
retention.ms:604800000;segment.bytes:26214400;retention.bytes:1048576000;partitions:6;replication.factor:1 |
`tbmq.ie.uplink`主题的Kafka主题属性（分号分隔） |
| queue.kafka.integration-uplink.additional-consumer-config |
TB_KAFKA_IE_UPLINK_ADDITIONAL_CONSUMER_CONFIG |
|
`tbmq.ie.uplink`主题的额外Kafka消费者配置（分号分隔） |
| queue.kafka.integration-uplink.additional-producer-config |
TB_KAFKA_IE_UPLINK_ADDITIONAL_PRODUCER_CONFIG |
|
`tbmq.ie.uplink`主题的额外Kafka生产者配置（分号分隔） |
| queue.kafka.integration-uplink-notifications.topic-prefix |
TB_KAFKA_IE_UPLINK_NOTIF_TOPIC_PREFIX |
tbmq.ie.uplink.notifications |
用于从集成执行器向特定tbmq节点发送通知或回复的主题的前缀 |
| queue.kafka.integration-uplink-notifications.topic-properties |
TB_KAFKA_IE_UPLINK_NOTIF_TOPIC_PROPERTIES |
retention.ms:604800000;segment.bytes:26214400;retention.bytes:1048576000;partitions:1;replication.factor:1 |
`tbmq.ie.uplink.notifications`主题的Kafka主题属性（分号分隔） |
| queue.kafka.integration-uplink-notifications.additional-consumer-config |
TB_KAFKA_IE_UPLINK_NOTIF_ADDITIONAL_CONSUMER_CONFIG |
|
`tbmq.ie.uplink.notifications`主题的额外Kafka消费者配置（分号分隔） |
| queue.kafka.integration-uplink-notifications.additional-producer-config |
TB_KAFKA_IE_UPLINK_NOTIF_ADDITIONAL_PRODUCER_CONFIG |
|
`tbmq.ie.uplink.notifications`主题的额外Kafka生产者配置（分号分隔） |
| queue.kafka.integration-msg.topic-properties |
TB_KAFKA_IE_MSG_TOPIC_PROPERTIES |
retention.ms:604800000;segment.bytes:26214400;retention.bytes:1048576000;replication.factor:1 |
`tbmq.msg.ie`主题的Kafka主题属性（分号分隔） |
| queue.kafka.integration-msg.additional-consumer-config |
TB_KAFKA_IE_MSG_ADDITIONAL_CONSUMER_CONFIG |
max.poll.records:50 |
`tbmq.msg.ie`主题的额外Kafka消费者配置（分号分隔） |
| queue.kafka.integration-msg.additional-producer-config |
TB_KAFKA_IE_MSG_ADDITIONAL_PRODUCER_CONFIG |
|
`tbmq.msg.ie`主题的额外Kafka生产者配置（分号分隔） |
| queue.kafka.kafka-prefix |
TB_KAFKA_PREFIX |
|
所有Kafka主题、生产者、消费者组和消费者的通用前缀。默认为空字符串，表示不添加前缀 |