kroxylicious-junit5-extension release 0.7.0

import java.time.Duration;
import java.util.Set;
import java.util.concurrent.ExecutionException;

import org.apache.kafka.clients.consumer.Consumer;
import org.apache.kafka.clients.producer.Producer;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.assertj.core.api.Assertions;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;

import io.kroxylicious.testing.kafka.api.KafkaCluster;
import io.kroxylicious.testing.kafka.common.BrokerCluster;
import io.kroxylicious.testing.kafka.junit5ext.KafkaClusterExtension;
import io.kroxylicious.testing.kafka.junit5ext.Topic;

@ExtendWith(KafkaClusterExtension.class)
class ExampleTest {

    @BrokerCluster
    KafkaCluster cluster;

    @Test
    void shouldConsumePublishedRecord(Topic topic, Producer<String, String> producer, Consumer<String, String> consumer)
            throws ExecutionException, InterruptedException {
        //Given
        producer.send(new ProducerRecord<>(topic.name(), "my-key", "Hello, world!")).get();
        consumer.subscribe(Set.of(topic.name()));

        //When
        var records = consumer.poll(Duration.ofSeconds(10));

        //Then
        consumer.close();
        Assertions.assertThat(records).hasSize(1).extractingResultOf("value").containsExactly("Hello, world!");
    }
}