kstream

kstream copied to clipboard

for loop has _config_ variable declared once but it is used more than once by reference. this causes the last value of all _configEntries_ to be used for all of...

nirfri

Global Table sync gets stuck if the last message is a control record(https://kafka.apache.org/documentation/#controlbatch)

gmbyapa

next return fixed in filter

1

Fix issue #21

senpathi

When there is a filter process and filter func returns false, then other child streams in the parent's stream not running because filter process returns next = false.

senpathi

cannot send message on (github.com/tryfix/kstream/producer.(*saramaProducer).Produce) due to kafka server: The request attempted to perform an operation on an invalid topic. on func github.com/gorilla/mux.(*Router).ServeHTTP

wishperera