apache-kafka

1зной

1ответ

Query Кафка для сообщения (ий) по ключевым

У меня есть простая конфигурация Кафка: по умолчанию консоли-производитель записывает на одну тему с одним разделом пользовательского процессором (который реализует org.apache.kafka.streams.processor.

4зной

1ответ

искра потоковом утверждение не удалось: Не удалось получить записи для искрового исполнитель-а-группа А-тему 7 244723248 после опроса 4096

Спарк Streaming Проблема с Кафки DirectStream: искра потоковом утверждение не удалось: Не удалось получить записи для искровых исполнитель-а-а-группы темы 7 244723248 после опроса для 4096 Пытались: 1

0зной

1ответ

Какой производитель собирает и конвертирует журналы веб-сервера в формат avro и пишет в kafka?

В настоящее время я хочу собрать журналы веб-сервера apache (файлы access_logs, error_logs) и написать в Kafka в формате Avro. Доступен ли существующий производитель для этой операции ?. Если вы не мо

0зной

1ответ

Kafka Распределение тем среди брокеров

При создании тем мы можем определить, какой брокер будет лидером по этой теме? Рассматриваются ли темы в брокерах в Кафке? (С учетом темы есть только один раздел)

1зной

1ответ

Ranger пользователь синхронизации с Kerberos

У меня есть настройка Kerberos следующие ниже документа http://docs.hortonworks.com/HDPDocuments/Ambari-2.2.0.0/bk_Ambari_Security_Guide/content/ch_configuring_amb_hdp_for_kerberos.html Кроме того, я

0зной

2ответ

Разрешение отказано в модуле omkafka rsyslog

Я пытаюсь опубликовать сообщения от rsyslog на kafka на удаленной машине с помощью модуля omkafka. My omkafka action is configured as: if $HOSTNAME == 'localhost' then { action(type="omkafka"

0зной

1ответ

Можно запустить Elasticsearch 5.x с Flink 1.2.0?

Возможно ли запустить версию elasticsearch версии 5.x в Apache Flink 1.2.0? Я не могу обновить свой Flink до 1.3, потому что мне нужна версия 1.2.0 для запуска kafka. тем, что говорится в этой ссылке:

1зной

1ответ

Kafka spout интеграция

Я использую kafka 0.10.1.1 и storm 1.0.2. В документации по бури для интеграции kafka я вижу, что смещения все еще поддерживаются с использованием zookeeper, поскольку мы инициализируем kafka spout с