KAFKA_PRODUCER_PROPERTIES#

Настройка предоставляет свойства, которые используются kafka клиентом для создания инстанса org.apache.kafka.clients.producer.KafkaProducer.

Примеры properties можно посмотреть тут

import ru.tinkoff.qa.neptune.core.api.properties.object.ObjectPropertySupplier;

//Создаем поставщика, который будет поставлять объект класса Properties
public class MyProducerPropertiesSupplier 
    implements ObjectPropertySupplier<Properties, Supplier<Properties>> {

    @Override
    public Properties get() {
        //Тут создается объект, который будет использован клиентом
    }
}
#Значение свойства указывается так
KAFKA_PRODUCER_PROPERTIES=org.my.pack.MyProducerPropertiesSupplier
import static ru.tinkoff.qa.neptune.kafka.properties
        .DefaultKafkaProperties.KAFKA_PRODUCER_PROPERTIES;

public class SomeClass {

    public void someVoid() {
        //пример доступа до значения свойства
        Properties producerProperties = KAFKA_PRODUCER_PROPERTIES.get();
    }
}

Ниже пример, если модуль используется для тестирования Spring-приложения вместе с инструментами Spring Test

import ru.tinkoff.qa.neptune.core.api.properties.object.ObjectPropertySupplier;

import static ru.tinkoff.qa.neptune.spring.boot.starter.application
    .contexts.CurrentApplicationContextTestExecutionListener.getCurrentApplicationContext;

//Создаем поставщика, который будет поставлять объект класса Properties
public class MySpringProducerPropertiesSupplier 
    implements ObjectPropertySupplier<Properties, Supplier<Properties>> {

    @Override
    public Properties get() {
        //текущий контекст приложения
        var context = getCurrentApplicationContext();
        //Далее извлекаем необходимые бины,
        //при помощи которых можно получить свойства для продюсера.

        //....
        //алгоритм получения бинов от контекста приложения 

        //То, что нужно заполнить и вернуть
        var properties = new Properties();

        //Логика получения свойств продюсера и заполнения
        //результирующего объекта properties
        //....
        
        //какая-то дополнительная логика
        //....
        return properties;
    }
}

Полезная ссылка: Neptune Spring boot starter