no `transform()`
because keying must be preserved -- if you want to change the keying
you need to use `KTable#groupBy()` (data needs to be repartitioned if
you change the key).
HTH.
-Matthias
On 1/12/24 11:47 AM, Igor Maznitsa wrote:
Hello
Is there any way in Kafka Streams API to define p
Hello
Is there any way in Kafka Streams API to define processors for KTable
and KGroupedStream like KStream#transform? How to provide a custom
processor for KTable or KGroupedStream which could for instance provide
way to not downstream selected events?
--
Igor Maznitsa
email: rrg4
he standby
hasn't caught up yet?
Best,
Bruno
On 9/6/23 8:32 AM, Igor Maznitsa wrote:
Hello
1. I am starting two Kafka Streams applications worked in same group
with num.standby.replicas=1
2. Application A has active TimeWindow data store and application B
has the standby version of the
active node. Is there any restriction and such
mechanism works only for KeyValue stores?
--
Igor Maznitsa
Maybe somebody else
can help out?
-Matthias
On 3/9/21 3:15 AM, Igor Maznitsa wrote:
thanks for advice!
does standby.replicas play role during search of HostInfo through
InteractiveQueryService#getHostInfo ? will it return the local host info
(instead of remote instance) if it contains local
control it:
By default only active stores are queried. If you want to query standby
stores, you can use `StoreQueryParameters#enableStaleStores()`
-Matthias
On 3/9/21 1:30 AM, Igor Maznitsa wrote:
Hello
If I have started two KafkaStream application instances, and they have
parameter
Hello
If I have started two KafkaStream application instances, and they have
parameter 'num.standby.replicas=1'. It means that each instance has
shadow copy of local state stores, so the question:
How InteractionQuery behaves in activated stand by replica case? does it
aware about replicated
