kafka-streams

kafka-streams copied to clipboard

I was going through the documentation and the examples tying to understand how to join two streams by key, or a stream and a table. The idea is that given...

lloiacono

Message Headers

2

Hello all, Is there a way to propagate and/or transform message headers using the KStream API? Thank you

stavros-wb

I would like to read KStream or KTable in batches. How it could be done?

mamogaaa

I need to return my value JSON as an OBJECT without tampering, if I use **send**, I have to stringify and it inserts the value as a string... If I...

MinallW

Updated types from unknown and removing unused variables

7

* Starting to move types across. * Tests will fail due to types not being correct in `node-sinek` Which leads me to the next part of updating `node-sinek` in kafka-streams....

rob3000

Skip key only if it's not buffer

2

polovi

Ignoring element in stream

1

how i prevent sending empty string '' if number is odd, like prevent .to from running and just move to next stream data? if defeats the purpose of multiple branching...

hamid512

Hi there, I used the window.js example in order to create a `kstream window` and I have a few questions regarding the way this is intended to work: 1. When...

Radu1990

Questions about KTables

5

Hi, I'm very new to Kafka and streaming platforms so I apologize if my understanding is not correct. One use-case I see for using KTables is to handle external queries...

jonathan-roy

no .mapWrapKafkaKey() & .wrapAsKafkaKey()

4

Hi, To add Key on produce messages after .filter() was not possible for me, always null even if the consuming message got a value. Is There another way to push...

cnwme