lsm

0 声望

这家伙太懒，什么都没留下

个人动态

贬了 lsm 在 kafka根据时间戳消费或者消费指定时间内的数据的评论!
```
 props.put("log.message.timestamp.type","LogAppendTime");
```
为什么设置了没反应
5年前
贬了 lsm 在 kafka根据时间戳消费或者消费指定时间内的数据的评论!
使用KafkaConsumer.offsetsForTimes，但要确认集群已开启log.message.timestamp.type参数，并且clien要使用0.10.*的客户端发送数据，数据格式和0.9不同了。

5年前