Я использую Debezium MongoDB Connector для прослушивания определенной коллекции MongoDB, чтобы...

Я новичок в Кафке и изучаю его. Я использую сливную платформу для работы с Кафкой. Я создал тему в...

Я вижу следующее исключение, когда настраиваю исходное соединение для чтения из таблицы в тему...

Можно ли использовать Confluent Kafka JDBC connect в кластере Apache Kafka? Я пытаюсь использовать...

Я пытаюсь добавить kafka-mongo-connector в kafka-connect, чтобы быть источником событий. Я...

Я хочу использовать Apache Kafka Connect, чтобы получать твиты из Twitter и помещать их в мой...

Может кто-нибудь сказать мне, почему мое snowke.topic2table.map сообщение о том, что мое Snowflake...

Чтобы настроить SSL для REST API Kafka connect, я следовал за документацией, приведенной в...

Я хочу получить данные из SQL в разделы kafka с помощью Source Connector, поэтому для этого я...

Я использую исходный JDBC-разъем Kafka для извлечения событий БД, и я запускаю kafka connect в...

Я создаю собственный SinkConnector с использованием Kafka Connect (2.3.0), который необходимо...

Я настроил сотрудников Kafka connect для работы в кластере и получения данных БД. Также я сохранил...

Я пытаюсь запустить работников Kafka в распределенном режиме.В отличие от автономного режима, мы не...

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

У меня есть два узла соединителя Kafka, скажем Node-A и Node-B. Я запускаю одного распределенного...

Мне нужно создать приложение, которое читает из Kafka и записывает данные в MongoDB.В большинстве...

Можно ли публиковать xml в кафке?Если да, какой метод можно использовать для сериализации данных,...

В настоящее время я настроил отдельный запрос в файле свойств исходного соединителя Kafka JDBC, и...

Я использую ниже конфигурацию kafka для одного из моих производителей, функциональность работает...

Я устанавливал службу kafka connect для получения данных от MySQL к kafka брокеру.Просматривая...

Я вижу, что это обсуждалось несколько раз здесь, например , но я думаю, что решения устарели из-за...

это очень странная проблема, я маскирую метку времени для String, используя TimestampConverter,...

Я использую curl для отправки нашей службе Kafka Connect сообщения запроса JSON с информацией о...

Я использую исходный соединитель jdbc, в именах моих таблиц есть специальные символы (т. Е. $),...

У меня был мой исходный разъем debezium mysql, работающий на Kafka.Я добавил еще один исходный...