kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Sachin Mittal <sjmit...@gmail.com>
Subject Failure on timestamp extraction for kafka streams 0.10.2.0
Date Tue, 02 May 2017 07:43:44 GMT
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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message