Spring Kafka: UnknownHostException: 34bcfcc207e0 ⇐ JAVA

[Anonymous]

Я написал производитель/потребитель Kafka для своего приложения:
Конфигурация потребителя:

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

@EnableKafka
@Configuration
class KafkaConsumerConfig {

@Bean
fun consumerFactory(): ConsumerFactory {
val props: MutableMap = HashMap()
props[ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG] = "http://localhost:9092"
props[ConsumerConfig.GROUP_ID_CONFIG] = "group12345"
props[ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG] = StringDeserializer::class.java
props[ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG] = StringDeserializer::class.java
return DefaultKafkaConsumerFactory(props)
}

@Bean
fun kafkaListenerContainerFactory(): ConcurrentKafkaListenerContainerFactory {
val factory = ConcurrentKafkaListenerContainerFactory()
factory.consumerFactory = consumerFactory()
return factory
}
}

Конфигурация производителя:

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

@Configuration
class KafkaProducerConfig {

@Bean
fun producerFactory(): ProducerFactory {
val configProps: MutableMap = HashMap()
configProps[ProducerConfig.BOOTSTRAP_SERVERS_CONFIG] = "http://localhost:9092"
configProps[ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG] = StringSerializer::class.java
configProps[ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG] = StringSerializer::class.java
return DefaultKafkaProducerFactory(configProps)
}

@Bean
fun kafkaTemplate(): KafkaTemplate {
return KafkaTemplate(producerFactory())
}
}

Конфигурация темы:

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

@Configuration
class KafkaTopicConfig {

@Bean
fun kafkaAdmin(): KafkaAdmin {
val configs: MutableMap = HashMap()
configs[AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG] = "http://localhost:9092"
return KafkaAdmin(configs)
}

@Bean
fun topic1(): NewTopic {
return NewTopic("kafkaTest", 1, 1.toShort())
}
}

Сервис Kafka:

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

@Service
class KafkaService(
private val kafkaTemplate: KafkaTemplate
) {

fun send() {
kafkaTemplate.send("kafkaTest", "test message ${System.currentTimeMillis()}")
}

@KafkaListener(topics = ["kafkaTest"], groupId = "group12345")
fun listenGroupFoo(message: String) {
println("--> $message")
}
}

Это ВСЕ классы в моем приложении. Когда я пытаюсь запустить приложение, я получаю следующее исключение:

2021-10-11 17:20:13.319 WARN 8544 --- [| adminclient-1]
org.apache.kafka.clients.NetworkClient: [AdminClient
clientId=adminclient-1] Ошибка подключения к узлу 34bcfcc207e0:9092
(id: 1001 стойка: null)
java.net.UnknownHostException: 34bcfcc207e0

Я понятия не имею, что такое хост 34bcfcc207e0. Оно появляется в начале или в цепочке.


Что не так?