Количество слов Kafka не обновляется

Моя песочница — это ящик с Ubuntu 16.04.2 LTS, Kafka 0.11.0.0 и Scala 2.11.11.

Как объясняется в руководстве по быстрому запуску Kafka Streams, я выполнил следующие шаги:

echo -e "all streams lead to kafka\nhello kafka streams\njoin kafka summit" > file-input.txt

bin/kafka-topics.sh --create \
    --zookeeper localhost:2181 \
    --replication-factor 1 \
    --partitions 1 \
    --topic streams-file-input

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic streams-file-input < file-input.txt

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

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 \
    --topic streams-wordcount-output \
    --from-beginning \
    --formatter kafka.tools.DefaultMessageFormatter \
    --property print.key=true \
    --property print.value=true \
    --property key.deserializer=org.apache.kafka.common.serialization.StringDeserializer \
    --property value.deserializer=org.apache.kafka.common.serialization.LongDeserializer

При просмотре вывода streams-wordcount с помощью последней команды мой стандартный вывод показывает следующее:

all 1
streams 1
lead    1
to  1
kafka   1
hello   1
kafka   2
streams 2
join    1
kafka   3
summit  1

Затем, не прерывая команду bin/kafka-console-consumer.sh, я повторно запускаю производителя консоли следующим образом:

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic streams-file-input < file-input.txt

Я удивлен, что стандартный вывод не меняется, чтобы отразить изменения, внесенные этим новым дополнением. Насколько я понимаю, файл-input.txt использовался для получения дополнительных данных, поэтому количество слов должно было обновиться (теперь все токены должны учитываться дважды). Что не так с моими рассуждениями?