Описание тега confluent-platform
Платформа потоковой передачи, обеспечивающая функции потоковой передачи корпоративных событий, дополняющие Apache Kafka.
1
ответ
Идеальное значение для конфигурации конфигурации Kafka Connect Distributed tasks.max?
Я ищу продукт для ионизации и развертывания моего приложения Kafka Connect. Тем не менее, у меня есть два вопроса о настройке tasks.max, которая необходима и очень важна, но детали неясны для того, чтобы на самом деле установить это значение. Мой са…
27 янв '17 в 18:30
1
ответ
Kafka Connect: подходящий драйвер не найден
Я пытаюсь Kafka с Postgres Sink, используя JDBC-приемник. Исключение: INFO Unable to connect to database on attempt 1/3. Will retry in 10000 ms. (io.confluent.connect.jdbc.util.CachedConnectionProvider:91) java.sql.SQLException: No suitable driver f…
25 июн '18 в 12:25
0
ответов
Проблемы, связанные с использованием таблицы Kafka KSQL AVRO в качестве источника для KDK Kinkka Connect JDBC Sink
Я боролся с этим уже около недели, пытаясь получить простую (3 поля) отформатированную AVRO таблицу KSQL в качестве источника для приемника коннектора JDBC (mysql) Я получаю следующие ошибки (после строки INFO): [2018-12-11 18:58:50,678] INFO Settin…
11 дек '18 в 19:31
1
ответ
kafka-connect-jdbc: SQLException: нет подходящего драйвера только при использовании распределенного режима
Мы успешно использовали загрузку данных mySQL - kafka с использованием автономного коннектора jdbc, но теперь столкнулись с проблемой при использовании того же самого в распределенном режиме (в качестве службы соединения kafka). файл connect-distrib…
15 ноя '18 в 14:32
1
ответ
Как запустить ksql в windows?
Как запустить ksql в среде Windows? мы установили сливную кафку в формате zip. мы не нашли файл ksql-server-start.bat в каталоге confluent-home / bin / windows, но мы обнаружили файл с таким же именем в каталоге confluent-home / bin /, который не яв…
30 янв '19 в 07:41
1
ответ
Сбой режима метки времени соединителя источника JDBC Kafka для sqlite3
Я попытался создать базу данных с двумя таблицами в sqlite. Однажды в моей таблице есть столбец метки времени. Я пытаюсь реализовать режим отметки времени для захвата постепенных изменений в БД. Соединение Kafka завершается с ошибкой ниже: ERROR Fai…
04 фев '19 в 14:55
2
ответа
Режим кластера реестра Confluent Schema
Я использую Kafka Connect из Confluent для использования потока Kafka и записи в HDFS в формате паркета. Я использую службу реестра Schema в 1 узле, и она работает нормально. Теперь я хочу перевести реестр схем в режим кластера, чтобы обработать отк…
26 авг '16 в 09:04
3
ответа
Полностью удалить Confluent на Linux
Я хочу полностью удалить слияние. Я установил его, следуя инструкциям на их сайте. Было три простых шага: $ wget -qO - https://packages.confluent.io/deb/4.0/archive.key | sudo apt-key add - $ sudo add-apt-repository "deb [arch=amd64] https://package…
18 фев '18 в 11:03
1
ответ
GenericRecord для объекта SpecificRecord с использованием Avro
Я использую Confluent.Kafka.Avro для сериализации между производителем и потребителем для Apache Kafka. От производителя я использую конкретную запись, но на стороне потребителя я хочу использовать все записи как общие, а затем преобразовать их в ко…
23 авг '18 в 09:31
0
ответов
Как получить последнее значение смещения от потребителя confluent_python AVRO
Я довольно новичок в confluent_kafka, но я приобрел некоторый опыт работы с kafka-python. То, что я пытаюсь сделать, это изменить смещение, где начать потреблять сообщения. Вот почему я хотел бы создать потребительский клиент, способный вернуться к …
22 апр '18 в 16:45
5
ответов
Kafka - Confluent - Поддержка версий Java
Я смотрю на Apache Kafka v2.0.0 и не могу понять, какую версию java он поддерживает (OpenJDK или новый жизненный цикл Oracle JDK)? До сих пор я видел противоречивые документы. Например: на странице документации Apache Kafka написано: Java 1.8, однак…
02 окт '18 в 16:16
0
ответов
'Confluent start': Не удается запустить Kafka, Zookeeper не запущен
Я получаю следующую ошибку при запуске платформы: $ ./confluent start Starting zookeeper |Zookeeper failed to start zookeeper is [DOWN] Cannot start Kafka, Zookeeper is not running. Check your deployment У меня Zookeeper работает на порте 2181, а Ка…
31 окт '17 в 13:38
1
ответ
KSQL EXTRACTJSONFIELD пробел в имени ключа
У меня проблема с пробелами в именах при использовании EXTRACTJSONFIELD в KSQL. Например: SELECT EXTRACTJSONFIELD(payload, '$.Successful Login') FROM MYSTREAM; - это всегда возвращает NULL Как мне обрабатывать пробелы в именах ключей? Я пытался: EXT…
11 июн '18 в 21:51
2
ответа
Невозможно собрать исходный код kafka-connect-jdbc
mvn install Команда не выполнена, и я не могу собрать исходный код kafka-connect-jdbc. Я собираюсь изменить исходный код kafka-connect-jdbc. Я следовал инструкциям https://github.com/confluentinc/kafka-connect-jdbc/issues/456 и https://github.com/co…
23 окт '18 в 01:26
2
ответа
Confluent Kafka подключения распределенного режима JDBC разъем
Мы успешно использовали загрузку данных mySQL - kafka с использованием автономного коннектора jdbc, но теперь столкнулись с проблемой при использовании того же самого в распределенном режиме (в качестве службы соединения kafka). Команда используется…
14 ноя '18 в 22:45
1
ответ
Соединитель JDBC Kafka с устаревшей базой данных
Я пытаюсь использовать kafka-jdbc-connector (как источник, так и приемник) с очень старой базой данных (cloudscape). У меня есть драйвер JDBC этой базы данных. Я поместил драйвер в папку Confluent "/share/java/kafka/connect/jdbc" (версия 5) и создал…
25 янв '19 в 12:25
1
ответ
Не удается найти разъемы в центре управления Confluent
Я учу кафку с помощью Confluent Platform. Я следовал их краткому руководству по началу работы с докером. Но когда я попытался сгенерировать фиктивные данные для этой темы, я не смог найти соединители, как в их руководстве. Затем я провожу дни, чтобы…
01 мар '19 в 08:54
1
ответ
Кафке не удалось начать использовать команду слияния
Я сталкиваюсь с некоторыми трудностями при попытке запустить ZooKeeper, Kafka и реестр схем через: $confluent start schema-registry Я запускаю кластер из 3 узлов, и по какой-то причине, когда я запускаю выше команды, Кафка не может запуститься: #roo…
16 авг '18 в 11:43
1
ответ
Confluent Kafka Streams - не удалось найти класс io.confluent.connect.avro.ConnectDefault
Я использую исходный соединитель jdbc с режимом запроса, и кажется, что без указанного имени таблицы схемы, зарегистрированные в реестре схемы для ключа записи и значения записи, имеют пустые имена схем и им присваивается имя по умолчанию "ConnectDe…
02 ноя '17 в 17:53
0
ответов
Kafka Mirror Maker не может воспроизвести тему __consumer_offset
Я пытаюсь использовать зеркало производителя для репликации __consumre_offsets тема наряду с другими темами. Это дает ошибку, как указано ниже. [2018-10-24 16:16: 03,802] ОШИБКА Ошибка при отправке сообщения в тему __consumer_offsets с ключом:16 бай…
24 окт '18 в 11:20