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

Reply via email to