kafka.consumer.SimpleConsumer: reconexão devido a erro de soquete: java.nio.channels.ClosedChannelException

Estou executando um consumidor simples para kafka como este: int timeout = 80000; int bufferSize = 64*1024; consumer = new SimpleConsumer(host, port,timeout, bufferSize, clientName);Isso funciona bem por algumas horas, mas recebo uma exceção ...

Como ler uma solicitação usando o CompletionHandlers e um ByteBuffer menor que a solicitação?

Seletores java.nio e SocketChannel para continua Streaming

Atualmente, estou usando o java.nio.channel.Selectors & SocketChannels para um aplicativo que abrirá conexões de 1 para muitos para continuar o streaming...

java.lang.UnsupportedOperationException: 'posix: permissions' não suportado como atributo inicial no Windows

Como enviar e receber um objeto serializado no canal de soquete

Eu quero transmitir um objeto serializado através de um canal de soquete. Eu quero fazer "Hi friend" string como objeto serializado e, em seguida, ...

Criar um ByteBuf no Netty 4.0

Duas perguntas simples, que não posso resolver lendo a documentação:eu tenho um

Tempo limite de conexão ao soquete usando o NIO SocketChannel [duplicado]

Esta questão já tem uma resposta aqui:Especifique o tempo limite de conexão em java.nio 2 respostasNós temos uma classe que está falando com outro HOST em um...

Quando usar ** (estrela dupla) na sintaxe glob dentro de JAVA

Diretamente deisto Tutorial do Oracle Java:Dois asteriscos, **, funcionam como *, mas cruzam os limites do diretório. Essa sintaxe é geralmente usada para co...

Como usar o pacote java.nio.file no android?

Como implemento um cliente multicast no NIO.2?

Como seria um exemplo de uso de um cliente multicast Java 7 NIO.2? Eu só consegui encontrar metade de um exemplo noMulticastChannel [http://docs.oracle.com/javase/7/docs/api/java/nio/channels/MulticastChannel.html] documentação.