KSTREAM basics

2019-10-03 Thread David O'Connor
I apologise if this query is trivial, but if I set up a Kafka stream to read from a KTABLE, will the stream contain both of the following? (I) all rows in the table that match the selection criteria when the stream is created, (2) any new rows written to the table while the stream is running.

Using the current date/time in a KSQL query

2019-10-02 Thread David O'Connor
I am planning to have a producer writing payment messages to a Kafka topic. One attribute of the messages would be process date, which could be in the future, i.e. the payment is not to be sent for collection until this date. How can I configure Kafka so that a stream will only contain the

Querying a change log

2019-08-15 Thread David O'Connor
Please forgive this question if it turns out to be trivial but I am new to Kafka and am evaluating it for use as the backbone of our new payments application. I envisage a 'payment' topic being fed by a producer for each payment channel, each payment being represented in JSON with an attribute