Ниже приведена ошибка после запуска потока в течение определенного времени? Я не могу найти, кто несет ответственность за создание файла .sst? Env: Kafka version 0.10.0-cp1 scala 2.11.8 org.apache.kaf
В потоках Кафки, канонический способ создания/записи потока? В Spark есть пользовательский ресивер, который работает как долго работающий адаптер из произвольного источника данных. Что эквивалентно в
Я использую потоки Кафки для выполнения параллельных работ по теме Кафки. Поток имеет следующий вид stream(topic)
.map(somefunction)
.through(secondtopic)
Я установить KStreams иметь 15 рабочих по
Я попытался запустить примеры Кафка-потоки по адресу: https://github.com/confluentinc/examples/tree/master/kafka-streams Команды как mvn compile и mvn test по отрасли «Кафка-0.10.0.0-ф-3.0.0», как пре