схема: 2 брокера -2 хозяина Клиенты Java - свойство серверов Bootsrap org.apache.kafka.clients
Я вставляю запись производителю Kafka и затем вызываю потребителя, который возвращает вставленный...
У меня есть кластер Kafka, работающий на Kubernetes вместе с ZooKeeper на Kubernetes . Как указано...
Следующее исключение выдается для Elastic Search Connector: [2018-05-07 11:40:38,975] ERROR...
Я пытаюсь реализовать http-сервер, который: Рассчитать дальнейшее перенаправление, используя...
Я использую vertx-kafka-client 3.5.1 и не могу найти способ создать KafkaProducerRecord с...
В плане разделения трафика внутри сервера кафки, Какие есть варианты? 1) Split the traffic into...
В каком файле я могу увеличить максимальный размер сообщения для Кафки? (Я отправляю записи String,...
Проект Prometheus jmx_exporter предоставляет официальный пример конфигурации для Kafka здесь:...
У меня Кафка-докер, работающий на Vagrant Ubuntu VM. Я могу создавать и потреблять сообщения,...
Я хочу создать сообщение в тему кафки. Это сообщение должно иметь следующий шаблон:...
Я не могу запустить службу Apache Kafka из-за сбоя при попытке запустить экземпляр Zookeeper. Я...
Код производителя, который будет читать видеофайл .mp4 с диска и отправлять его на kafka, который,...
Я использую Кафку в Docker-контейнере. Одним из требований является то, что kafka будет доступен...
Я настроил kafka в Docker-контейнере, используя этот проект https://github
Я новая пчела в ksql. Я просто играю с темами kafka для чтения в потоки, и это прекрасно работает....
Я разрабатываю приложение на основе kafka, в котором слушатель kafka будет прослушивать запись; как...
Я работаю с кафкой и апачем флинк. Я пытаюсь использовать записи (которые в формате avro) из темы...
В Кафке я могу разбить свою тему на множество разделов. У меня не может быть больше потребителей,...
Мне удалось скомпилировать статическую версию librdkafa для MacOS достаточно просто: ./configure...
Я создал простейшую конфигурацию коннектора раковины kafka, и я использую confluent 4.1.0: {...
Я использую spring-kafka и spring-kafka-test 2.1.5.RELEASE, и я запускаю пример модульного теста в...
У меня есть приложение, которое использует идемпотентного производителя для записи уникально...
Я настроил своего продюсера kafka заново, следуя инструкции, упомянутой здесь: https://www
После реализации сжатия gzip будут ли сжаты ранее сохраненные сообщения? И при отправке сообщений...