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 sense create issue & PR to add cluster expansion function at the EmbeddedKafkaCluster or IntegrationTestHarness? May be I miss something and a cluster expansion functionality not specifically added to the classes? -- With best regards, Taras Ledkov
