What kafka image are you using?

[extreme4all]

i'm using the following

docker-compose.yml

version: '3'
services:
  kafka:
    image: bitnami/kafka:latest
    environment:
      - ALLOW_PLAINTEXT_LISTENER=yes
      - KAFKA_CFG_LISTENERS=PLAINTEXT://:9092,CONTROLLER://:9093,EXTERNAL://:9094
      - KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP=CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT,EXTERNAL:PLAINTEXT
      - KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://kafka:9092,EXTERNAL://localhost:9094
    volumes:
      - ./kafka:/bitnami/kafka:rw
    ports:
      - 9094:9094

[sternakt]

Hi,

We are not using docker images to run ApacheKafka.

For testing with a real ApacheKafka broker, the Tester object has an option to start ApacheKafka broker in another process.
You need to have JRE and Kafka installed on your machine, for that, you can use fastkafka testing install_deps command.
There is also an option for starting an instance of ApacheKafkaBroker directly.

Here are the links to mentioned functions:
AacheKafkaBroker: https://fastkafka.airt.ai/docs/api/fastkafka/testing/ApacheKafkaBroker
Tester using local Apache Kafka: https://fastkafka.airt.ai/docs/api/fastkafka/testing/Tester#using_local_kafka
fastkafka testing install_deps command: https://fastkafka.airt.ai/docs/cli/fastkafka#fastkafka-testing-install_deps

If you plan to connect the Tester to your external broker, this is not yet supported, but we have submitted an issue for it: https://github.com/airtai/fastkafka/issues/355