-BEGIN PGP SIGNED MESSAGE-
Hash: SHA512
I cannot completely follow what this feature is supposed to do. Can
you maybe describe you scenario with some example input data and
expected behavior in more detail?
- -Matthias
On 11/12/16 3:12 PM, Nick DeCoursin wrote:
> Feature proposal:
>
>
-BEGIN PGP SIGNED MESSAGE-
Hash: SHA512
> Note both ksteam and ktable source are from same topic. When
> executed (see code below), the joined ktable is 'behind' the
> kstream so lookup will sometimes fail. I think the ktable is just
> slower to process because it is doing more processi
Hi,
I am getting below warning message:
WARN kafka.server.KafkaServer - [Kafka Server 1], Retrying
controlled shutdown after the previous attempt failed...
WARN kafka.server.KafkaServer - [Kafka Server 1], Proceeding to do
an unclean shutdown as all the controlled shutdown attempts failed
IN
Feature proposal:
KTable when(predicate);
I have a KTable, but I'd only like to trigger a stream processor on certain
conditions. I'd like to do something like:
myKtable.when(
(key, value) -> some predicate
);
The result is just the same KTable. The predicate function is called on any
new
