props.put("log.message.timestamp.type","LogAppendTime");
为什么设置了没反应
使用KafkaConsumer.offsetsForTimes
,但要确认集群已开启log.message.timestamp.type
参数,并且clien要使用0.10.*
的客户端发送数据,数据格式和0.9
不同了。
今日访问:
昨日访问:
本周访问:
本月访问:
所有访问:1003
最近登录:3年前
加入时间:2019-07-11 14:06:11