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

Известно, что Kafka может предоставить семантическую семантическую доставку после 0.11.0.0.И я...

Я создал Kafka Producer, используя сараму с кодом ниже. var, производитель sarama.AsyncProducer //.

Я читаю записи в потоковом / пакетном формате из самого файла журнала nifi-пользователя для...

У меня есть настройка kafka, которая включает экспортер jmx в prometheus.Я ищу показатель, который...

Я пытаюсь настроить диспетчер каналов Kafka в Knative, используя эту документацию: https://github

У меня есть веб-приложение на основе Django, в которое я пытаюсь интегрировать Kafka с помощью этой...

У меня есть таблица, содержащая большое количество записей. Там есть столбец, определяющий тип...

Как интегрировать cassandra как производителя данных в apache Kafka? Какая-либо конкретная...

Я неоднократно удаляю и воссоздаю кластер HDInsight Kafka, и каждый раз, когда IP-адреса брокеров и...

Мы уже знаем, max.in.flight.requests.per.connection на 1 потенциально изменит порядок записей,...

Каждый раз, когда я пытаюсь подключиться к kafka для производителя / потребителя, я получаю...

Я хочу использовать Кафку для распределения высокочастотных цен финансового рынка внутри фирмы

Я использую Spring Boot 2.1.4, Kafka и React в качестве пользовательского интерфейса. У меня есть...

У меня есть KafkaProducer, я настроил сериализатор ключей и значений, как показано ниже: props

У меня есть одно приложение Spring, которое использует экземпляр Kafka без какой-либо...

У меня есть сервис, который читает тему Кафки, используя librdkafka.Я заметил, что если потребитель...

В среде разработки у человека есть Java-приложение, и он видит тысячи открытых соединений.Но они...

Я использую Scala для публикации сообщений в Kafka. У меня есть список сообщений для публикации на...

Я пытаюсь установить поток данных Horton works 3.3 с использованием ambari.Перед установкой...

У меня есть работающий и протестированный кластер Kafka, и я пытаюсь использовать скрипт Python для...

Приложение Читает из темы кафки.Каждое сообщение должно быть уникальным (дубликаты игнорируются)...

Я довольно новый в Python и начинаю с Кафки. У меня есть требование, когда мне нужно отправлять и...

Я создаю собственный десериализатор для потребителя кафки. но я получаю исключение удара -...

Я создал table в ksql из kafka topic.Выдвинул набор данных в тему и таблицы заполнены.Разместил...