Давайте предположим, enable.auto.commit = true , и давайте предположим, что тема, из которой я...
У меня есть сторонний API, который создает события через websocket.Как лучше всего прослушивать и...
Я работаю над топологией, используя Apache Flux.В настоящее время strom получает сообщения с самого...
Мы читаем входящие записи из нашего приложения и используем идентификатор пользователя (в виде...
У меня есть kafkaspout, 2 болта для обработки данных, 2 болта для хранения обработанных данных в...
repo: yolean / kubernetes-kafka Я собираюсь выполнить шаги по развертыванию кластера kafka в облаке
, поэтому у меня есть контроллер конечной точки SpringBoot, который запускается так:...
Нужна помощь в выяснении проблем с настройкой круиз-контроля kafka с кластером kafka с 3-мя...
Я попытался настроить Zookeeper на экземпляре AWS EC2 Windows 10 и затем подключить Kafka 2.11-1.1
Консольные команды kafka-console-producer.sh и kafka-console-consumer.sh работают правильно, но...
Существует ли какой-либо подход, позволяющий определить, по какому тарифу потребитель кафки...
Скажите, если интервал автоматической фиксации составляет 30 секунд, потребитель по некоторым...
У меня есть поток данных, например: DataStream[myTuple(topic, value)] И я хотел отправить...
Пару месяцев я играл с Кафкой (1.0.0) и пытался понять, как работает группа потребителей.У меня...
я запустил zookeeper и Kafka server на машине с Linux.Оба сервера запущены успешно.После этого я...
Я работаю над приложением kafka и весенней загрузкой.Я пишу файл для привода с помощью Java API...
Caused by: org.apache.kafka.common.errors.SerializationException: Error retrieving Avro schema for...
Шаг 1: создать тему только с одним разделом: bin/kafka-topics.sh --create --zookeeper...
Рекомендованная настройка для JVM выглядит следующим образом -Xmx8g -Xms8g -XX:MetaspaceSize=96m...
Вот список плагинов моего коннектора: > curl localhost:8083/connector-plugins {...
Изучая кафку в документации, я нашел следующее предложение: Очередь - это стандартный тип обмена...
Я пытаюсь прочитать сообщение от Kafka, используя потребителя со следующими свойствами value
При использовании службы заказов Kafka в Hyperledger Fabric каждый канал сопоставляется с темой с...
Справочная информация: Ранее мы использовали поиск в спящем режиме, очередь Lucene и jboss hornetq...
У меня есть образ докера, расположенный здесь https://github.com/Landoop/fast-data-dev, в котором...