0
Я пытаюсь изучить kafka.Зарегистрированный сервер и kafka и установлен на узле AWS Ubuntu. Сервер Zookeper работает вместе с тремя брокерами и потребителем. Я использую java-клиент (kafka-clients0.9.0 .1) в моем проекте maven (на моем ноутбуке), чтобы отправить данные брокерам и потребителю на aws.Kafka Clients jar JAVA
Нужно ли, чтобы кокер и кафка работали на моей локальной системе, чтобы подключиться к kafka на aws? У меня есть окна 10 на моей локальной системе.
При подключении к кластеру Kafka брокер показывает следующее> INFO Закрытие разъема для подключения к /xx.xx.xx.xx из-за неверного запроса: Запрос длины 1195725856 недействителен, он больше максимального размера 104857600 байт. (kafka.network.Processor)
Нет, это вовсе не нужно. Вот где клиенты приходят в картину. Единственное, что вам нужно - это доступ к серверу Kafka. – avr
Привет, у меня есть сервер zookeper (в каталоге kafka), три брокера и потребитель для темы, работающей на aws. Но мой клиентский код (локальный компьютер) не может отправлять данные потребителям. Какая может быть проблема? – user2966021
см. Разницу между Kafka Broker, Kafka Producer и Kafka Consumer здесь: 1. Kafka Broker (Сервер) является оригинальным сервером Kafka, который имеет данные 2. Kafka Producer (Клиент) является одним из клиентов Kafka, который отправляет данные Брокеру 3. Kafka Consumer (Клиент) также является одним из клиентов Kafka и который использует данные от Kafka Broker (Server). Можете ли вы проверить, есть ли у вашего продюсера доступ к Kafka? как порт открыт или нет? – avr