Spring Boot Kafka AdminClient не подключается к порту REST Kafka, работает с портом открытого текста ⇐ JAVA

[Anonymous]

Я работаю над проектом Spring Boot с Kafka. AdminClient не может подключиться при использовании порта REST Kafka, но он работает нормально, когда я использую текстовый порт 40305.
Вот моя настройка:

Код: Выделить всё

@RestController
@RequiredArgsConstructor
public class PageEventRestController {

private final StreamBridge streamBridge;

@GetMapping("publish/{topic}/{name}")
public PageEvent publish(@PathVariable String topic, @PathVariable String name) {
PageEvent pageEvent = new PageEvent(name, Math.random() < 0.5 ? "user1" : "user2", new Date(), new Random().nextInt(9000));
streamBridge.send(topic, pageEvent);
return pageEvent;
}
}

application.properties:

Код: Выделить всё

spring.application.name=spring-cloud-streams-kafka
server.port=8080
spring.kafka.bootstrap-servers=localhost:8082
spring.cloud.function.definition=PageEventConsumer

Журнал ошибок:

Код: Выделить всё

2024-10-07T16:37:55.440+01:00  INFO 18108 --- [spring-cloud-streams-kafka] [|
adminclient-1] org.apache.kafka.clients.NetworkClient   : [AdminClient
clientId=adminclient-1] Node -1 disconnected.

pom.xml:

Код: Выделить всё

 

org.springframework.boot
spring-boot-starter-web


org.apache.kafka
kafka-streams


org.springframework.cloud
spring-cloud-stream


org.springframework.cloud
spring-cloud-stream-binder-kafka


org.springframework.cloud
spring-cloud-stream-binder-kafka-streams


org.springframework.kafka
spring-kafka



org.projectlombok
lombok
true


org.springframework.boot
spring-boot-starter-test
test


org.springframework.cloud
spring-cloud-stream-test-binder
test


org.springframework.kafka
spring-kafka-test
test

Дополнительный контекст:

• Я запускаю Kafka с помощью Confluent CLI с помощью команды:
  Конфлюентный локальный запуск Kafka
• Confluent CLI сообщает о следующих портах:

  Код: Выделить всё

  | Kafka REST Port | 8082  |
  | Plaintext Ports | 40305 |
  

Подробнее здесь: https://stackoverflow.com/questions/790 ... -with-plai