Elasticsearch içinde bir TransportClient örneği oluşturuyorum. Aşağıda aynı kod var. Sorun, TransportClient'in başlattığı threadpool ile oluşturulan iplik sayısını azaltmaya çalışıyorum. Ama hangi ayarları benim elasticsearch kullanıyorum her zaman thread thread 12 thread ile başlangıç. İstediğiniz konuları almak için lütfen nasıl yapılandırılacağını bana bildirin.sınır iplik sayısı
public static TransportClient getTransportClient(String ip, int port) {
ImmutableSettings.Builder settings = ImmutableSettings
.settingsBuilder();
settings.put("cluster.name", "elasticsearch");
settings.put("threadpool.bulk.type", "fixed");
settings.put("threadpool.bulk.size" ,5);
settings.put("threadpool.bulk.queue_size", 5);
settings.put("threadpool.index.type" , "fixed");
settings.put("threadpool.index.size" , 5);
settings.put("threadpool.index.queue_size" , 10);
settings.put("threadpool.search.type", "fixed");
settings.put("threadpool.search.size" ,5);
settings.put("threadpool.search.queue_size", 5);
settings.build();
TransportClient instance = new TransportClient(settings)
.addTransportAddress(new InetSocketTransportAddress(ip, port));
return instance;
}
alınan JanuZ için
Kredi, deneyin? – bagui
bunun için çözüm buldunuz mu? –
Çözüme ulaşmadım – bagui