Форум программистов, компьютерный форум, киберфорум
Java EE (J2EE)
Войти
Регистрация
Восстановить пароль
 
Рейтинг 4.67/3: Рейтинг темы: голосов - 3, средняя оценка - 4.67
2 / 2 / 1
Регистрация: 17.05.2009
Сообщений: 98
1

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

25.03.2020, 12:52. Показов 510. Ответов 3
Метки нет (Все метки)

Пишу Kafka Broker и Consumer, чтобы ловить сообщения от приложения. При попытке достать сообщения из Consumer вылетает ошибка
Код
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) также наблюдается ошибка подключения
Код
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.
В моем проекте указаны следующие зависимости:
Код
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
Эксперт
94731 / 64177 / 26122
Регистрация: 12.04.2006
Сообщений: 116,782
25.03.2020, 12:52
Ответы с готовыми решениями:

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

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

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

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

3
Эксперт Java
3049 / 2544 / 782
Регистрация: 05.07.2013
Сообщений: 12,304
25.03.2020, 13:23 2
запущена кафка то?
0
2 / 2 / 1
Регистрация: 17.05.2009
Сообщений: 98
25.03.2020, 13:41  [ТС] 3
Цитата Сообщение от xoraxax Посмотреть сообщение
запущена кафка то?
а Spring не поднимает все, что нужно при создании EmbeddedKafkaBroker? или что-то еще нужно? есть только этот класс
0
Эксперт Java
3049 / 2544 / 782
Регистрация: 05.07.2013
Сообщений: 12,304
25.03.2020, 13:46 4
ну видимо надо, логи попробуй почитать, должно быть видно, что кафка поднялась
вообще надо читать, я ни разу с этим не работал. Вот тут например
https://github.com/spring-proj... sting.adoc
0
IT_Exp
Эксперт
87844 / 49110 / 22898
Регистрация: 17.06.2006
Сообщений: 92,604
25.03.2020, 13:46

Заказываю контрольные, курсовые, дипломные работы и диссертации здесь.

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

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

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

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


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

Или воспользуйтесь поиском по форуму:
4
Ответ Создать тему
Опции темы

КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin® Version 3.8.9
Copyright ©2000 - 2021, vBulletin Solutions, Inc.