首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >问答首页 >Kafka未连接到下面的问题

Kafka未连接到下面的问题
EN

Stack Overflow用户
提问于 2021-09-09 17:25:55
回答 1查看 386关注 0票数 1
代码语言:javascript
运行
复制
2021-09-09 21:42:40.039  WARN 14636 --- [ntainer#0-0-C-1] org.apache.kafka.clients.NetworkClient   : [Consumer clientId=consumer-mygroup-1, groupId=mygroup] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2021-09-09 21:42:40.039  WARN 14636 --- [ntainer#0-0-C-1] org.apache.kafka.clients.NetworkClient   : [Consumer clientId=consumer-mygroup-1, groupId=mygroup] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2021-09-09 21:42:41.778  WARN 14636 --- [ad | producer-1] org.apache.kafka.clients.NetworkClient   : [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2021-09-09 21:42:41.779  WARN 14636 --- [ad | producer-1] org.apache.kafka.clients.NetworkClient   : [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2021-09-09 21:42:43.001  WARN 14636 --- [ntainer#0-0-C-1] org.apache.kafka.clients.NetworkClient   : [Consumer clientId=consumer-mygroup-1, groupId=mygroup] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2021-09-09 21:42:43.002  WARN 14636 --- [ntainer#0-0-C-1] org.apache.kafka.clients.NetworkClient   : [Consumer clientId=consumer-mygroup-1, groupId=mygroup] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2021-09-09 21:42:44.634  WARN 14636 --- [ad | producer-1] org.apache.kafka.clients.NetworkClient   : [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2021-09-09 21:42:44.634  WARN 14636 --- [ad | producer-1] org.apache.kafka.clients.NetworkClient   : [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2021-09-09 21:42:45.908  WARN 14636 --- [ntainer#0-0-C-1] org.apache.kafka.clients.NetworkClient   : [Consumer clientId=consumer-mygroup-1, groupId=mygroup] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2021-09-09 21:42:45.908  WARN 14636 --- [ntainer#0-0-C-1] org.apache.kafka.clients.NetworkClient   : [Consumer clientId=consumer-mygroup-1, groupId=mygroup]

代码

代码语言:javascript
运行
复制
@Service
public class KafKaConsumerService {
    private final Logger logger = 
            LoggerFactory.getLogger(KafKaConsumerService.class);
 
    @KafkaListener(topics="mytopic", groupId="mygroup")
    public void consumeFromTopic(String message) {
        System.out.println("Consummed message "+message);
    }

}

    public class KafKaProducerService {
    private static final Logger logger = 
            LoggerFactory.getLogger(KafKaProducerService.class);
     
    public static final String topic = "mytopic";
      
      @Autowired 
      private KafkaTemplate<String, String> kafkaTemp;
      
      public void publishToTopic(String message) {
          System.out.println("Publishing to topic "+topic);
          this.kafkaTemp.send(topic, message);
      }
}

属性

代码语言:javascript
运行
复制
spring.kafka.consumer.bootstrap-servers=localhost:9092
spring.kafka.consumer.group-id=mygroup
spring.kafka.consumer.auto-offset-reset=earliest
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer

spring.kafka.producer.bootstrap-servers=localhost:9092
spring.kafka.producer.key-deserializer = org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.producer.value-deserializer = org.apache.kafka.common.serialization.StringDeserializer
EN

回答 1

Stack Overflow用户

发布于 2021-09-24 21:55:54

由于以下Apache-Kafka配置,您将收到此警告

代码语言:javascript
运行
复制
KAFKA_AUTO_CREATE_TOPICS_ENABLE: 'false'

这意味着在Spring Boot启动时,消费者试图侦听/消费来自mytopic的消息,但它实际上并不存在。

请先创建主题或将上述配置更改为

代码语言:javascript
运行
复制
KAFKA_AUTO_CREATE_TOPICS_ENABLE: 'true'
票数 0
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/69122433

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档