Я пытаюсь запустить Кафку на Windows (в лазурном облаке).Но происходит сбой, как каждые 2 дня с...
У нас есть приложение-производитель, которое работает уже несколько дней и выдает данные в тему A
Я пытаюсь найти API, который соединяет кинезис с кафкой.API, указанный на веб-сайте kafka connect ,...
Я настроил 3 kafka в кластере и пытаюсь использовать с spring-kafka. Но после того, как я убил...
Я установил Kafka " kafka_2.12-0.11.0.0 ". Запущены службы как zookeper , так и Кафка-сервер ....
Я настроил SSL и SASL безопасности и попытался создать данные для темы Kafka и работает нормально...
Я хотел бы создать одно из значений атрибута в качестве partitionID для темы kafka.Например, мой...
Я пытаюсь отправить данные в Hive через Kafka -> Flink -> Hive, используя следующий фрагмент кода:...
В KSQL можно использовать EXTRACTJSONFIELD для вложенных структур, но я не понимаю, как обращаться...
Следуя этому учебнику , я смог создать простой пример «производитель-потребитель».В моем примере...
Я использую Spring Boot 2.0.2 и Spring Kafka.Также я использую Kafka Docker image 1.1.0 из...
Я создал новую тему 'rahul' с помощью следующей команды: bin/kafka-topics.sh --create --zookeeper...
Мы недавно обновили наших брокеров и клиентов Kafka до версии 1.1.1.После обновления мы...
Я настраиваю приемник kafka connect s3, продолжительность устанавливается на 1 час, а также я...
У меня есть тема с одним разделом и двумя процессами потребителей, которые образуют группу...
Как вы, наверное, знаете, документация Сарамы такая плохая.Ничего не понятноЯ только что нашел этот...
Моя задача заключается в следующем: Я отслеживаю события синхронизации времени от стороннего...
При удалении темы, Kafka автоматически удаляет связанные ACL-привязки или мне нужно убирать вручную
System :Тип экземпляра EC2: m5.2xlargeОС: Ubuntu 14.04.5 LTSВерсия ядра: 4.4.0-1022-awsvCPU: 8...
Я только что установил Kafka (с Confluent Platform) на мой компьютер с Windows.Я основал Zookeeper...
Может кто-нибудь объяснить, как тестируется производительность в Кафке, используя...
Я использую confluent 4.1.1, я пробовал несколько агрегатных команд, но всегда возвращал NPE с...
Как это просто, возможно ли Stream Dtream в тему Kafka? У меня есть потоковое задание Spark,...
Я пытаюсь написать наивного продюсера Кафки, используя Java.Приложение принимает два ввода: Имя...
Мое приложение java-spring успешно получало сообщения от kafka0.9.0.0.но я перешел на kafka0.10.2.0...