You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "John Roesler (Jira)" <ji...@apache.org> on 2021/07/21 14:43:00 UTC
[jira] [Created] (KAFKA-13117) After processors, migrate
TupleForwarder and CacheFlushListener
John Roesler created KAFKA-13117:
------------------------------------
Summary: After processors, migrate TupleForwarder and CacheFlushListener
Key: KAFKA-13117
URL: https://issues.apache.org/jira/browse/KAFKA-13117
Project: Kafka
Issue Type: Sub-task
Reporter: John Roesler
Currently, both of these interfaces take plain values in combination with timestamps:
CacheFlushListener:
{code:java}
void apply(K key, V newValue, V oldValue, long timestamp)
{code}
TimestampedTupleForwarder
{code:java}
void maybeForward(K key,
V newValue,
V oldValue,
long timestamp){code}
These are internally translated to the new PAPI, but after the processors are migrated, there won't be a need to have this translation. We should update both of these APIs to just accept {{Record<K, Change<V>>}}.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)