You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by Sachin Mittal <sj...@gmail.com> on 2017/05/02 07:43:44 UTC

Failure on timestamp extraction for kafka streams 0.10.2.0

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

Re: Failure on timestamp extraction for kafka streams 0.10.2.0

Posted by Sachin Mittal <sj...@gmail.com>.

Thanks. Upgrade fixed it.

On Tue, May 2, 2017 at 2:48 PM, Eno Thereska <en...@gmail.com> wrote:

> Hi Sachin,
>
> This should be fixed in 0.10.2.1, could you upgrade to that release? Here
> is JIRA: https://issues.apache.org/jira/browse/KAFKA-4861 <
> https://issues.apache.org/jira/browse/KAFKA-4861>.
>
> Thanks
> Eno
> > On May 2, 2017, at 8:43 AM, Sachin Mittal <sj...@gmail.com> wrote:
> >
> > The timestamp of the message is out of acceptable range
>
>

Re: Failure on timestamp extraction for kafka streams 0.10.2.0

Posted by Eno Thereska <en...@gmail.com>.

Hi Sachin,

This should be fixed in 0.10.2.1, could you upgrade to that release? Here is JIRA: https://issues.apache.org/jira/browse/KAFKA-4861 <https://issues.apache.org/jira/browse/KAFKA-4861>.

Thanks
Eno
> On May 2, 2017, at 8:43 AM, Sachin Mittal <sj...@gmail.com> wrote:
> 
> The timestamp of the message is out of acceptable range