The following tool is really good:
https://github.com/yahoo/kafka-manager
On Sat, Apr 21, 2018 at 5:42 AM, Joris Meijer wrote:
> You can do this without exposing the JMX port, e.g. by using a Prometheus
> exporter as javaagent (https://github.com/prometheus/jmx_exporter).
>
>
If you set *message.timestamp.type* (or *log.message.timestamp.type*) to be
LogAppendTime, this would make sense.
I am new to Kafka, too, and if this was set to CreateTime, I don't know
what the behavior would be. There is *message.timestamp.difference.max.ms