apache-kafka-connect

0зной

1ответ

Как получить/прочитать данные кафки из флинка?

Я пытаюсь читать данные кафки из флинка, и поскольку я новичок в kafka и flink, я не знаю, как их соединить.

0зной

1ответ

Поддерживает ли kafka активный активный режим в распределенном режиме?

При тестировании подключения kafka в распределенном режиме мы обнаружили, что он работает в режиме ожидания, а не в активном активном режиме. Если у нас есть кластер из двух элементов, то только один

0зной

1ответ

Как удалить тему, которая запускается в многоуровневом многоуровневом кластере HA kafka

Я установил kafka версию 2.11-0.10.1.0 в многоуровневую многокластерную среду. В kafka server.properties я уже добавил delete.enable.topic = true в все 3 машины. Я использую команду для удаления темы

0зной

1ответ

Как CONVER полезных данных MQTT к Кафке строкового типа

Теперь я пытаюсь соединиться от MQTT сообщений Кафок (на самом деле искра потокового в Кафке) Я использовал этот Коннектер https://github.com/evokly/kafka-connect-mqtt И Спарк-2.1. 0, Кафка - 0.10.1.1

1зной

1ответ

Проблема доступа AWS S3 при использовании qubole/streamx на AWS EMR

Я использую qubole/streamx в качестве разъема для раковины kafka, чтобы потреблять данные в kafka и хранить их в AWS S3. Я создал пользователя на AIM и разрешением AmazonS3FullAccess. Затем установите

0зной

1ответ

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

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