Spring управляемый KafkaTemplate предоставляет template.send(record).addCallback(... template
Я пытаюсь отправить поток вывода из Apache Spark 2.3.1 в Apache Kafka с использованием приемника...
У меня есть сценарий, в котором мне нужно переместить записи из улья в кафку.Я не мог найти способ,...
Я вижу ниже WARN в моем производителе Kafka. WARN [kafka-producer-network-thread | producer-4] o.a
Я создаю потоковое задание, которое читает две темы кафки и пишет в одной теме кафки.Я работаю с...
Я хочу использовать SSL-шифрование и аутентификацию, но у нас много клиентов, и мы не хотим...
Я запустил док-контейнер от Wurstmeister Kafka с командой: docker run -ti --name sender...
Я использую процессор KafkaPublish для публикации сообщений в теме kafka, защищенной с...
Я пытался реализовать механизм очередей, используя kafka, где я хочу убедиться, что дублирующиеся...
У меня проблема с отправкой сериализованного XML в мою тему Kafka. Всякий раз, когда я запускаю...
Я использую весеннее загрузочное приложение с интеграцией kafka и хочу реализовать конечную точку,...
У меня есть код, который будет отправлять данные в тему Кафки. public void sendMessage(String...
Я хочу поместить текст, состоящий из нескольких строк, как одно сообщение, в тему кафки. После того...
Я пытаюсь определить URL для SalesForce, так как он связан с настройкой провайдера Kafka. Я...
Мы используем pykafka 2.3.1 и время от времени наблюдаем, как продюсер зависает. Сообщение об...
Я создал проект Java для передачи данных на сервер Kafka. и этот проект Java Maven не содержит...
Мы используем Кафку 1.11 наша системная задача состоит в том, чтобы удерживать низкую задержку на...
У меня есть кластер Kafka, работающий на локальной машине с настройками по умолчанию вне моей...
Я прочитал много тем о конфигурации и до сих пор не понимаю. когда я делаю: ../kafka_2.11-1.1
У меня есть следующая конфигурация: Одна тема кафки с 2 разделами Один экземпляр Zookeeper Один...
Я строю проект, в котором для Project Target Frame используется .NET Framework 4.0, я не могу...
Я новичок в очередях сообщений в целом, и в данный момент я работаю с apache Kafka. У меня есть...
Какое свойство производителя Kafka использовать для достижения следующих целей? Я использую UDP...
Есть ли способ создать сообщение в kafka-console-produser с нулевым значением (т. Е. Пометить его,...
У нас есть сценарий, когда несколько производителей выходят в сеть в одно и то же время.Этим...