这家伙太懒,什么都没留下
那你应用突然重启呢?考虑过这种场景吗
弄个一个AtomicLong atoOffset,用来存储已提交的offset,如果当前要提交的offset<atoOffset,则不提交
你这个是网络问题那,超时。
出现了下面的异常
java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
客户端低版本可以向高版本发的。