Hi, We are getting this exception right when we start the stream. org.apache.kafka.common.KafkaException: Unexpected error from SyncGroup: The timestamp of the message is out of acceptable range. at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.java:535) ~[kafka-clients-0.10.2.0.jar:na] at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.java:508) ~[kafka-clients-0.10.2.0.jar:na] at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:764) ~[kafka-clients-0.10.2.0.jar:na] at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:745) ~[kafka-clients-0.10.2.0.jar:na] at org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:186) ~[kafka-clients-0.10.2.0.jar:na] at org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:149) ~[kafka-clients-0.10.2.0.jar:na] at org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:116) ~[kafka-clients-0.10.2.0.jar:na] at
In server.properties we have: log.message.timestamp.type=LogAppendTime and at streams side we are using default: timestamp.extractor = class org.apache.kafka.streams.processor.FailOnInvalidTimestamp What could be the reason here. I suppose by specifying LogAppendTime we are essentially instructing to provide the broker side ingestion timestamp and not rely on any producer sent timestamp. Thanks Sachin