Я ищу реализацию кода Python для преобразования Pandas Dataframe в json файл в формате, указанном...

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

ActiveMQ Горизонтальное масштабирование объясняется здесь: http://activemq.apache

Мы находимся в разработке и пытаемся удалить схему по теме, поскольку изменение несовместимо со...

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

Я новичок в Кафке.Мне нужно написать простого производителя и потребителя для Kafka от Spring Boot....

Я использую JDBC-коннектор в режиме «временной метки» для запроса таблицы CDC в SQL Server.Таблица...

Я пытаюсь опубликовать данные (счет) таблицы faust в теме kafka через некоторый промежуток времени

Я новичок в Kafka и micronaut, и я не понимаю, как использовать @KafkaKey.В интернете я обнаружил:...

У меня есть брокер Kafka с одним узлом, работающий внутри модуля в среде kubernetes с одним узлом.Я...

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

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

Я пытаюсь следовать руководству, чтобы настроить шифрование и аутентификацию SSL: https://kafka

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

Для мониторинга процессов микросервисов моя команда настроила стек ELK с выходом, направленным...

Поскольку мы мигрировали на Kafka-клиент 2.3 (ранее он был 1.1), мы периодически получаем...

Мой сервис работает в K8s и является потребителем тем Kafka.Метрики, связанные с темами Kafka,...

Мне нужно поместить данные из OPC-UA в тему в kafka. Я попытался найти соединитель или технологию,...

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

Я прочитал документацию по безопасности Kafka здесь: https://kafka.apache

Я обновил одного из наших потребителей C #, и он (казалось) случайно входил в цикл неудачных...

Мы используем поток kafka для потребления данных.У нас есть кластер с 4 брокерами и раздел с 64...

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

Я заинтересован в реализации метода на python, который будет вызываться каждые несколько минут и...

В моем тесте на цитрусовые я хочу проверить количество определенных сообщений в теме Кафки. Однако...