Я пытаюсь использовать ReplyingKafkaTemplate и периодически вижу сообщение ниже. Нет ожидающего...

Нашему новому кластеру kafka не хватило места быстрее, чем ожидалось, поэтому я принял некоторые...

Я экспериментирую на Kafka с Spring Boot. Spring Boot 2.1.0.RELEASE Spring-Kafka 2.2.0...

Я создаю инструмент для потребления данных из Kafka и вставки их в MongoDB, с некоторыми...

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

При попытке запустить я получаю следующее: naren@tesla:~$ sudo su [sudo] password for naren:...

Моя тема называется mytopic.Мой потребитель может производить данные JSON из CSV.Мой CSV ниже owner...

У меня есть веб-сервис с пружинной загрузкой, который использует XML-файлы, создавая JSON для MQ,...

Загрузка соединителя: { "name": "jdbc-source-test", "config": {...

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

Я пытаюсь понять логи данных kafka.Я могу видеть журналы под dir, установленным в logs.dir как...

Я пытаюсь проверить потоковую передачу kafka с версией брокера 0.10 с этим кодом.Это просто простой...

Допустим, у меня есть один брокер kafka, настроенный с одним разделом log.retention.bytes=80000 log

Этот скрипт - метод подписки на событие от Kafka. using Confluent.Kafka; using Confluent.Kafka

Возможно ли подключение kafka к базе данных interbase с использованием interclient.jar.Я не могу...

Я создал поток NiFi, который в конечном итоге публикует записи json в виде записей с...

Я борюсь с этим уже около недели, пытаясь получить простую (3 поля) отформатированную AVRO таблицу...

Я использую распределенную установку kafka-connect. Я тестировал с одной установкой машины /...

Мне действительно нравится использовать все конфигурации, доступные в Spring Boot, для настройки...

Я строю кластер kafka на kubernetes, следуя этому руководству https://github

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

У меня есть вопрос о перераспределении в Kafka ... Допустим, у меня есть тема, в которой есть 3...

Возникла проблема при попытке добавить KafkaEx.ConsumerGroup в дерево наблюдения приложения....

В документации Beam рекомендуется использовать withLogAppendTime вместо withProcessingTime.Почему...

Я получил две ошибки при начальном соединении: [ошибка] Не удалось подключиться к брокеру...