Взаимодействие сервиса бизнес-логики с Apache Kafka

Шаблон сервиса бизнес-логики предоставляет готовые решения для работы с Kafka Producer и Kafka Consumer.

Kafka Producer

Настройка Kafka Producer включает следующие шаги:

1. Активация модуля Producer.

   Следующий блок кода файла application.yaml демонстрирует активацию модуля Producer.

   platform:
   kafka:
    producer:
      starter:
        enabled: true

   Следующий блок кода файла build.gradle демонстрирует добавление зависимости.

implementation 'org.springframework.kafka:spring-kafka'

2. Настройка дополнительных параметров модуля Producer.

   Следующая таблица демонстрирует дополнительные параметры, которые могут быть заданы в файле application.yaml и переменных окружения.

   Имя параметра	Переменная окружения	Значение по умолчанию
   spring.kafka.producer.bootstrap-servers	Kafka__Server	-
   spring.kafka.producer.key-serializer	SPRING_KAFKA_PRODUCER_KEY_SERIALIZER	StringSerializer
   spring.kafka.producer.value-serializer	SPRING_KAFKA_PRODUCER_VALUE_SERIALIZER	StringSerializer
   spring.kafka.producer.acks	SPRING_KAFKA_PRODUCER_ACKS	all
   spring.kafka.producer.delivery-timeout	SPRING_KAFKA_PRODUCER_DELIVERY_TIMEOUT	45000
   spring.kafka.producer.request-timeout	SPRING_KAFKA_PRODUCER_REQUEST_TIMEOUT	45000
   spring.kafka.producer.max-block	SPRING_KAFKA_PRODUCER_MAX_BLOCK	45000

   Адрес сервера Apache Kafka является обязательным параметром.

В результате настройки в Spring-контексте регистрируется компонент ru.platform.kafka.producer.KafkaProducerProperties, пример использования которого показан в следующем блоке кода.

@Autowired
private KafkaProducerPropertiesBuilder producerBuilder;

public void sendMessage(String topic, String message) {
    KafkaProducer<String, String> producer = producerBuilder.build();
    // ... отправка сообщения
}

Kafka Consumer

Настройка Kafka Consumer включает следующие шаги:

1. Активация модуля Consumer.

   Следующий блок кода файла application.yaml демонстрирует активацию модуля Consumer.

   platform:
    kafka:
        consumer:
            starter:
                enabled: true

   Следующий блок кода файла build.gradle демонстрирует добавление зависимости.

   implementation 'org.springframework.kafka:spring-kafka'

2. Настройка дополнительных параметров модуля Consumer.

   Следующая таблица демонстрирует дополнительные параметры, которые могут быть заданы в файле application.yaml и переменных окружения.

   Имя параметра	Переменная окружения	Значение по умолчанию
   spring.kafka.consumer.bootstrap-servers	Kafka__Server	-
   spring.kafka.consumer.key-deserializer	SPRING_KAFKA_CONSUMER_KEY_DESERIALIZER	StringDeserializer
   spring.kafka.consumer.value-deserializer	SPRING_KAFKA_CONSUMER_VALUE_DESERIALIZER	StringDeserializer
   spring.kafka.consumer.enable-auto-commit	SPRING_KAFKA_CONSUMER_ENABLE_AUTO_COMMIT	false
   spring.kafka.consumer.auto-offset-reset	SPRING_KAFKA_CONSUMER_AUTO_OFFSET_RESET	-
   spring.kafka.consumer.group-idt	SPRING_KAFKA_CONSUMER_GROUP_ID	-
   spring.kafka.consumer.client-id	SPRING_KAFKA_CONSUMER_CLIENT_ID	-
   platform.kafka.topic	PLATFORM_KAFKA_CONSUMER_TOPIC	-

   Все параметры являются обязательными.

В результате настройки в Spring-контексте регистрируется компонент ru.platform.kafka.consumer.KafkaConsumerPropertiesBuilder, пример использования которого показан в следующем блоке кода.

@KafkaListener(topics = "${platform.kafka.topic}")
public void listen(String message) {
    // ... обработка сообщения
}