概要描述

kafka topic增加时间戳

详细说明

为单个topic增加时间戳支持
bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic test --partitions 1 --replication-factor 1 --config message.timestamp.type=LogAppendTime

使用console消费时打印时间戳
./kafka-console-consumer.sh --bootstrap-server ip:9092 --topic test --property print.timestamp=true