Hi Raj,
The Kafka design is based on fully decoupled producers and consumers, where
the responsibility of the producer ends after a record has been
successfully produced.
Since a producer is not aware of other applications that might be consuming
the record it can continue with its own flow.
The s
Hello,
I need to check case with kafka cluster expansion at the integration test.
I see the EmbeddedKafkaCluster and IntegrationTestHarness are popular to use at
he integration tests.
But these test classes don't support test cluster expansion.
What do you suggest to use in this case?
Does make
