У меня возникла следующая проблема: Я установил максимально возможную базовую платформу на AWS,...
В моем приложении при отправке сообщений я использую метаданные в обратном вызове, чтобы сохранить...
Я использую spring-kafka 2.1.10. ВЫПУСК.У меня есть потребитель со следующими свойствами...
Я использую сценарий горизонтального автоматического масштабирования (HPA.yaml) для модулей Kafka...
У меня проблема с Kerberos (в данном случае я пытаюсь использовать ее с kafka). Во-первых, мой kdc
Я перехожу на kafka в качестве брокера и debezium, чтобы получать данные (данные ETL) из всех...
Я запускаю команду: "JAVA_HOME=./jdk ./origin/bin/kafka-run-class.sh kafka.tools.MirrorMaker...
Я пытаюсь десериализовать различные полезные нагрузки JSON из одной и той же темы Kafka.Другие...
Я запустил zookeeper и Kafka с помощью следующих команд: bin/zookeeper-server-start.sh...
Существует ли более новый или рекомендуемый способ написания MirrorMakerMessageHandler, поскольку...
Я новичок в написании кода на Scala.Я пытаюсь перебрать Java-карту с пользовательскими объектами в...
Я пытаюсь записать данные из темы (данные json) в базу данных MySql.Я полагаю, что мне нужен JDBC...
Если kafka enable.auto.commit=true, значит ли это, что каждые 5 секунд он будет запускать...
Я написал код приложения, в котором есть продюсер и потребительская часть одного и того же процесса
Мы работаем с брокерами Kafka в контейнерах с сервисом ECS AWS. Кластер состоит из 3 брокеров. Мы...
Я пытаюсь настроить систему, которая будет читать две разные темы Кафки - одну для живых сообщений...
1) У нас есть 3 узла kafka & kafka connect cluster 2) Мы запускаем kafka-connect на узлах kafka...
Я использую клиент kafka-node для публикации и подписки на kafka. Я хочу получить конкретное...
В наших рабочих распределенных реквизитах мы имеем: value.converter=io.confluent.connect.avro
Я подписался на тему Кафки, как показано ниже. Мне нужно запустить некоторую логику только после...
Я пишу код, в котором я пытаюсь создавать сообщения, используя kafka и SBT.Он компилируется, но при...
У нас есть тема Kafka с 25 разделами со следующими настройками темы: delete.retention.ms=5000...
Исходя из фона ActiveMQ.ActiveMQ использует конфигурационный файл Spring xml для запуска посредника...
При использовании @KafkaListener можно ли получить ссылку на базовый KafkaConsumer, поскольку я...
У нас есть требование выполнять массовую запись вasticsearch. Мы хотели бы знать, существует ли...