注册
登录
Kafka
Kafka重新启动时如何使Kafka Source重新连接
返回
Kafka重新启动时如何使Kafka Source重新连接
作者:
阿政ღ
发布时间:
2023-08-24 12:31:30 (11月前)
转自：
<div class =“excerpt”> 我使用Reactive创建了一个消费者记录来源 <span class =“result-highlight”> 卡夫卡 </跨度> 如下： val settings = ConsumerSettings（system，keyDeserializer，valueDeserializer） .withBootstrapServers（bootstrapServers （ConsumerConfig.MAX_POLL_RECORDS_CONFIG，“100”） Consumer.atMostOnceSource（settings，Subscriptions.topics（topic））。map（_。value） 我有1个实例 <span class =“result-highlight”> 卡夫卡 </跨度> 在我的本地机器上运行。我将值推到了主题中 </DIV>
收藏
举报
2 条回复
0#
回复此人
老人与海
|
2019-08-31 10-32
<div class =“post-text”itemprop =“text”> <P> 我想你需要至少有2个经纪人。如果一个人失败，另一个人可以完成这项任务，你可以重新启动另一个。 </p> </DIV>
编辑
登录
后才能参与评论
