Support of Elasticsearch for Spring Data

public class EsConfig {


    @Autowired
    private EsSinkProperties properties;


    @Bean
    public Client client() throws Exception {

        Settings esSettings = Settings.builder()
                .put("cluster.name", properties.getClusterName())
                .build();

        TransportClient client = new PreBuiltTransportClient(esSettings)
                .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(properties.getHost()), Integer.parseInt(properties.getPort())));

     }
}

public class EsSinkProperties {

    /
     * Elasticsearch cluster name.
     */
    private String clusterName = "elasticsearch";

    /
     * Elasticsearch host name.
     */
    private String host = "localhost";

    /
     * Elasticsearch native port.
     */
    private String port = "9300";

    @NotBlank
    public String getClusterName() {
        return clusterName;
    }

    public void setClusterName(String clusterName) {
        this.clusterName = clusterName;
    }
}

@Document(indexName = "trader", type = "trade")
public class Trade {

    @Id
    private String id;

    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }

public override void Configure(EntityTypeBuilder<Contractor> builder)
        {
            builder.ToTable("Trial");
            builder.OwnsOne(m => m.Name, a =>
            {
                a.Property(p => p.FirstName).HasMaxLength(300)
                    .HasColumnName("FirstName")
                    .HasDefaultValue("");
                a.Property(p => p.LastName).HasMaxLength(300)
                    .HasColumnName("LastName")
                    .HasDefaultValue("");
                a.Ignore(p => p.FullName);
            });

public Book save(Book book) {
        return bookRepository.save(book);
    }

public void delete(Book book) {
        bookRepository.delete(book);
    }

public Iterable<Book> findAll() {
        return bookRepository.findAll();
    }

public interface BookRepository extends ElasticsearchRepository<Book, String> {

    Page<Book> findByAuthor(String author, Pageable pageable);

    List<Book> findByTitle(String title);

}

public Page<Book> findByAuthor(String author, PageRequest pageRequest) {
        return bookRepository.findByAuthor(author, pageRequest);
    }

public void deleteIndex() {
        operations.indexOps(Conference.class).delete();
}

import org.springframework.data.elasticsearch.client.elc.ReactiveElasticsearchClient;

@Repository
public class ElasticRepository {

    public static final String COURSE_INDEX = "course-store";
    private final ReactiveElasticsearchClient client;
    private final ObjectMapper objectMapper;

    public ElasticRepository(ReactiveElasticsearchClient client, ObjectMapper objectMapper) {
        this.client = client;
        this.objectMapper = objectMapper;
    }

    public Mono<DeleteResponse> deleteCourse() {
        return client.delete(deleteRequest -> deleteRequest.index(COURSE_INDEX));
    }
}