I have a scenario where we need to send messages to Kafka using transactional and non-transactional producers simultaneously. In this scenario I also want to monitor the highest offset value for particular partition say 0.Highest offset is nothing but offset of last committed message.