这家伙太懒,什么都没留下
您好,请问用go-kafka client来消费kafka中的数据时,代码中的Properties如何配置呢?
嗯嗯,知道了,谢谢
放入成功,会有多条的。kafka没有这块的逻辑,这个key你业务层拿到之后进行去重的。
奥奥,知道了,谢谢大神,那如果key相同的数据,会出现放入失败还是覆盖之前的数据呢?
kafka在发送消息的时候,有key和value。key可以根据你的需要进行自定义的。