问题描述
我有一个用 Java 编写的 Kakfa 消费者。 Out Kafka 服务器每天停机 5 分钟进行一些维护。
当服务器宕机时,Kafka消费者断开连接
我希望消费者能够在服务器启动时继续重试和连接。
这是我的代码:
@Bean
public KStream<String,EmployeeRaw> consumeEmp(StreamsBuilder streamsBuilder,SpecificAvroSerde<EmployeeRaw> employeeRawSerde) {
final KStream<String,EmployeeRaw> stream = streamsBuilder.stream(kafkaProperties.getTopic(),Consumed.with(Serdes.String(),employeeRawSerde));
stream.foreach((key,value) -> {
... do something
});
return stream;
}
我已尝试设置这些配置属性,但似乎不起作用
重试,retry.backoff.ms
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)