youmisun

> > 你可以直接使用 1.14 编译，没有什么问题的。 > > 报好多错额； > > go 1.14 > > runtime: bad pointer in frame github.com/konsorten/go-windows-terminal-sequences.EnableVirtualTerminalProcessing at 0xc000107670: 0x250 > fatal error: invalid pointer found on...

> **_sess.MarkMessage(msg, "") 这个 saram确实有实现，之前没看到，但是saram的实现并没有进行消息提交_**  _**但是好像作者用错了**_ > > 因为配置文件里面写的是自动提交 这样会有一个问题 如果offset提交后，消费者并没有把offset前的消息处理完就crash了 下次消费者起来时，会从之前提交的offset处拉取消息 这就导致了一部分消息的丢失 > > 为了避免消息丢失 应该采用手动提交 作者认为 sess.MarkMessage(msg, "")会把offset提交到kafka 所以就在自动提交模式下用了MarkMessage > > 但是： > > ### **sess.MarkMessage(msg,** "")...

> @youmisun 当前只有在线实时投递 后续有打算支持离线消息吗