org. apache .kafka.streams.examples.wordcount.WordCountDemo не завершается

Question

Я запустил этот скрипт, и он не заканчивается.

sudo ./bin/kafka-run-class.sh org.apache.kafka.streams.examples.wordcount.WordCountDemo

Вот результат:

[cloudera@quickstart kafka_2.12-2.4.1]$ sudo ./bin/kafka-run-class.sh org.apache.kafka.streams.examples.wordcount.WordCountDemo
[2020-04-14 13:26:36,153] WARN The configuration 'admin.retries' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)
[2020-04-14 13:26:36,165] WARN The configuration 'admin.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

Он не заканчивается.

Есть Любое решение, пожалуйста?

Answer 1

Это ожидаемое поведение демонстрационной версии , которую вы используете , и вам нужно нажать ctrl- c, чтобы завершить процесс.

---

Если вы хотите, чтобы демонстрация прекратилась через пять секунд, вы можете использовать более старую версию демонстрации, которая заканчивается через 5 секунд:

// usually the stream application would be running forever,
// in this example we just let it run for some time and stop since the input data is finite.
Thread.sleep(5000L);