OffsetResetFlagReset是什么意思啊


 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 * 发送一个带有fin标记的TCP 若返回RST+ACK 则端ロ关闭 否则什么也不返回
 * 发送一个任何标记不带的TCP 若返回RST+ACK 则端口关闭 否则什么也不返回
 
 
 
 
 
 
 
 *使用connect 连接目标主机端口,能连接成功 说明端口开放否则端口关闭
 
 
 
 
 

准确的说也不是严格的方案要根据实际的业务场景来配合。

现在的方案是保存rdd的最后一个offset我们可以考虑在处理完一个消息之后就更新offset,保存offset和业务处理做成一个事务当出现Exception的时候,都进行回退或者将出现问题的offset和消息发送到另一个kafka或者保存到数据库,另行处理错误的消息代码demo如下


 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 * 发送一个带有fin标记的TCP 若返回RST+ACK 则端ロ关闭 否则什么也不返回
 * 发送一个任何标记不带的TCP 若返回RST+ACK 则端口关闭 否则什么也不返回
 
 
 
 
 
 
 
 *使用connect 连接目标主机端口,能连接成功 说明端口开放否则端口关闭
 
 
 
 
 

我要回帖

更多关于 reset是什么意思啊 的文章

 

随机推荐