JAVA-7309: Take a look into failing apache-kafka tests

This commit is contained in:
sampadawagde 2021-10-06 22:05:30 +05:30
parent 00026a8d5b
commit 250d084d3c
3 changed files with 7 additions and 1 deletions

View File

@ -12,8 +12,10 @@ import java.util.Properties;
import static org.assertj.core.api.Assertions.assertThat;
// This live test needs a running Docker instance so that a kafka container can be created
@Testcontainers
class KafkaTopicApplicationIntegrationTest {
class KafkaTopicApplicationLiveTest {
@Container
private static final KafkaContainer KAFKA_CONTAINER = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:5.4.3"));

View File

@ -20,6 +20,8 @@ import java.util.concurrent.atomic.AtomicReference;
import static org.junit.Assert.assertEquals;
// This live test needs a Docker instance running so that kafka container can be created
public class KafkaSerDesLiveTest {
private static final String CONSUMER_APP_ID = "consumer_id";
private static final String CONSUMER_GROUP_ID = "group_id";

View File

@ -44,6 +44,8 @@ import static org.apache.kafka.clients.consumer.ConsumerConfig.BOOTSTRAP_SERVERS
import static org.apache.kafka.clients.producer.ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG;
import static org.apache.kafka.clients.producer.ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG;
// This live test needs a Docker instance running so that kafka container can be created
public class KafkaStreamsLiveTest {
private final String LEFT_TOPIC = "left-stream-topic";
private final String RIGHT_TOPIC = "right-stream-topic";