У меня есть вопрос о TopologyTestDriver и KTable;У меня есть потоковая топология, которая настраивает KTable.
builder.table("topicA",
Consumed.with(Serdes.Long(),
Serdes.String()),
Materialized.as("a-store")
);
, когда я пытаюсь получить доступ к этому хранилищу состояний позже в тесте, он жалуется на отсутствие зоопарка или брокера (что правильно, хотя я думал, что этоМодульное тестирование Мне не нужно было запускать Kafka и Zookeeper).
Если мне нужно запустить Zookeeper и Kafka, какова цель модульного тестирования, тогда я разработаю тест для встроенного Kafka.
Так нужно ли мне запускать Zookeeper и Kafka для проверки этого случая?
Один побочный вопрос, старые статьи в Интернете показывают 'ProcessorTopologyTestDriver' в качестве точки входа, но я не могу найти этот класс в2.0 файлов, так что теперь TopologyTestDriver является правильным классом для реализации модульных тестов для Kafka ...