Быстрый и практический пример тестирования Кафки

• "commitSync": true: Здесь мы говорим тесту сделать `commitSync` после использования сообщения, это означает, что он не будет читать сообщение снова, когда вы` опросите ‘в следующий раз. Он будет читать только новые сообщения, если они появятся в теме.

• "maxNoOfRetryPollsOrTimeouts": 3Здесь мы говорим тесту показывать опрос максимум три раза, а затем прекращать опрос. Если у нас есть больше записей, мы можем установить это большее значение. Значением по умолчанию является 1.

• "pollingTime": 500:  Здесь мы говорим тест на опрос в течение 500 миллисекунд каждый раз опрашивает. Значение по умолчанию составляет 100 миллисекунд, если вы пропустите этот флаг.

Посетите эту страницу для  всех настраиваемых ключей — ConsumerLocalConfigs из исходного кода.

Посетите репозиторий с примерами HelloWorld Kafka, чтобы попробовать его дома.

Примечание. Эти значения конфигурации могут быть установлены в файле свойств глобально для всех тестов, что означает, что они будут применяться ко всем тестам в нашем тестовом пакете. Также мы можем переопределить любой из конфигов для конкретного теста или тестов внутри пакета. Следовательно, это дает нам гибкость для охвата всех видов тестовых сценариев.

Что ж, настройка этих свойств не имеет большого значения, и мы все равно должны сделать это, чтобы их экстернализовать. Следовательно, чем проще они поддерживаются, тем лучше для нас! Но мы должны понять, что происходит внутри них.

Мы обсудим это в следующих разделах.

12. Сочетание тестирования REST API с тестированием Kafka

Большую часть времени в архитектуре микросервисов мы создаем приложения, используя сервисы RESTful, сервисы SOAP (возможно, устаревшие) и Kafka.

Поэтому нам необходимо охватить все проверки контрактов API в наших сценариях сквозного тестирования, включая Kafka.

Но это не имеет большого значения, так как, в конце концов, здесь ничего не меняется, за исключением того, что мы просто указываем наш URL-адрес на конечную точку HTTP для нашей службы REST или SOAP, а затем соответствующим образом манипулируем блоком полезной нагрузки / утверждений. Это действительно так.

Пожалуйста, посетите раздел Объединение тестирования Kafka с тестированием REST API для полного пошагового подхода.

Если у нас есть сценарий использования:

Шаг 1: вызов Кафки — мы отправляем запись «Адрес» с идентификатором «id-lon-123» в «адрес-тему», которая в конечном итоге обрабатывается и записывается в базу данных «Адрес» (например, Postgres или Hadoop). Затем мы утверждаем подтверждение брокера.

Шаг 2: вызов REST — запрос (GET) REST API «Address» с помощью «/ api / v1 / address / id-lon-123» и подтверждение ответа.

Соответствующий тестовый пример выглядит ниже.

{
    "scenarioName": "Kafka and REST api validation example",
    "steps": [
        {
            "name": "produce_to_kafka",
            "url": "kafka-topic:people-address",
            "operation": "produce",
            "request": {
                "recordType" : "JSON",
                "records": [
                    {
                        "key": "id-lon-123",
                        "value": {
                            "id": "id-lon-123",
                            "postCode": "UK-BA9"
                        }
                    }
                ]
            },
            "assertions": {
                "status": "Ok",
                "recordMetadata" : "$NOT.NULL"
            }
        },
        {
            "name": "verify_updated_address",
            "url": "/api/v1/addresses/${$.produce_to_kafka.request.records[0].value.id}",
            "operation": "GET",
            "request": {
                "headers": {
                    "X-GOVT-API-KEY": "top-key-only-known-to-secu-cleared"
                }
            },
            "assertions": {
                "status": 200,
                "value": {
                    "id": "${$.produce_to_kafka.request.records[0].value.id}",
                    "postCode": "${$.produce_to_kafka.request.records[0].value.postcode}"
                }
            }
        }
    ]
}

"recordType" : "RAW",

{
    "name": "produce_a_record",
    "url": "kafka-topic:demo-topic",
    "operation": "produce",
    "request": {
        "recordType" : "RAW",
        "records": [
            {
                "key": 101,
                "value": "Hello World"
            }
        ]
    },
    "assertions": {
        "status": "Ok",
        "recordMetadata": "$NOT.NULL"
    }
}

"recordType" : "JSON"

{
    "name": "produce_a_record",
    "url": "kafka-topic:demo-topic",
    "operation": "produce",
    "request": {
        "recordType" : "JSON",
        "records": [
            {
                "key": 101,
                "value": { 
                    "name" : "Jey"
                }
            }
        ]
    },
    "assertions": {
        "status": "Ok",
        "recordMetadata": "$NOT.NULL"
    }
}