Хотелось бы узнать сжатый размер сообщения в кафке. Я использую kafka 1.1.0 и java kafka-connect 1

Следующее исключение выдается для Elastic Search Connector: [2018-05-07 11:40:38,975] ERROR...

Проект Prometheus jmx_exporter предоставляет официальный пример конфигурации для Kafka здесь:...

Я создал простейшую конфигурацию коннектора раковины kafka, и я использую confluent 4.1.0: {...

Я пытаюсь собрать kafka-connect-hdfs, следуя этому FAQ. При попытке скомпилировать схему-реестр я...

у меня есть схема { "type" : "record", "name" : "test",...

Здравствуйте, у меня возникла проблема при установке разъема эластичного поиска для Kafka. Я...

У меня есть тема kafka, значение там - формат avro, где схема хранится в реестре схемы. Теперь я...

Я загружаю ниже файл JSON с ./confluent load CRM_TEST -d /kafka/CRM_TEST.json затем происходит...

Я пытаюсь запустить kafka-connect-hdfs безуспешно. Я добавил следующую строку в .bash_profile и...

jar-файл jdbc для ibm db2 as400 находится по адресу: /confluent-4.1

Когда я создаю соединитель источника или приемника с помощью Confluent Control Center, где он...

Я пытаюсь подключить мой Kafka к HDFS, но при запуске конфигурации я получаю следующую ошибку: java

Я попытался создать этот соединитель из Confluent Control Center, и нажатие кнопки «Продолжить» на...