apache-kafka-connect

0зной

1ответ

Как настроить Kafka, чтобы потребители и производители восстанавливались после сбоев при отключении репликации?

У нас есть прецедент, где допустимость потери данных (думаю, приемлема 30-50%). Чтобы уменьшить затраты, мы хотим знать, можно ли настроить Kafka с коэффициентом репликации 1, чтобы потребители и прои

1зной

1ответ

Есть ли клиент Kafka Connect Python?

У меня есть приложение, которое читает из тем Kafka. Теперь мне нужно отправить их в HDFS с помощью разъема Kafka: http://docs.confluent.io/2.0.0/connect/connect-hdfs/docs/index.html Есть команды для

0зной

2ответ

Как установить max.poll.records в API-интерфейсе Kafka-Connect платформы Confluent

Я использую платформу confluent-3.0.1 и создаю разъем Kafka-Elasticsearch. Для этого я использую SinkConnector и SinkTask (API-интерфейс Kafka-connect) для получения данных от Kafka. В качестве части

1зной

2ответ

Kafka connect confluent elasticsearch раковина (не найдена погрешность класса)

Я очень новичок в подключении Kafka. Я хочу подтолкнуть свои сообщения из темы Кафки к elasticsearch. После того, как вы выполнили доступную документацию .. Я загрузил и скомпилировал эластичный раков

0зной

1ответ

Как создать Kafka Connect, который является раковиной, а также источником

Я разрабатываю Kafka-Connector, который подписывается на тему, трансформирует сообщения, переводит преобразованные сообщения обратно в другую тему. До сих пор я реализую его как класс SinkTask, и кажд

0зной

1ответ

Какие API-интерфейсы REST доступны для Kafka Connect?

Я столкнулся с двумя ссылками о API REST для Kafka Connect. Есть несколько дополнительных в https://kafka.apache.org/documentation#connect. Получите ошибку 404, когда я использую GET /connectors/{name