package io.quarkus.it.kafka.streams;

import javax.inject.Inject;

import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;

import io.quarkus.test.common.QuarkusTestResource;
import io.quarkus.test.junit.QuarkusTest;

@QuarkusTestResource(KafkaTestResource.class)
@QuarkusTest
public class KafkaStreamsCdiEventTest {

    @Inject
    KafkaStreamsEventCounter eventCounter;

    @Test
    void testEventShouldBePublished() {
        Assertions.assertEquals(1, eventCounter.getEventCount(),
                "There should be one event for creating KafakStreams in the producder.");
    }
}
