Eu estou criando uma instância TransportClient emelasticsearch. Abaixo está o código para o mesmo. O problema é que eu estou tentando diminuir o número de threads gerado com o threadpool que TransportClient inicia.Mas quais configurações sempre usar meu elasticsearch sempre rubricando o threadpool com 12 threads.Por favor, deixe-me saber como configurar o mesmo para obter o desejável tópicos.
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;
}
Respostas:
1 para resposta № 1Experimentar
Settings settings = ImmutableSettings.settingsBuilder()
.put("transport.netty.workerCount",NUM_THREADS)
.build();
Crédito para JanuZ, retirado de http://www.lucidelectricdreams.com/2013/11/reducing-number-of-threads-created-by.html