Форум программистов, компьютерный форум, киберфорум
Java: Spring, Spring Boot
Форум программистов и сисадминов Киберфорум > Форум программистов > Java > Java: Spring, Spring Boot
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
Рейтинг 4.54/13: Рейтинг темы: голосов - 13, средняя оценка - 4.54
 Аватар для templllar
2 / 2 / 1
Регистрация: 17.05.2009
Сообщений: 99

Spring Kafka. Ошибка Connection refused при подключении к брокеру Kafka

25.03.2020, 12:52. Показов 3124. Ответов 3
Метки нет (Все метки)
Студворк — интернет-сервис помощи студентам
Пишу Kafka Broker и Consumer, чтобы ловить сообщения от приложения. При попытке достать сообщения из Consumer вылетает ошибка
Code
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

java.net.ConnectException: Connection refused: no further information
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
    at org.apache.kafka.common.network.PlaintextTransportLayer.finishConnect(PlaintextTransportLayer.java:50)
    at org.apache.kafka.common.network.KafkaChannel.finishConnect(KafkaChannel.java:216)
    at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:531)
    at org.apache.kafka.common.network.Selector.poll(Selector.java:483)
    at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:540)
    at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:262)
    at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:233)
    at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:212)
    at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:230)
    at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:444)
    at org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1267)
    at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1231)
    at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1211)
    at org.springframework.kafka.test.utils.KafkaTestUtils.getRecords(KafkaTestUtils.java:303)
    at org.springframework.kafka.test.utils.KafkaTestUtils.getRecords(KafkaTestUtils.java:280)
Со стороны приложения (Producer) также наблюдается ошибка подключения
Code
1

2020-03-25 12:29:33.689  WARN 25786 --- [ad | producer-1] org.apache.kafka.clients.NetworkClient   : [Producer clientId=producer-1, transactionalId=tx0] Connection to node -1 (<[COLOR="DarkGreen"]Здесь указан hostname брокера[/COLOR]>:9092) could not be established. Broker may not be available.
В моем проекте указаны следующие зависимости:
Code
1
2

compile "org.springframework.kafka:spring-kafka-test:2.4.4.RELEASE"
compile "org.springframework.kafka:spring-kafka:2.4.4.RELEASE"
код класса:
Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

public class KafkaServer {
 
    private static final String BROKERPORT = "9092";
    private static final String BROKERHOST = "localhost";
    public static final String TOPIC1 = "fss-fsstransdata";
    public static final String TOPIC2 = "fss-fsstransscores";
    public static final String TOPIC3 = "fss-fsstranstimings";
    public static final String TOPIC4 = "fss-fssdevicedata";
    @Getter
    private Consumer<String, String> consumer;
 
    private EmbeddedKafkaBroker embeddedKafkaBroker;
 
    public void run() {
 
        String[] topics = {TOPIC1, TOPIC2, TOPIC3, TOPIC4};
 
        this.embeddedKafkaBroker = new EmbeddedKafkaBroker(
                1,
                false,
                1,
                topics
        ).kafkaPorts(BROKERPORT);
 
        Map<String, Object> configs = new HashMap<>(KafkaTestUtils.consumerProps("consumer", "false", this.embeddedKafkaBroker));
        this.consumer = new DefaultKafkaConsumerFactory<>(configs, new StringDeserializer(), new StringDeserializer()).createConsumer();
 
        this.consumer.subscribe(Arrays.asList(topics));
    }
 
  
}
Просьба помочь разобраться с ситуацией.
0
Programming
Эксперт
39485 / 9562 / 3019
Регистрация: 12.04.2006
Сообщений: 41,671
Блог
 25.03.2020, 12:52
Ответы с готовыми решениями:

Spring Kafka: Запись в базу данных и чтение из неё
Гайз, нужен хэлп. Киньте инфу или подскажите как записывать данные из Kafka в базу данных, а потом читать из базы и писать в топики...

При использовании WinSock2 ошибка 10061 (connection refused)
Решил поизучать WinSock. Возможно, этот вопрос глупый, но очевидно, что ошибка в сетевом адресе. Код сервера, принимающего запросы: ...

Написание Kafka Server Mock
Приложение передает некоторые сообщения по TCP в Kafka Server. Нужно реализовать заглушку Kafka Server, которая будет ловить эти сообщения...

3
Эксперт Java
3639 / 2971 / 918
Регистрация: 05.07.2013
Сообщений: 14,220
25.03.2020, 13:23
запущена кафка то?
0
 Аватар для templllar
2 / 2 / 1
Регистрация: 17.05.2009
Сообщений: 99
25.03.2020, 13:41  [ТС]
Цитата Сообщение от xoraxax Посмотреть сообщение
запущена кафка то?
а Spring не поднимает все, что нужно при создании EmbeddedKafkaBroker? или что-то еще нужно? есть только этот класс
0
Эксперт Java
3639 / 2971 / 918
Регистрация: 05.07.2013
Сообщений: 14,220
25.03.2020, 13:46
ну видимо надо, логи попробуй почитать, должно быть видно, что кафка поднялась
вообще надо читать, я ни разу с этим не работал. Вот тут например
https://github.com/spring-proj... sting.adoc
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
inter-admin
Эксперт
29715 / 6470 / 2152
Регистрация: 06.03.2009
Сообщений: 28,500
Блог
 25.03.2020, 13:46
Помогаю со студенческими работами здесь

Ошибка подключения к почте imap.ukr.net (Connection refused)
Пытаюсь начать работу с почтой freemail.ukr.net: &lt;?php ini_set('display_errors', 'On'); // сообщения с ошибками будут показываться ...

При запуске проекта ASP .NET вылетает connection refused
Добрый день! Создаю в Visual Studio 2013 тестовый проект ASP.NET (пустой), пытаюсь запустить его в браузере, получаю показанную ниже...

Spring Multi Part загрузка файла и ошибка при подключении bean id multipartResolver
Пытаюсь реализовать upload файла-картинки на сервер на базе MultiPart механизма Spring В контроллере POST примерно так ...

Почему при подключении к FireBird возникает ошибка GDS Exception. 335544421. connection rejected by remote int
Здравствуйте. Сегодня решил открыть для себя СУБД FireBird. Установил сервер Firebird 3.0.1 под Widnows Создал файл с БД ...

При get запросе выдает "socket erorr 10061 - connection refused"
Проблема в заголовке. С чем это может быть связано, как лечить?


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
4
Ответ Создать тему
Новые блоги и статьи
Access
VikBal 11.12.2025
Помогите пожалуйста !! Как объединить 2 одинаковые БД Access с разными данными.
Новый ноутбук
volvo 07.12.2025
Всем привет. По скидке в "черную пятницу" взял себе новый ноутбук Lenovo ThinkBook 16 G7 на Амазоне: Ryzen 5 7533HS 64 Gb DDR5 1Tb NVMe 16" Full HD Display Win11 Pro
 Музыка, написанная Искусственным Интеллектом
volvo 04.12.2025
Всем привет. Некоторое время назад меня заинтересовало, что уже умеет ИИ в плане написания музыки для песен, и, собственно, исполнения этих самых песен. Стихов у нас много, уже вышли 4 книги, еще 3. . .
От async/await к виртуальным потокам в Python
IndentationError 23.11.2025
Армин Ронахер поставил под сомнение async/ await. Создатель Flask заявляет: цветные функции - провал, виртуальные потоки - решение. Не threading-динозавры, а новое поколение лёгких потоков. Откат?. . .
Поиск "дружественных имён" СОМ портов
Argus19 22.11.2025
Поиск "дружественных имён" СОМ портов На странице: https:/ / norseev. ru/ 2018/ 01/ 04/ comportlist_windows/ нашёл схожую тему. Там приведён код на С++, который показывает только имена СОМ портов, типа,. . .
Сколько Государство потратило денег на меня, обеспечивая инсулином.
Programma_Boinc 20.11.2025
Сколько Государство потратило денег на меня, обеспечивая инсулином. Вот решила сделать интересный приблизительный подсчет, сколько государство потратило на меня денег на покупку инсулинов. . . .
Ломающие изменения в C#.NStar Alpha
Etyuhibosecyu 20.11.2025
Уже можно не только тестировать, но и пользоваться C#. NStar - писать оконные приложения, содержащие надписи, кнопки, текстовые поля и даже изображения, например, моя игра "Три в ряд" написана на этом. . .
Мысли в слух
kumehtar 18.11.2025
Кстати, совсем недавно имел разговор на тему медитаций с людьми. И обнаружил, что они вообще не понимают что такое медитация и зачем она нужна. Самые базовые вещи. Для них это - когда просто люди. . .
Создание Single Page Application на фреймах
krapotkin 16.11.2025
Статья исключительно для начинающих. Подходы оригинальностью не блещут. В век Веб все очень привыкли к дизайну Single-Page-Application . Быстренько разберем подход "на фреймах". Мы делаем одну. . .
Фото: Daniel Greenwood
kumehtar 13.11.2025
КиберФорум - форум программистов, компьютерный форум, программирование
Поддержать - Реклама - Условия использования - Обратная связь
Powered by vBulletin
Copyright ©2000 - 2025, CyberForum.ru