我的也是key有值,value为null,咋解决的啊
props.put("log.message.timestamp.type","LogAppendTime");
为什么设置了没反应
请问下,假如kafka集群这个参数是默认的CreateTime,我又不想改集群配置,可以直接消费的时候指定这个参数为LogAppendTime
props.put("log.message.timestamp.type","LogAppendTime");
为什么设置了没反应
props.put("log.message.timestamp.type","LogAppendTime");
为什么设置了没反应
这个就是开启时间戳的, 然后用这个方法offsetsForTimes 获取偏移量?
你也用cdh啊。这就简单了,在高级配置里找到kafka.properties的kafka broker高级配置代码段,这个选项,配进去就重启就可以了。