在“Spring data+mongodb项目”中添加elasticsearch

Question

第二个问题：当elastic和mongo都有@DocumNet注释时，如何注释模型类？现在我错误地认为它与这个问题有关：“没有为类找到id属性”

@Document(indexName = "gold", type = "article")
@Document
public class GoldSnapShot {
    public static final String TOPIC = "goldsnapshot";
    Double ons;
    Double gram18;
    Double irec;
    Double dollar;
    @org.springframework.format.annotation.DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    private DateTime timestamp;

最后，我将感谢任何关于最佳实践和更干净的编码的指导。

SpringBootApplication：

@EnableMongoRepositories("com.sames.samesgoldconsumer.Repository")
@EnableElasticsearchRepositories(basePackages = "com.sames.samesgoldconsumer.elasticsearch.Repository")
@SpringBootApplication
public class SamesGoldConsumerApplication {

    public static void main(String[] args) {
        SpringApplication.run(SamesGoldConsumerApplication.class, args);
    }

}

@Component
public class KafkaConsumerService {
    private final GoldSnapShotMongoRepository goldSnapShotMongoRepository;
    private final GoldSnapShotElasticRepository goldSnapShotElasticRepository;

    private final Logger logger
            = LoggerFactory.getLogger(KafkaConsumerService.class);

    public KafkaConsumerService(GoldSnapShotMongoRepository goldSnapShotMongoRepository,
                                GoldSnapShotElasticRepository goldSnapShotElasticRepository) {
        this.goldSnapShotMongoRepository = goldSnapShotMongoRepository;
        this.goldSnapShotElasticRepository = goldSnapShotElasticRepository;
    }
    @KafkaListener(topics = "gold", groupId = AppConstants.GROUP_ID)
    public void processMessage(GoldSnapShot goldSnapShot) {
        logger.info(String.format("GoldSnapShot Received -> %s", goldSnapShot.toString()));
        goldSnapShotMongoRepository.save(goldSnapShot);
        goldSnapShotElasticRepository.save(goldSnapShot);
    }
}

@Configuration
public class ElasticConfig {

    @Bean
    public RestHighLevelClient client() {
        ClientConfiguration clientConfiguration
                = ClientConfiguration.builder()
                .connectedTo("localhost:9200")
                .build();

        return RestClients.create(clientConfiguration).rest();
    }

    @Bean
    public ElasticsearchOperations elasticsearchTemplate() {
        return new ElasticsearchRestTemplate(client());
    }
}

@EnableKafka
@Configuration
public class KafkaConfig {
//    @Value("${spring.kafka.consumer.group-id}")
//    private String brokers;
    private final String brokers = "localhost:9092";
//    @Value("${spring.kafka.bootstrap-servers}")
//    private String groupId;
    private final String groupId = "group-id";
    @Bean
    public ConsumerFactory<String, GoldSnapShot> consumerFactory() {
        Map<String, Object> props = new HashMap<>();
        props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, brokers);
        props.put(ConsumerConfig.GROUP_ID_CONFIG, groupId);
        props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
        props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, ErrorHandlingDeserializer.class);
        props.put(ErrorHandlingDeserializer.VALUE_DESERIALIZER_CLASS, JsonDeserializer.class);
        props.put(JsonDeserializer.VALUE_DEFAULT_TYPE, GoldSnapShot.class);
        return new DefaultKafkaConsumerFactory<>(props);
    }
    @Bean
    KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<String, GoldSnapShot>>
    kafkaListenerContainerFactory() {
        ConcurrentKafkaListenerContainerFactory<String, GoldSnapShot> factory =
                new ConcurrentKafkaListenerContainerFactory<>();
        factory.setConsumerFactory(consumerFactory());
        return factory;
    }
}

Answer 1

您真的需要将整个对象存储在ES中吗？我只是想知道在ES中有什么搜索是MongoDB没有提供的？数据中没有文本字段，只有数值和日期。

我强烈建议不要将同一个类用于三个目的：阅读Kafka，存储到MongoDB和ElasticSearch中。为Spring数据模块定义单独的类，并编写映射器将从Kafka读取的数据转换为单独的数据模型。

否则，您最终会在类上有两个不同的@document注释，其中一个需要完全限定。