Jan Filipiak

@zliu41 the entire task will be blocked by a slow fork at the moment anyhow. Wich is wanted behaviour i guess. IMO the gain of the whole looping thing in...

Changing the queue with statistics to give the wanted behavior is a little more invasive. I also need to touch/ write some unittests then. Will take me a little longer

Did all the changes that seemed to be required, Junittest seem to deadlock. If someone else want to fix this. Highly appreaciated.

Hi, Sorry yall, not sure if i have time to pull it over the finish line. I can maybe chop of a few hours next week. If not Ill let...

Coming from a protobuf background and not really into logstash I poked around a little. Indeed logstash is not really a friendly environment for event processing of that scheme. My...

Lets look at TCP input https://github.com/logstash-plugins/logstash-input-tcp/blob/master/lib/logstash/inputs/tcp.rb#L168 it will for example remove all CR/LF from the input stream. So if you have ever a CR/LF in one of your Proto messages...

@mjsax KSQL could just add another child to the source Node. Highly recommend not fixing in streams but have KSQL reuse the Kstreamsource instead of re-registering. How would that fix...