ProducerConfiguration
时间: 2023-09-20 11:13:16 浏览: 75
在Kafka的生产者配置中,可以设置以下几个参数:
1. 设置记录的时间戳(timestamp):如果用户在创建ProducerRecord时没有指定时间戳,那么可以使用producer的当前时间作为时间戳。在Java客户端中,可以使用Time接口来设置时间戳,内置的实现是SystemTime,它会将记录的时间戳设置为当前时间。如果希望在Kafka生产者中使用其他的时间,可以自定义Time的实现。<span class="em">1</span><span class="em">2</span><span class="em">3</span>
#### 引用[.reference_title]
- *1* [Kafka Producer异步发送的流程](https://blog.csdn.net/qq_26222859/article/details/54407541)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v92^chatsearchT0_1"}}] [.reference_item style="max-width: 50%"]
- *2* *3* [Kafka安全认证 SASL/PLAINTEXT,账号密码认证](https://blog.csdn.net/weixin_43564627/article/details/118386089)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v92^chatsearchT0_1"}}] [.reference_item style="max-width: 50%"]
[ .reference_list ]
阅读全文