Hi Hamza,
If you have an infinite while loop, that would mean the app would spend all the
time in that loop and poll() would never be called.
Eno
> On 28 Nov 2016, at 10:49, Hamza HACHANI <hamza.hach...@supcom.tn> wrote:
>
> Hi,
>
> I've some troubles with the method puctuate.In fact when i would like to
> print a string in the method punctuate.
>
> this string would be printed in an indefinitly way as if I printed (while
> (true){print(string)}.
>
> I can't understand what happened.Does any body has an explenation ?.
>
>
> Besides In the other hand,for another application it print the following
> error :
>
> WARN Failed to commit StreamTask #0_0 in thread [StreamThread-1]:
> (org.apache.kafka.streams.processor.internals.StreamThread)
> org.apache.kafka.clients.consumer.CommitFailedException: Commit cannot be
> completed since the group has already rebalanced and assigned the partitions
> to another member. This means that the time between subsequent calls to
> poll() was longer than the configured session.timeout.ms, which typically
> implies that the poll loop is spending too much time message processing. You
> can address this either by increasing the session timeout or by reducing the
> maximum size of batches returned in poll() with max.poll.records.
>
> When i tried to modify the configuration of the consumer nothing happened.
>
> Any Ideas for this too ?
>
> Thanks in Advance.
>
>
> Hamza
>
