kafka-producer-perf-test.sh выдает ошибку и не дает никаких результатов.В чем причина. Я пытаюсь...
Я реализую потоковый конвейер, который похож на рисунок ниже: *K-topic1* ---> processor1 --->...
При использовании Integer в качестве ключа это не проблема, kafka должен иметь возможность...
Я бы хотел обновить кластеры Kafka моей команды с версии 0.10.1.1 до версии 2.1.0. Кстати, в...
Я пытаюсь подключить MySql к Kafka, используя Debezium. Это REST API, я пытаюсь выполнить. curl -i...
Я не смог найти какие-либо подробности о связи между Узлами и Zookeeper. предполагать в узлах Kafka...
В кластере Кафка, если количество повторных попыток увеличивается, что может быть причиной? Какие...
Предыдущее примечание: я довольно новичок в Kafka. Я пытаюсь получить все схемы из реестра схем, но...
Я немного озадачен ожидаемым поведением poll ().В моем приложении, если processLogic () работает, я...
Я хочу получить данные из сокета и поместить их в тему kafka, чтобы моя программа flink могла...
В случае ошибки интерфейс ConsumerAwareErrorHandler предоставляет ссылку на метод ConsumerRecord и...
Я ищу структуру данных, которая работает аналогично теме Apache Kafka с одним разделом: Отправитель...
при запуске кафки-потребителя зоокейпер отобразит это: [2019-01-02 16:34:15,893] INFO Accepted...
У нас есть метод execute (), в котором мы используем FlinkKafkaConsumer08 в качестве источника...
Событие delivery-report вызывается каждый раз для каждого созданного сообщения и продолжает давать...
Среда: HDP 2.6.4 Амбари - 2.6.1 3 сервера zookeeper 23.1.35.185 - это IP первого сервера zookeeper...
В нашем сценарии у нас есть набор микро-сервисов, которые взаимодействуют с другими сервисами,...
У меня работает брокер Kakfa, который я отслеживаю с помощью JMX. Этот брокер является...
KAFKA TOPIC (test3) $ kafka-console-consumer --bootstrap-server broker:9092 --topic test3...
Я пытаюсь найти примеры связи Кафки с Springboot.Похоже, что нет интеграции с весенней загрузкой...
У меня есть одна тема, из которой я могу получать различные типы jsons.Однако, похоже, что я...
Когда брокер kafka отключен, производитель все еще пытается связаться с ним.provider.send ()...
Проблема: при вызове commit(), я получаю сообщение об ошибке, если выполнение сообщения занимает...
Это мой код: Properties props2 = new Properties(); props.put(CommonClientConfigs
Я получаю следующее исключение, потому что я производю из одного проекта, а потребитель потребляет...