Я занимаюсь тестированием и имею только 300 сообщений в теме кафки. При попытке показать, что отсчитывается время ожидания команды kafka-console-consumer:
$kafka-console-consumer --from-beginning --bootstrap-server localhost:9092 --property print.key=true --property print.value=false --property print.partition --topic air2008 --timeout-ms 20000 | tail -n 10
[2019-05-10 22:55:01,646] ERROR Error processing message, terminating consumer process: (kafka.tools.ConsoleConsumer$)
org.apache.kafka.common.errors.TimeoutException
Processed a total of 300 messages
2008-06-05_730
2008-06-05_332
2008-06-15_1669
2008-06-12_1637
2008-06-21_227
2008-06-25_542
2008-06-17_1790
2008-06-22_1058
2008-06-04_1676
Что на самом деле здесь происходит / чего ждут? Я могу изменить время ожидания с 20 секунд до более высокого (например, 60 секунд) или ниже (например, 1 секунда) - но получаю ту же ошибку.