Я упрощаю свою проблему по следующему сценарию: 3 друга делят карту лояльности. Карта имеет два...
У нас есть приложение Spark Streaming (Kafka), которое также выступает в роли продюсера, создавая...
Я хочу отправить несколько пользовательских заголовков запроса при подключении к реестру схемы из...
Я должен установить IP-адрес zookeeper в ConsumerGroup вместо IP-адреса Kafka-Host. Потому что я...
У меня есть приложение для потоковой передачи, которое потребляет данные из темы 1 и анализирует их...
У меня есть кластер из 3 брокеров Kafka с коэффициентом репликации 3 для всех тем.Так как последние...
Я использую Spring Framework и Kafka, в котором есть 3 кластера. Я обнаружил, что потребитель не...
Моя цель - у меня есть приложение для загрузки весенних приложений kafka со свойством сериализации...
У меня есть производитель, который создает сообщение в Кафке, прежде чем создавать сообщение. Я...
Я хочу, чтобы мое весеннее загрузочное приложение не запускалось при запуске, если оно не может...
Я пытаюсь удалить тему Кафки __Consumer_offset, так как это вызывает много недоразумений у моих...
асинхронный вызов не работает с Callback (), программа ожидает завершения send () и не выполняет...
Мне нужно сохранить потоковые данные в майскую базу данных Casandra, используя Kafka spark stream....
kafka-console-consumer.bat --bootstrap-server localhost:2181 --topic baeldung kafka-console-producer
У меня есть конфигурация flume, которая пытается подогнать логи -> сгенерировать UUID ->...
KafkaProducer не может выбрать schema.registry.url, определенный в его свойствах. Как мы можем...