Bruno Cadonna
Bruno Cadonna
The state updater exposes tasks that are in restoration to the stream thread. To ensure that the stream thread only accesses the tasks to read from the tasks without modifying...
Currently, in the async Kafka consumer updates to the group metadata that are received by the heartbeat are propagated to the application thread in form of an event. Group metadata...
*More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* *Summary of testing...
Owner: **Is your feature request related to a problem? Please describe.** In Kafka Streams, we have a Kafka Improvements Proposal (KIP) under discussion that wants to add [transactionality to RocksDB-backed...
*More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* *Summary of testing...