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

Я установил для enable.auto.commit значение true, для интервала автоматического принятия - 1000 мс,...

Я работаю над дизайном MySQL -> Debezium -> Kafka -> Flink -> Kafka -> Kafka Connect JDBC -> MySQL

Я установил конфигурацию jaas для kafka, используя свойство sasl.jaas.config.Я хочу обновить этот...

Я использую python3 и confluent-python , чтобы отправить сообщение Кафке.Мне нужно отправить данные...

Сообщение под темой Кафки также называется log? log разделы = разделы сообщения темы? # The default...

Я бы хотел отобразить поток kafka на входы Unity. Мне удалось получить вывод на консоль в C #,...

Я пытаюсь реализовать шаблон запроса / ответа с Kafka.Я работаю с именованными службами и...

При использовании исторических данных в операторе соединения с eventTime чтение данных из одного...

Мне нужно включить / выключить потребителя Kafka на основе некоторого свойства, управляемого базой...

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

Я пытаюсь сбросить смещение определенного раздела темы kafka, но я не нашел ни одной команды. Мне...

Распределенный журнал - это здорово, но я вижу хорошие варианты использования и для эфемерных тем,...

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

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

Я использую bin / kafka-topics.sh --zookeeper --delete --topic и вижу в логах kafka, которые...

у меня есть 6 брокеров kafka: Kafka1.fat: 9092, kafka2.fat: 9092, kafka3.fat: 9092, kafka4.fat:...

Я новичок в lagom ,asticsearch, я использую lagom ,asticsearch, scala и cassandra. Все хорошо, но...

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

У меня есть функции A, B & C. Когда я вызываю функцию A (), она отправляет уведомление kafka, и...

Я хочу знать текущее смещение FlinkKafkaConsumer010 в режиме реального времени для мониторинга.В...

, когда я пытаюсь запустить сервер Zookeeper с помощью команды .\bin\windows\zookeeper-server-start

У меня проблема при публикации сообщения json в теме kafka через конвейер данных в Apache Nifi, где...

У меня есть разъем источника и приемника Kafka Connect для помещения данных в Kafka и их извлечения

Я сбрасываю сообщения журнала Kafka, чтобы посмотреть, что находится внутри файлов журнала.Тем не...