src/test/java/TeamSyncTest/kafka/KafkaSendReceiveTest.java - master - koskv/TeamSync-Tests

src/test/java/TeamSyncTest/kafka/KafkaSendReceiveTest.java

63 строки2 KB

Koskv

Add: getTaskByStatus_ApiTest_positive() - теперь параметризированный

18 окт 2025, 21:23

18 окт 2025, 21:231218883

package TeamSyncTest.kafka;

import TeamSyncTest.kafka.config.TestConsumer;
import TeamSyncTest.kafka.config.TestConsumer2;
import io.qameta.allure.Epic;
import io.qameta.allure.Story;
import org.junit.jupiter.api.Tag;
import org.junit.jupiter.api.Test;

import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.kafka.test.context.EmbeddedKafka;

import java.util.concurrent.TimeUnit;

import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertTrue;

@SpringBootTest
@EmbeddedKafka(
        topics = {"test-topic", "test-topic-2"},
        partitions = 1,
        bootstrapServersProperty = "spring.kafka.bootstrap-servers"
)
@Tag("kafka")
@Epic("Kafka Tests")
@Story("Kafka operations - story")
public class KafkaSendReceiveTest {

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    @Autowired
    private TestConsumer testConsumer;
    @Autowired
    private TestConsumer2 testConsumer2;

    @Test
    public void givenEmbeddedKafkaBroker_whenSendingMessage_thenMessageReceived() throws Exception {
        String testMessage = "Hello, Kafka!";

        kafkaTemplate.send("test-topic", testMessage);

        boolean messageReceived = testConsumer.getLatch().await(10, TimeUnit.SECONDS);

        assertTrue(messageReceived, "Сообщение не было получено");
        assertEquals(testMessage, testConsumer.getReceivedMessage(), "Полученное сообщение не совпадает с отправленным");
    }

    @Test
    public void topicTwo_Test() throws Exception {
        String testMessage = "Test, Kafka! Send to topic 2! ";

        kafkaTemplate.send("test-topic-2", testMessage);

        boolean messageReceived = testConsumer2.getLatch().await(10, TimeUnit.SECONDS);

        assertTrue(messageReceived, "Сообщение из топика test-topic-2 не было получено");
        assertEquals(testMessage, testConsumer2.getRecievedMessage());
    }

}