Kafka Configuration

# Kafka `@Configuration` — Java, Spring Boot 3.2+

Generated when `(language, bootBranch) = (java, boot3.2)` and `serializerSource = @Configuration`.

## Variables

- `{packageName}` — from Step 4.
- `{className}` — from Step 4.
- `{prefix}` — `decapitalize({producerValueType} simple name)`.
- `{producerKeyType}` / `{producerValueType}` / `{consumerKeyType}` / `{consumerValueType}` — simple names.
- `{producerKeySerializer}` / `{producerValueSerializer}` / `{consumerKeyDeserializer}` / `{consumerValueDeserializer}` — short class names; resolve FQNs via `examples/serializer-mapping.md`.
- `{jsonConsumerPropertiesLines}` — present only when `consumerKeyType` OR `consumerValueType` is a POJO; otherwise the lines are omitted. Always include `TRUSTED_PACKAGES` when any consumer side is a POJO. Include `KEY_DEFAULT_TYPE` only when `consumerKeyType` is a POJO. Include `VALUE_DEFAULT_TYPE` only when `consumerValueType` is a POJO:
  ```java
  consumerProperties.put(JsonDeserializer.TRUSTED_PACKAGES, "{packages}");
  consumerProperties.put(JsonDeserializer.KEY_DEFAULT_TYPE, "{consumerKeyTypeFqn}");
  consumerProperties.put(JsonDeserializer.VALUE_DEFAULT_TYPE, "{consumerValueTypeFqn}");
  ```
- `{listenerFactoryName}` — `kafkaListenerContainerFactory` by default; `{prefix}KafkaListenerContainerFactory` only on name collision.

## Code

```java
package {packageName};

import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.clients.producer.ProducerConfig;
import org.springframework.beans.factory.ObjectProvider;
import org.springframework.boot.autoconfigure.kafka.KafkaProperties;
import org.springframework.boot.ssl.SslBundles;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory;
import org.springframework.kafka.core.ConsumerFactory;
import org.springframework.kafka.core.DefaultKafkaConsumerFactory;
import org.springframework.kafka.core.DefaultKafkaProducerFactory;
import org.springframework.kafka.core.KafkaTemplate;

import java.util.Map;

@Configuration
public class {className} {

    @Bean
    DefaultKafkaProducerFactory<{producerKeyType}, {producerValueType}> {prefix}ProducerFactory(
            KafkaProperties properties,
            ObjectProvider<SslBundles> sslBundles) {
        Map<String, Object> producerProperties = properties.buildProducerProperties(sslBundles.getIfAvailable());
        producerProperties.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, {producerKeySerializer}.class);
        producerProperties.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, {producerValueSerializer}.class);
        return new DefaultKafkaProducerFactory<>(producerProperties);
    }

    @Bean
    KafkaTemplate<{producerKeyType}, {producerValueType}> {prefix}KafkaTemplate(
            DefaultKafkaProducerFactory<{producerKeyType}, {producerValueType}> {prefix}ProducerFactory) {
        return new KafkaTemplate<>({prefix}ProducerFactory);
    }

    @Bean
    ConsumerFactory<{consumerKeyType}, {consumerValueType}> {prefix}ConsumerFactory(
            KafkaProperties properties,
            ObjectProvider<SslBundles> sslBundles) {
        Map<String, Object> consumerProperties = properties.buildConsumerProperties(sslBundles.getIfAvailable());
        consumerProperties.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, {consumerKeyDeserializer}.class);
        consumerProperties.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, {consumerValueDeserializer}.class);
        {jsonConsumerPropertiesLines}
        return new DefaultKafkaConsumerFactory<>(consumerProperties);
    }

    @Bean
    ConcurrentKafkaListenerContainerFactory<{consumerKeyType}, {consumerValueType}> {listenerFactoryName}(
            ConsumerFactory<{consumerKeyType}, {consumerValueType}> {prefix}ConsumerFactory) {
        ConcurrentKafkaListenerContainerFactory<{consumerKeyType}, {consumerValueType}> factory =