Jiangjie (Becket) Qin
Jiangjie (Becket) Qin
@rmetzger @fhueske One thing not quite clear to me is the `compatible Flink version` section. As far as I understand, anything compatible with `Flink X.Y` should also be compatible with...
@rmetzger Thanks for pushing this. I'll remove the compatible versions column. > I'm fine leaving the compatibility version out. > > As I said before, I think the information about...
@JasonSongHoho 谢谢review。可否在你觉得有问题的具体地方加comments？笼统的对几篇文章对比可操作性有点低。
@xccui 谢谢这么仔细的review。修改以后的确通顺多了。
图片链接好像有问题，看不到图片。
I don't have an example of using this in Akka stream. What do you mean by Akka streams Kafka?
@clement76 I am not aware of any integration of li-apache-kafka-clients lib with Storm. But in general it should be a drop-in replacement.
@hussein-joe @artembilan The reason we need to set the internal KafkaConsumer offset reset strategy to be none is that we need to clean up the state of the affected partitions...
@kimgr Sorry for the late reply. And thanks for the patch. The patch itself looks good to me. Usually, a test needs to be added to verify the bug is...
Thanks for the patch. LGTM overall. Can we add a unit test?