apache-kafka

2зной

1ответ

Я не мог найти информацию о узлах Kafka внутри кластера, обмениваться данными друг с другом. Я имею в виду, что во время репликации производитель связывается с одним из узлов. Допустим, это лидер. Теп

0зной

1ответ

Spring cloud dataflow DestinationReslutionException при запуске источника образца

У меня проблема с запуском примера источника источника spring-cloud-dataflow. Приложение выходит с кодом 0 (и оно должно работать). Я отлажена его и заметил следующее исключение бросают: DestinationRe

4зной

3ответ

Как управлять несколькими потребителями кафки на одном и том же ящике независимо друг от друга?

У меня есть два покупателя Kafka ConsumerA и ConsumerB. Я хочу, чтобы эти два покупателя кафки были независимы друг от друга на одной машине. Между ними нет никакой связи. Эти два потребителя кафки бу

0зной

1ответ

Как настроить Apache Kafka Broker на EC2?

Я установил Apache Kafka на свой экземпляр EC2, изменил группы безопасности, чтобы открыть порты 9092 и 2181 для Kafka и Zookeeper. У меня только один брокер, одна тема, один раздел ничего сложного. Я

1зной

1ответ

Какое имя хоста выбрать из группы zookeepers

Я новичок в распределенной системе, и я использую докер для настройки группы zookeeper s. К примеру, у меня есть три зоопарка с начала: services: zoo1: image: zookeeper restart: always

1зной

1ответ

Dataproc Spark Streaming Предупреждение о контрольной точке Kafka в облачном хранилище Google

У меня есть много предупреждений при использовании Dataproc 1.1 (Spark 2.0.2) с контрольной точкой Kafka в Google Cloud Storage. У меня есть следующий предупредить: 16/12/11 01:36:02 WARN HttpTranspor

1зной

1ответ

Плохая производительность log4j2 в сочетании с Kafka

У меня возникают проблемы с производительностью с использованием log4j2 (2.5) в сочетании с Kafka (0.10.1.0). Когда я включаю Kafka в файл log4j2.xml, мое приложение замедляется до обхода, в то время