Только начал изучать докер. Идея следующая: Есть 2 spring boot сервиса, между которыми общение осуществляется через кафку. Хочу попробовать перенести все это в докер. Для начала решил перенести в докер кафку. Используя docker-compose поднимаю zooKeeper и кафку так:
networks:
kafka-net:
driver: bridge
services:
zookeeper-server:
image: 'bitnami/zookeeper:latest'
networks:
- kafka-net
ports:
- '2181:2181'
environment:
- ALLOW_ANONYMOUS_LOGIN=yes
kafka-server1:
image: 'bitnami/kafka:latest'
networks:
- kafka-net
ports:
- '9092:9092'
environment:
- KAFKA_CFG_ZOOKEEPER_CONNECT=zookeeper-server:2181
- KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://localhost:9092
- ALLOW_PLAINTEXT_LISTENER=yes
depends_on:
- zookeeper-server
используя команду docker-compose -f ./compose.yaml up -d
у меня получается поднять и zookeeper и кафку, но почему то, мои сервисы не видят ее.
Вот конфиг класс consumer'a из сервиса:
@Configuration
public class KafkaConsumerConfig {
@Value("${kafka.server}")
private String kafkaServer;
@Value("${kafka.group.id}")
private String kafkaGroupId;
@Bean
public Map<String, Object> consumerConfigs() {
Map<String, Object> props = new HashMap<>();
props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaServer);
props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, LongDeserializer.class);
props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
props.put(ConsumerConfig.GROUP_ID_CONFIG, kafkaGroupId);
return props;
}
@Bean
public KafkaListenerContainerFactory<?> kafkaListenerContainerFactory() {
ConcurrentKafkaListenerContainerFactory<Long, BookingReceiptDto> factory =
new ConcurrentKafkaListenerContainerFactory<>();
factory.setConsumerFactory(consumerFactory());
return factory;
}
@Bean
public ConsumerFactory<Long, BookingReceiptDto> consumerFactory() {
return new DefaultKafkaConsumerFactory<>(consumerConfigs());
}
И проперти файл данного сервиса:
server.port=8081
kafka.consumer.id=consumerServer
kafka.producer.id=producerServer
kafka.server=localhost:9092
kafka.group.id=server.broadcast
Думаю, что возможно, причина в том что порты как то не так проброшены. Но вроде бы все делаю по мануалам, а эффекта нет. В чем может быть причина?
docker-compose ps
(у вас там используетсяcompose.yaml
, поэтому еще с ключиком-f compose.yaml
). Это покажет и контейнеры, и их порты. например,0.0.0.0:3320->3306
- это проброс порта 3320 с машины на 3306 в контейнере. 2.kafka.server=localhost:9092
- а вот это уже интересно. Сервер приложений тоже в контейнере? Или прямо на машине, без контейнеров? Если внутри дрогого контейнера, тоlocalhost:9092
конечно же не подойдет, так как внутри контейнера локалхост - это этот же контейнер!