mujianping

When I use an earlier version of the server or the server uses an earlier version of the encryption algorithm, an authentication failure message is displayed, as shown in the...

> Hi @mujianping, > > I'm not sure I understand? Are you stating that you are encountering this issue with the current JSch release ([0.2.11](https://github.com/mwiede/jsch/releases/tag/jsch-0.2.11))? > > Thanks, Jeremy Hi...

**I've learned that Exactly-once are conditional**

这块代码应该使用fileNodeKey对应的应该是sourceKey，否则在KafkaCallBack中写入的都是fileKey，在flush的时候进行rollback， for (String key : failedOffsetMap.keySet()) { WorkingFileNode wfn = ((LogSource) source).getCollectingFileNodeMap().get(key); LOGGER.info("rollback !wfn is " + wfn); if (wfn != null) { wfn.seek(failedOffsetMap.get(key)); } } 这个wfn始终是null，会丢消息