Откуда приходит второй слушатель Кафки? ⇐ JAVA

[Anonymous]

Я пытаюсь настроить проект, используя Spring Boot, Spring Kafka & TestContainers. Моя настройка TestContainer выглядит ниже: < /p>

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

  private static final Network NETWORK = Network.newNetwork();

@Bean
@ServiceConnection
public ConfluentKafkaContainer kafkaContainer() {
return new ConfluentKafkaContainer(
DockerImageName.parse("confluentinc/cp-kafka:7.9.0")
.asCompatibleSubstituteFor("apache/kafka"))
.withNetwork(NETWORK)
.withNetworkAliases("kafka")
.withEnv("KAFKA_KRAFT_MODE", "true")
.withEnv("KAFKA_PROCESS_ROLES", "broker,controller")
.withEnv("KAFKA_CONTROLLER_QUORUM_VOTERS", "1@kafka:9093")
.withEnv("KAFKA_NODE_ID", "1")
.withEnv("KAFKA_LISTENERS", "BROKER://0.0.0.0:9092,CONTROLLER://0.0.0.0:9093")
.withEnv("KAFKA_ADVERTISED_LISTENERS", "BROKER://kafka:9092")
.withEnv("KAFKA_LISTENER_SECURITY_PROTOCOL_MAP", "BROKER:PLAINTEXT,CONTROLLER")
.withEnv("KAFKA_INTER_BROKER_LISTENER_NAME", "BROKER")
.withEnv("KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR", "1")
.withEnv("KAFKA_TRANSACTION_STATE_LOG_MIN_ISR", "1")
.withEnv("KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR", "1")
.withEnv("KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS", "0")
.withEnv("KAFKA_CONTROLLER_LISTENER_NAMES", "CONTROLLER")
.withEnv("KAFKA_AUTO_CREATE_TOPICS_ENABLE", "true")
.withLogConsumer(new Slf4jLogConsumer(LoggerFactory.getLogger("KafkaContainer")));
}
< /code>
Но когда я пытаюсь запустить тест, я получаю сообщение в соответствии с: < /p>
STDOUT: Exception in thread "main" java.lang.IllegalArgumentException: Error creating broker listeners from 'PLAINTEXT://localhost:59694,BROKER://c958fa04fe68:9093': No security protocol defined for listener BROKER at kafka.utils.CoreUtils$.listenerListToEndPoints(CoreUtils.scala:216)...
< /code>
Но я понятия не имею, откуда прослушитель открытого текста. Я могу обновить описание с помощью более подробной информации (например, зависимости и т. Д.), Если мне нужно. Выполнение поиска в моем проекте для PloundText 

, и я получаю только строку выше, устанавливая безопасность.

Подробнее здесь: https://stackoverflow.com/questions/795 ... oming-from