Whe response metadata from kafka drive formatdatetime correct:

RecordMetadata metadata = r.recordMetadata(); Instant timestamp = Instant.ofEpochMilli(metadata.timestamp()); LocalDateTime localDateTime = LocalDateTime.ofInstant(timestamp, ZoneId.systemDefault()); ZonedDateTime zonedDateTime = localDateTime.atZone(ZoneId.systemDefault()); try { dateFormat.format(timestamp); }catch(Exception e){ e.printStackTrace(); } System.out.printf("Message %d sent successfully, topic-partition=%s-%d offset=%d timestamp=%s\n", r.correlationMetadata(), metadata.topic(), metadata.partition(), metadata.offset(), dateFormat.format(timestamp));