I am currently read the log from the kafka ,which is formated in protobuf format and then consume it via akka actors.and then I streaming it to graylog2-server via gelfclient.
but the method on GelfTransport is either block or no blocking with just an hint,so it would not that nice when working it with akka.
so how about make it return a Future?
and I know you using the queue there maybe for back pressure ,but the a composable way maybe implement the RS.
I am currently read the log from the kafka ,which is formated in protobuf format and then consume it via akka actors.and then I streaming it to graylog2-server via gelfclient.
but the method on GelfTransport is either block or no blocking with just an hint,so it would not that nice when working it with akka.
so how about make it return a Future?
and I know you using the queue there maybe for back pressure ,but the a composable way maybe implement the RS.