apache-kafka

2зной

1ответ

Не удалось перезагрузить ошибку в потоках Kafka с более чем одним разделом тем

Работает нормально, если исходный раздел разделов = 1. Если я разбиваю разделы на любое значение> 1, я вижу ошибку ниже. Применимо как к низкому уровню, так и к API DSL. Любые указатели? Что может быт

3зной

1ответ

Что delete.topic.enable в Кафке

Я новичок в Кафка, я создал некоторые темы под названием Hell0-Kafka3 Теперь я хочу, чтобы удалить его. Поэтому я выдавать такую команду: $ bin/kafka-topics.sh --zookeeper localhost:2181 --delete --

0зной

1ответ

Как автоматически выбрать файл как вход производителя кафки?

Я только начал изучать Кафку. Я сделал много googlings, но до сих пор не знаю: как я могу автоматически собирать файлы, упавшие в папке, как входные данные производителя и, следовательно, получать пот

9зной

1ответ

Spark-Streaming от актера

Я бы хотел, чтобы пользователь-потребитель подписался на тему Kafka и передал данные для дальнейшей обработки с помощью Spark Streaming вне потребителя. Почему актер? Поскольку я читал, что его страте

2зной

1ответ

Kafka High-level Consumer error_code = 15

При попытке потребления у Kafka с использованием потребителя высокого уровня (с использованием совершенно новой группы потребителей) потребитель никогда не запускается. Когда я включаю уровень протоко

1зной

2ответ

Могут ли разные темы Kafka иметь разные длины удерживания?

У меня есть главная тема (с сохранением журнала 7 дней) и несколько более мелких тем с фильтрованным корпусом с меньшим сохранением журнала (2 дня). Это возможно? Я использую Kafka v0.10.1.1.

0зной

1ответ

Исключение из потока «main» java.lang.NoClassDefFoundError: org/spark_project/guava/cache/CacheLoader

Когда я пытаюсь выполнить проект искры kafka. Я получаю ниже ошибок: Exception in thread "main" java.lang.NoClassDefFoundError: org/spark_project/guava/cache/CacheLoader at org.apache.spark.Spark