Следуя инструкциям в уроке 28 курса изучения Apache Kafka для начинающих Удеми , чтобы запустить...

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

Я создал GenericData.Record из класса POJO в Java и пытаюсь сериализовать этот объект в байтовый...

Я использую @KafkaListener и ConcurrentKafkaListenerContainerFactory для прослушивания 3 тем kafka,...

Потребитель Kafka продолжает печатать сообщения об ошибках Я собрал кластер (kafka версия 2.3.0),...

WARN [Producer clientId = console-provider] Не удалось установить соединение с узлом -1 (localhost...

Чтобы применить речевую аналитику в реальном времени, используя технологии больших данных, я...

Мне интересно использовать Kubernetes для запуска Kafka, Zookeeper и других экосистем. Я хочу знать...

Я использую пользователя sarama kafka, у которого MaxProcessingTime 250 мс. Когда я отправляю...

Мы пытаемся объединить тему Kafka с включенными функциями SSL с версией Apache spark 1.6 pyspark и...

Я настроил Kafka на моей машине amazon ec2 под управлением ubuntu-18 после этого blog plost и вот...

Представьте, что вы определили, что хотите использовать ровно 8 пользовательских потоков для своего...

Я запустил MySQL Debezium Kafka Connector ( Версия: 0.9.2.Final ) с одной таблицей в "table

Я использую kafka_2.11-2.2.1. У меня ниже настройки в server.properties. message.max.bytes=20971520...

У меня есть приложение, в котором я генерирую объекты avro с использованием файла AVSC, а затем...

У меня есть тема с 7 миллионами записей (3 раздела), и я развертываю приемник Elasticsearch с 1...

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

Потребители Kafka не могут воспользоваться преимуществами оптимизации без копирования по сравнению...

Я использую Spring Boot 2.2 вместе с кластером Kafka (диаграмма bitnami helm). И получить довольно...

Я пытался построить кластер Kafka с использованием Strimzi (0.14) в кластере Kubernetes. Я...

Кафка уже запущена в производство. И, к сожалению, это более старая версия, 0.10.2. Я хочу начать...

происходит что-то странное, когда мы создаем сообщения AVRO через KSQL и пытаемся использовать их с...

Мы сталкиваемся с множеством неравномерно сбалансированных разъемов на нашей установке, начиная с...

Я работал над обновлением процессора Flink (версия Flink 1.9), который читает из Kafka, а затем...

Я пытаюсь использовать kafkajs для создания потребителя кафки. Тем не менее, я уже получаю...