Я хочу получить последнее сообщение темы от KafkaNet (без платформы Confluent). Сначала самое...
Я пытался реализовать механизм очередей, используя kafka, где я хочу убедиться, что дублирующиеся...
Теперь я должен использовать трубу, чтобы получить данные из кафки. чего я хочу добиться, так это...
У меня проблема с отправкой сериализованного XML в мою тему Kafka. Всякий раз, когда я запускаю...
У меня проблемы с темами кафки. У нас в среде разработки Кафка версия 2.0, и я проверил, чтобы...
Я использую kafka для сборки двух потребительских клиентов, как показано в коде ниже, но он дал мне...
В настоящее время я изучаю Kafka Connect для потоковой передачи некоторых наших баз данных в озеро...
Вариант использования: у нас есть сжатая тема, которая будет использовать UUID для отслеживания...
Я пытаюсь получить доступ к одной или нескольким темам Kafka с помощью Python Streaming API в Flink...
у нас очень странное поведение с приложением, которое использует kafka avro для потребителя и...
Я бы хотел использовать Spring Kafka с транзакциями, но я не совсем понимаю, как он должен быть...
Искробезопасное приложение передается в отдельном кластере с 2-мя рабочими. В моем приложении...
Мой проект нуждается в кафке процесса. поэтому я загрузил kafka_2.11-2.0.0 на мою локальную машину....
Как хранить всю информацию о теме kafka со всеми деталями записей в файле. a) Могу ли я получить...
У меня появляется json, как это: { "app" : "hw", "content" :...
Из документации kafka Когда производитель устанавливает acks на "all" (или "-1"), эта конфигурация...
Я возился с паузой / возобновлением работы.Одна проблема, с которой я столкнулся, возникла для...
У нас есть архитектура микроуслуг, где Кафка используется в качестве механизма связи между...
Если я использую темы кафки с одним разделом, все работает нормально. Если я использую 5 серверов...
Я использую весеннее загрузочное приложение с интеграцией kafka и хочу реализовать конечную точку,...
У меня есть код, который будет отправлять данные в тему Кафки. public void sendMessage(String...
В настоящее время мы используем несколько пользовательских подключаемых модулей для нашего...
Я установил JRE на 32-битную Windows-машину и пытаюсь запустить Zookeeper. Это показывает следующую...
Мне нужно обновить Kafka с 0.10.0 до 2.0.0 для производственной системы. Это стабильный релиз?...
Я попробовал следующую команду для установки kafkacat в моей ubuntu 14.04 операционной системе:...