AskOverflow.Dev

AskOverflow.Dev Logo AskOverflow.Dev Logo

AskOverflow.Dev Navigation

  • Início
  • system&network
  • Ubuntu
  • Unix
  • DBA
  • Computer
  • Coding
  • LangChain

Mobile menu

Close
  • Início
  • system&network
    • Recentes
    • Highest score
    • tags
  • Ubuntu
    • Recentes
    • Highest score
    • tags
  • Unix
    • Recentes
    • tags
  • DBA
    • Recentes
    • tags
  • Computer
    • Recentes
    • tags
  • Coding
    • Recentes
    • tags
Início / coding / Perguntas / 77120245
Accepted
banan3'14
banan3'14
Asked: 2023-09-17 10:08:49 +0800 CST2023-09-17 10:08:49 +0800 CST 2023-09-17 10:08:49 +0800 CST

A conexão com o nó -1 (localhost/127.0.0.1:9092) não pôde ser estabelecida no Spring Kafka

  • 772

Adicionei Spring Kafka ao meu aplicativo Spring e esperava que funcionasse, mas consegui

INFO     [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka version: 3.4.1
INFO --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId: 8a516edc2755df89
INFO --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka startTimeMs: 1694915576434
INFO --- [| adminclient-1] org.apache.kafka.clients.NetworkClient   : [AdminClient clientId=adminclient-1] Node -1 disconnected.
WARN --- [| adminclient-1] org.apache.kafka.clients.NetworkClient   : [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established.

Eu adicionei ao meupom.xml

<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
    <version>3.0.9</version>
</dependency>

e configurei-o

@Bean
public KafkaAdmin kafkaAdmin() {
    Map<String, Object> configs = new HashMap<>();
    configs.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapAddress);
    return new KafkaAdmin(configs);
}

@Bean
public NewTopic checkInTopic() {
    return new NewTopic(checkInTopicName, 1, (short) 1);
}

onde bootstrapAddressé configurado via application.yml:

spring:  
  kafka:
    bootstrap-servers: localhost:9092

e também tenho uma configuração de produtor:

@Bean
public KafkaTemplate<String, String> kafkaTemplate() {
    return new KafkaTemplate<>(producerFactory());
}

@Bean
public ProducerFactory<String, String> producerFactory() {
    return new DefaultKafkaProducerFactory<>(Map.of(
            ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapAddress,
            ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class,
            ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class
    ));
}

O que está errado? Devo executar o Kafka manualmente na porta localhost 9092? Presumo que isso seja feito automaticamente pelo framework Spring, assim como não preciso implantá-lo no Tomcat porque ele está empacotado. Isso inicia o serviço Kafka ou devo fazer isso sozinho?

apache-kafka
  • 1 1 respostas
  • 36 Views

1 respostas

  • Voted
  1. Best Answer
    Anish B.
    2023-09-17T12:20:13+08:002023-09-17T12:20:13+08:00

    Sim, você deve executar o Kafka manualmente na porta localhost 9092.

    Os módulos Spring Kafka não são empacotados com binários Kafka. Ele contém apenas as APIs Kafka necessárias para realizar operações em tópicos, produtores e consumidores do Kafka.

    Por outro lado, você precisará baixar e configurar o Apache Kafka em seu sistema.

    Existem 2 opções para executar um serviço Kafka: com o Zookeeper legado e o KRaft mais recente.

    O modo KRaft é mais escalonável que o modo ZooKeeper, permitindo que os clusters Kafka lidem com mais tráfego e dados. O modo KRaft é mais rápido que o modo ZooKeeper, resultando em menor latência e maior rendimento.

    Os passos iniciais são os mesmos.

    1. Baixe a versão mais recente do Kafka aqui .
    2. Navegue até bin/o diretório kafka.

    Kraft

    Etapas continuadas:

    1. Construa o projeto usando./gradlew jar -PscalaVersion=2.13.10
    2. Gerar um UUID de cluster KAFKA_CLUSTER_ID="$(./kafka-storage.sh random-uuid)"
    3. Formatar diretórios de log ./kafka-storage.sh format -t $KAFKA_CLUSTER_ID -c ../config/kraft/server.properties
    4. Modifique log.dirspara apontar para algum outro diretório válido em vez de /tmp/kraft-combined-logs.
    5. Inicie o corretor Kafka. ./kafka-server-start.sh ../config/kraft/server.properties

    Para Windows, há uma pasta windowscom scripts em lote correspondentes aos scripts de shell do Linux/Mac.

    Funcionário do zoológico

    Etapas continuadas:

    1. Inicie o Zookeeper .

      • Linux/Mac:./zookeeper-server-start.sh ../config/zookeeper.properties
      • Janelas:windows\zookeeper-server-start.bat ..\..\config\zookeeper.properties
    2. Edite o server.properties

      • Remova o comentário desta linha de código: listeners=PLAINTEXT://localhost:9092para permitir que o corretor seja escutado neste soquete.
      • Modifique log.dirspara apontar para algum outro diretório válido em vez de /tmp/kafka-logs.
    3. Inicie o corretor Kafka.

      • Linux/Mac:./kafka-server-start.sh ../config/server.properties
      • Janelas:windows\kafka-server-start.bat ..\..\config\server.properties

    Isso é tudo para a configuração inicial.


    Visite aqui para ler mais informações sobre criação de tópicos e outras coisas relacionadas ao Kafka.

    Agora, o aplicativo Spring poderá se conectar ao Kafka.

    • 2

relate perguntas

  • orientação de arquitetura para múltiplas mensagens em uma matriz

  • Kafka em microsserviços para fornecer transações

Sidebar

Stats

  • Perguntas 205573
  • respostas 270741
  • best respostas 135370
  • utilizador 68524
  • Highest score
  • respostas
  • Marko Smith

    destaque o código em HTML usando <font color="#xxx">

    • 2 respostas
  • Marko Smith

    Por que a resolução de sobrecarga prefere std::nullptr_t a uma classe ao passar {}?

    • 1 respostas
  • Marko Smith

    Você pode usar uma lista de inicialização com chaves como argumento de modelo (padrão)?

    • 2 respostas
  • Marko Smith

    Por que as compreensões de lista criam uma função internamente?

    • 1 respostas
  • Marko Smith

    Estou tentando fazer o jogo pacman usando apenas o módulo Turtle Random e Math

    • 1 respostas
  • Marko Smith

    java.lang.NoSuchMethodError: 'void org.openqa.selenium.remote.http.ClientConfig.<init>(java.net.URI, java.time.Duration, java.time.Duratio

    • 3 respostas
  • Marko Smith

    Por que 'char -> int' é promoção, mas 'char -> short' é conversão (mas não promoção)?

    • 4 respostas
  • Marko Smith

    Por que o construtor de uma variável global não é chamado em uma biblioteca?

    • 1 respostas
  • Marko Smith

    Comportamento inconsistente de std::common_reference_with em tuplas. Qual é correto?

    • 1 respostas
  • Marko Smith

    Somente operações bit a bit para std::byte em C++ 17?

    • 1 respostas
  • Martin Hope
    fbrereto Por que a resolução de sobrecarga prefere std::nullptr_t a uma classe ao passar {}? 2023-12-21 00:31:04 +0800 CST
  • Martin Hope
    比尔盖子 Você pode usar uma lista de inicialização com chaves como argumento de modelo (padrão)? 2023-12-17 10:02:06 +0800 CST
  • Martin Hope
    Amir reza Riahi Por que as compreensões de lista criam uma função internamente? 2023-11-16 20:53:19 +0800 CST
  • Martin Hope
    Michael A formato fmt %H:%M:%S sem decimais 2023-11-11 01:13:05 +0800 CST
  • Martin Hope
    God I Hate Python std::views::filter do C++20 não filtrando a visualização corretamente 2023-08-27 18:40:35 +0800 CST
  • Martin Hope
    LiDa Cute Por que 'char -> int' é promoção, mas 'char -> short' é conversão (mas não promoção)? 2023-08-24 20:46:59 +0800 CST
  • Martin Hope
    jabaa Por que o construtor de uma variável global não é chamado em uma biblioteca? 2023-08-18 07:15:20 +0800 CST
  • Martin Hope
    Panagiotis Syskakis Comportamento inconsistente de std::common_reference_with em tuplas. Qual é correto? 2023-08-17 21:24:06 +0800 CST
  • Martin Hope
    Alex Guteniev Por que os compiladores perdem a vetorização aqui? 2023-08-17 18:58:07 +0800 CST
  • Martin Hope
    wimalopaan Somente operações bit a bit para std::byte em C++ 17? 2023-08-17 17:13:58 +0800 CST

Hot tag

python javascript c++ c# java typescript sql reactjs html

Explore

  • Início
  • Perguntas
    • Recentes
    • Highest score
  • tag
  • help

Footer

AskOverflow.Dev

About Us

  • About Us
  • Contact Us

Legal Stuff

  • Privacy Policy

Language

  • Pt
  • Server
  • Unix

© 2023 AskOverflow.DEV All Rights Reserve