I'm trying to use Pulumi to manage some docker containers. One container is running Kafka. How can I have Pulumi wait until Kafka is up and running before creating the topic?

kafkaContainer = docker.Container("kafka-container",
    image=kafkaImage.name,
    restart="on-failure",
    networks_advanced=[{ 'name': network.name }],
    start=True,
    envs=[
      "KAFKA_BROKER_ID=1",
      "KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181",
      "KAFKA_ADVERTISED_LISTENERS=<PLAINTEXT://kafka:29092>,PLAINTEXT_<HOST://localhost:9092>",
      "KAFKA_LISTENER_SECURITY_PROTOCOL_MAP=PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT",
      "KAFKA_INTER_BROKER_LISTENER_NAME=PLAINTEXT",
      "KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1"
    ],
    ports=[{
        'internal': 9092,
    }],
    opts=pulumi.ResourceOptions(depends_on=[zkContainer])
)


topic = kafka.Topic("topic",
      name="sample-topic",
      replication_factor=1,
      partitions=4,
      opts=pulumi.ResourceOptions(depends_on=[kafkaContainer])
    )

wondering adding the

healthcheck

property to your container will work

Hmmm yeah the problem is the healthcheck was gonna be "is this topic there" but I can try something else

@mysterious-belgium-44686 Are you trying to get this working with local or aws right now?

local

for local you'd want to add Kafka to our

docker-compose.yml

Yeah what I'm doing is testing replacing docker-compose with Pulumi

oh lmao ok

😊

Yeah what I’m doing is testing replacing docker-compose with Pulumi

@sparse-tomato-5980 I never thought about this, what do you think would be the advantages in a local setup? Don’t you think it complicates things for “normal users”?

I think you might have meant to message me with that one, not Max?

👍