Я пытаюсь настроить Kafka с использованием SSL с помощью команд openssl и keytool.Я настроил...
Я пытался подключиться с kafka-avro-console-consumer от Confluent к нашему устаревшему кластеру...
Как работает этот плагин-коннектор? Kafka Connect AWS Lambda Sink В docker-compose.yml файл, в...
. Я использую библиотеку Джексона для генерации json.Джексон генерирует JSON в формате ниже....
Я знаю, что мы могли бы использовать JMX для мониторинга байтов в скорости темы kafka, используя...
РЕДАКТИРОВАТЬ: Я узнал, что я должен включить JMX в моих процессорах Consumer и Producer и получить...
У меня есть пользовательский UDF с именем getCityStats (строковый город, двойное расстояние),...
Я публикую сообщения в теме кафки (outputTopic) в формате, понятном моим подписчикам.Теперь я хочу...
У нас есть 3 брокера Kafka 0.10.1.0 развертывания в производстве.В некоторых приложениях есть...
Может ли кто-нибудь представить мне небольшой пример весенней загрузки kafka, где мы можем...
нам нужно создать компактные темы, которые должны быть уплотнены после определенного размера...
Я использую Spring впервые и пытаюсь реализовать общую очередь, в которой слушатель Kafka помещает...
Мои журналы kafka полны этих журналов: [2018-09-17 18:36:18,118] ERROR [Replica Manager on Broker...
Я новичок в Java, Spring и Kafka в целом. Вот ситуация: Я использовал аннотации @KafkaListener для...
Кафка 1.1.1-cp1.( Редактировать 4: Я закончил с сообщением об ошибке с Кафкой по этому поводу -...
Потребитель Apache MetaModel kafka не работает для смещенного хранилища зоопарков.Я использую...
как я могу интегрировать Kafka Connect с производителем Kafka в Java, чтобы я мог читать файл CSV в...
Я пытаюсь запустить kafka в UNIX, но сначала мне нужно запустить zookpeer. У меня кафка 2.12 версия...
У меня была простая демонстрация для передачи данных из одного кластера kafka, который не...
Файл свойств Kafka Connects содержит конфигурацию jks, включая пароли для доступа к хранилищу...
В hdfs для подключения Kafka у нас есть следующий класс SequenceFileWriter.java для записи...
При создании данных AVRO для Kafka, сериализатор Avro записывает тот же идентификатор схемы в...
У меня есть базовый код Spark - Kafka, я пытаюсь запустить следующий код: import org.apache.spark
У меня есть схема avro, определенная следующим образом: [ { "namespace": "com.fun
Это то, что говорится в руководстве разработчика о динамических соединителях https://docs.confluent