Я создал kafka topi c локально, используя терминал
> bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
Затем я попытался записать в эту топику c из intellij. Мой код принимает следующие аргументы
--group group-1 --topic test --brokers localhost:9092 --schemaRegistryUrl https://schema-registry.com
Но когда я запускаю свой код с указанными брокерами, он говорит:
java. net. ConnectException: соединение отклонено
Не удалось установить соединение с узлом -1 (localhost / 127.0.0.1: 9092). Брокер может быть недоступен.
Я не уверен, что следую правильной процедуре подключения к localhost или записи в topi c от Ide. Любые предложения или ссылки для навигации будут полезны.