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
