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 at 5:39 PM Oscar Perez via user <user@flink.apache.org> wrote: > 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, so that these messages can be read > > Is there a clean solution to send the payment event after the job has been > started? Currently I m using Thread.sleep for that but I would like to > await on something but dont know what would be the trigger for that > > Regards, > Oscar > > >
