Hi, I'm new here, but I just read this and have implemented similar functionality for our cli tool (https://github.com/deviceinsight/kafkactl).
In order to get a tail on topic level we fetch the last n messages from all partitions but only keep the latest n messages according to message timestamp in a buffer and finally print those messages. Perhaps that's also an option? Regards, Dirk Am 20. Januar 2020 03:27:54 MEZ schrieb Hu Xi <huxi...@hotmail.com>: >Hi All, > >I'd like to start a discussion on KIP-563 which is to add "tail -n" >capability for ConsumerConsole tool. > >Please check >https://cwiki.apache.org/confluence/display/KAFKA/KIP-563%3A+Add+%27tail+-n%27+feature+for+ConsoleConsumer >for more details. Any feedbacks or comments are welcomed.
