Я учусь использовать Кафку, используя Spring Kafka в Котлине. Я понял, что когда публикуется новая...
Сценарий / вариант использования: У меня есть приложение Spring Boot, использующее Spring для Kafka...
У меня успешно установлен кластер Strimzi Kafka в OpenShift. Я вижу следующие услуги: kafka-brokers...
Чтобы настроить SSL для REST API Kafka connect, я следовал за документацией, приведенной в...
У меня есть потребитель Kafka со следующими параметрами: bootstrap.servers=<server.list>...
Я пробовал разные методы, но не смог получить права. что не так в этом коде? def main(args:...
Я думаю о создании отдельного производителя Kafka, который будет работать как демон, принимать...
Это мой первый пост в Stackoverflow, надеюсь, я выбрал не тот раздел. Контекст: Размер KAPKA HEAP...
Если я передаю html-файлы в форме Array [Byte] на стороне производителя в kafka, то как...
Я хочу запустить несколько потребителей для проверки ребалансировки в kafka, но я получаю ошибку...
Я хочу получить данные из SQL в разделы kafka с помощью Source Connector, поэтому для этого я...
Я создал два приложения wurstmeister/kafka и zookeeper, как показано ниже. oc new-app...
Я запускаю java 8 Kafka Applications из мэйнфрейма (config, application.properties и) и публикую...
Я использую Samza, чтобы получать сообщения из заданной темы Кафки в Scala. Для запуска я создал...
Я использую Kafka Console Producer для публикации JSON-сообщения на тему kafka. Полезная нагрузка...
У меня есть цепочка сертификатов (chain.pem), которая содержит 3 сертификата в порядке сертификата...
У меня есть приложение весенней загрузки, которое использует kafka, но я не могу его запустить,...
Я использую flume для передачи данных от потребителя kafka в приемник hdfs. Когда данные...
Мы изменили раздел темы и увеличили количество разделов с одного до 10. Но теперь все сообщения...
Я выполнил идентификационный проект, который взял данные с камеры rtsp и включил их в Tensorflow, и...
Это очень общий вопрос для сообщества, особенно для тех, кто читает Мост Кафки Стримзи, если они...
В чем разница между настройкой конфигурации Kafka как Properties объекта и Map объекта. Например:...
Мой файл server-1.properties выглядит следующим образом: listeners = PLAINTEXT://<domain...
Я пытаюсь подключиться к док-контейнеру kafka из другого док-контейнера. Но он не подключился....
Мы пишем новое приложение, которое публикуем в Kafka, и нам нужно сериализовать ключ сообщений как...