При запуске топологии с Kafka Spout с новой версией Kafka 2.1.0 и Storm версии 1.2.2, получая...
Следуя Руководству по быстрому запуску Apache Kafka , я проделал следующие шаги: Загрузка и...
У нас есть кластер kafka с 3 узлами брокеров kafka и 3 серверами zookeepers версия kafka - 10.1...
У меня есть следующие свойства производителя kafka. value.serializer=MyEventSerializer value
Я пытался создать несколько сообщений в своей теме test_partitions_41, но я получил эту ошибку:...
версии druid .10.1 из HDP-2.6.5.0 Мы используем загрузку службы индексатора druid-kafka для...
Это, вероятно, eisenbug, поэтому я не жду жестких ответов, но больше подсказок о том, что искать,...
У меня есть поле SQL DATETIME DT, которое я хочу передать в Kafka с помощью Avro.DT по местному...
Я пытаюсь индексировать сообщения в Elasticsearch, используя SMT только из Kafka Connect API. До...
У меня есть сценарий потребителя, который обрабатывает каждое сообщение и фиксирует смещения...
Прямо сейчас я настроил свой сервер Kafka с самозаверяющим сертификатом. version: '2'...
У меня есть 3 брокера kafka кластера с 3 zookeeper. У меня вопрос, нужно ли нам давать только один...
tl; dr; Я пытаюсь понять, как один потребитель, которому назначено несколько разделов, обрабатывает...
У меня есть данные темы kafka со следующей структурой: { property1:value1, property2:value2,...
Я создаю новый сервис, который станет потребителем темы Kafka.Это приложение Spring, поэтому я...
Я использую rdkafka_simple_producer.c для создания сообщений в кластер Kafka.У меня одна тема и 30...
В чем разница между log.cleaner.dedupe.buffer.size и log.cleaner.io.buffer.size?Какие факторы...
Я использую Kafka Java API v2.1.Я хочу знать, какие исключения будут распространяться на код...
создал поток, используя схему-реестр, без указания имени поля. См. Ниже CREATE STREAM sample_avro...
У меня странное поведение при сжатии журналов в kafka.Я создал тему со следующей конфигурацией:...
У меня есть приложение, которое использует Apache Flink Streaming Framework, а также работает с...
Мне нужно ваше руководство для разработки моей системы очереди сообщений. наша архитектура...
В прошлом я работал над настройкой аутентификации для клиентов Kafka.Я уже упоминал: https://kafka
Я запихнул json (20 пар ключ-значение) в kafka и смог его тоже использовать - проверил, чтобы...
есть ли какой-нибудь коннектор kafka, который читает из csv и конвертирует в Avro, прежде чем...