阅读与Spring boot相关的recordType的Spring boot TopicRecordNameStrategy使用客户

@Configuration
@EnableKafka
public class KafkaConfig {

    @Bean
    public ProducerFactory<String, Object> producerFactory() {
        Map<String, Object> configProps = new HashMap<>();
        // 配置Kafka生产者的属性
        // ...
        return new DefaultKafkaProducerFactory<>(configProps);
    }

    @Bean
    public KafkaTemplate<String, Object> kafkaTemplate() {
        return new KafkaTemplate<>(producerFactory());
    }

    @Bean
    public NewTopic myTopic() {
        return TopicBuilder.name("my-topic")
                .partitions(1)
                .replicas(1)
                .build();
    }

    @Bean
    public TopicRecordNameStrategy topicRecordNameStrategy() {
        return new TopicRecordNameStrategy() {
            @Override
            public String getRecordName(ProducerRecord<?, ?> producerRecord) {
                // 使用recordType作为消息记录名称
                return producerRecord.value().getClass().getSimpleName();
            }
        };
    }

    @Bean
    public KafkaTemplate<String, Object> customKafkaTemplate(KafkaTemplate<String, Object> kafkaTemplate,
                                                             TopicRecordNameStrategy topicRecordNameStrategy) {
        kafkaTemplate.setTopicRecordNameStrategy(topicRecordNameStrategy);
        return kafkaTemplate;
    }
}