развернул кафку битнами на aws ec2.https://bitnami.com/stack/kafka/cloud Я открыл порты 9092 для...
В группе 10 потребителей, слушающих какую-то тему.Очень часто случается так, что очень часто...
Я попытался настроить базу данных с таблицей со столбцом метки времени.Я пытаюсь реализовать режим...
Я установил Apache Kafka на сервере Ubuntu и протестировал его, выполнив первые пять шагов,...
У меня работает 3 брокера Kafka. Во всех моих темах коэффициент репликации установлен на 2. Когда я...
У меня есть монолитное приложение с jhipster и использующее kafka.Я следовал этому учебнику Но у...
У нас проблема с одним из наших кластеров kafka (Kafka версия 2.2.1).Некоторые разделы...
Я использую Confluent.Kafka string kafkaEndpoint = "127.0.0.1:9092"; string kafkaTopic =...
Я настроил аутентификацию Kafka и zookeeper с помощью SASL + ACL и Kafka для производителя и...
Использование Avro для сериализации данных в байты [] и десериализации данных. https://cwiki.apache
Я тестирую создание кластера kafka, используя зашифрованные промежуточные сертификаты.После...
Я пытаюсь запустить свой проект kafka в докере.Если я запускаю этот проект на своем локальном...
У меня есть класс, который создает производителей Kafka на основе конфигов из динамического cahce
Я пытаюсь использовать сообщения из нескольких тем, используя метод assign(). С моей реализацией,...
У меня есть функция в Java, в которой я пытаюсь получить сообщения, которые не прочитаны.Например,...
Я использую kafka connect для получения исходных данных из DB2 в теме kafka, и я настраиваю...
Есть ли примеры конфигурации для CSV Source Connector, особенно связанные с генерацией схемы?Я не...
У меня есть производитель Java Kafka, который использует org.apache.kafka.common.serialization
Я пытаюсь добавить агент prometheus jmx (jmx_prometheus_javaagent-0.3.1.jar) в существующий...
У меня есть три физических узла с установленным Docker на каждом из них. Я настроил Marathon, Flink...
Я пытаюсь смоделировать этот метод, который создает тему Кафки и ждет завершения объекта в будущем....
Отправка простой первой топологии шторма сводит меня с ума. Во-первых, я получил отказ в соединении...
Что касается Kafka-Zookeeper Security с использованием аутентификации DIGEST MD5, я пытаюсь...
Я публикую сообщения внешней команде, которая принимает сообщения для Кафки и возвращает нам ответ
Я настраиваю кластер Kafka, в котором я устанавливаю broker.id=-1, чтобы автоматически...