I have a Kafka client and I need to test the functionalities of it. For this I need to create a Kafka Cluster locally, and connect to it. As per the limitations, I can't use a Docker image or K8s for this.
I did a search, and found This class used in testing, but I can't change the broker ports.
I tried using Debezium KafkaCluster but it fails to create the cluster intermittently, hence causes intermittent test failures.
Is there a way to create a Kafka Cluster locally, to run integration tests for java-based Kafka clients?
Aucun commentaire:
Enregistrer un commentaire