Caused by: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.

df = new SimpleDateFormat(); // KeyedMessage message =new KeyedMessage("test","1","After Restart210"); // System.out.println(message.key()); // producer.send(message); // producer.close(); // System.out.println("done"); It works fine. Regards. Bhargav.

Re: How do you keep track of offset in a partition

Hi, How to know where to start consuming from, if we have already consumed a few messages. Some where in between latest and the earliest? How to identify the timestamp or offset from the api. Thanks, Bhargav --