Hi Oscar
You can refer to the unit tests in flink-connector-kafka.
https://github.com/apache/flink-connector-kafka/blob/d6525c1481fc2d2821f361d2d5ce48f97221dd74/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaITCase.java#L152
Best,
Feng
On Mon, Sep 11, 2023
Hi,
I have a flink job which I want to test e2e.
In the test I start flink minicluster and this reads from kafka topics in
testcontainers. I m facing a problem that for some topics I have starting
offset as latest and I want to publish these messages just after the job
has been completely started
