diff --git a/.ci/docker-compose-file/docker-compose-kafka.yaml b/.ci/docker-compose-file/docker-compose-kafka.yaml index d610316bd..d58f51146 100644 --- a/.ci/docker-compose-file/docker-compose-kafka.yaml +++ b/.ci/docker-compose-file/docker-compose-kafka.yaml @@ -33,10 +33,14 @@ services: ports: - "9092:9092" - "9093:9093" + - "9094:9094" + - "9095:9095" container_name: kafka-1.emqx.net hostname: kafka-1.emqx.net depends_on: - "kdc" + - "zookeeper" + - "ssl_cert_gen" environment: KAFKA_BROKER_ID: 1 KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181 diff --git a/lib-ee/emqx_ee_bridge/test/emqx_bridge_impl_kafka_producer_SUITE.erl b/lib-ee/emqx_ee_bridge/test/emqx_bridge_impl_kafka_producer_SUITE.erl index 5e9dbfc73..fb929e692 100644 --- a/lib-ee/emqx_ee_bridge/test/emqx_bridge_impl_kafka_producer_SUITE.erl +++ b/lib-ee/emqx_ee_bridge/test/emqx_bridge_impl_kafka_producer_SUITE.erl @@ -51,7 +51,7 @@ all() -> wait_until_kafka_is_up() -> wait_until_kafka_is_up(0). -wait_until_kafka_is_up(90) -> +wait_until_kafka_is_up(300) -> ct:fail("Kafka is not up even though we have waited for a while"); wait_until_kafka_is_up(Attempts) -> KafkaTopic = "test-topic-one-partition",