Я пытаюсь отправить это сообщение в Kafka Rest: { "key_schema": "[\"null\"...

я пытаюсь достичь { "source": "NEWS", "metadata": {...

У меня есть получатель, имеющий несколько обработчиков, и когда у потребителя есть прослушиватель...

Я читал, что kafka предоставляет клиентскую библиотеку-потребитель, которая позволяет...

Я продолжаю писать свой первый потребитель Kafka, используя Spring-Kafka.Посмотрел различные...

Я пытаюсь запустить соединитель приемника JDBC со следующей конфигурацией: { "name":...

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

Я отправляю сообщение в Kafka с помощью ReplyingKafkaTemplate, и оно отправляет сообщение с...

Я пытаюсь получить сообщение от kafka на моем локальном компьютере (виртуальный рабочий стол...

Как зафиксировать транзакции Kafka и сохранить порядок транзакций? У меня есть транснациональная...

Мой потребитель Spring / Java не может получить доступ к сообщению, созданному производителем....

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

У меня есть простое приложение Spring Boot, которое читает из Kafka и пишет в Kafka. Я написал...

Я запустил службу обмена сообщениями Kafka, где брокер Kafka настроен в докере и находится на порту...

Я использую Spring Kafka с аннотацией @EmbeddedKafka для запуска экземпляра Embedded kafka....

Я использую хранилище на основе JBoss для защиты конфиденциальных данных, таких как учетные данные...

У меня есть потоки производителей, помещающие данные в тему Kafka, и один потребительский поток...

У меня есть случай использования, когда данное сообщение, которое генерируется внешним клиентом,...

Я пытаюсь удалить схему из полезной нагрузки, и вот конфигурации connector.properties...

Я пишу для потребителя Kafka и в целях обучения на этот раз я подумал об использовании реализации...

У меня есть вопрос о политиках очистки тем Кафки и их взаимодействии с log.retention .... Например,...

Я настроил кластер Kafka & Zookeeper в Производстве.Мне нужно настроить инструмент INSTANA APM Tool...

Приемник Flume HDFS настроен следующим образом: tier1.sinks.sink1.hdfs.path = /project/mgd/ tier1

Я впервые запускаю Kafka на Windows 7 и получаю сообщение об ошибке при запуске Kafka-Service Я...

Я ищу лучший способ отправки данных из Splunk в Kafka.Единственный способ, который я нашел до сих...