Open MichaelDrogalis opened 5 years ago
Facing the same issue, [2019-12-10 15:53:04,788] ERROR Error processing message, terminating consumer process: (kafka.tools.ConsoleConsumer$:76) org.apache.kafka.common.errors.TimeoutException
Can it be modified easily?
When using kafka-avro-console-consumer with the
--timeout-ms M
switch, it will read messages for up to M milliseconds and then exit. Just before it exits, it logs the following message toERROR
:Instead of logging to
ERROR
, this should log toINFO
. This isn't an error because I instructed the program to terminate after the given duration.