./kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --describe --group Test-Group --command-config ../config/consumer.properties
我用这个命令查看消费组情况是正常的,但是我执行
./kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --list
就会报错。
返回的时间是utc时间×1000+毫秒,转显示时直接转本地时间会溢出,显示为-1
处理成真实utc时间后转本地时间即可
你好,我使用 SASL/SCRAM 认证之后kafka-consumer-group.sh查看消费组报错,搞了两天还没搞好
使用KafkaConsumer.offsetsForTimes
,但要确认集群已开启log.message.timestamp.type
参数,并且clien要使用0.10.*
的客户端发送数据,数据格式和0.9
不同了。
请问,我在server.properties中已经加入了message.timestamp.type=LogAppendTime这个配置,重启后新建的topic中消费出来的时间还是-1 这个是咋回事