Hello everyone,
Thanks for all your feedback for this KIP!
I think that the key to choosing proper names for this API is understanding
the terms used inside the StoreChangelogReader. Currently, this class has
two possible states: ACTIVE_RESTORING and STANDBY_UPDATING. In my opinion,
using Standby
to summarize what everyone's said in TLDR format:
> >>>>
> >>>> 1. Rename `onStandbyUpdateStart()` -> `onUpdateStart()`, and do
> >>> similarly
> >>>> for the other methods.
> >>>> 2. Keep `SuspendReason.PROMOTED` and `SuspendR
if
> >>>>>> a KIP is needed for it. Maybe, endOffsets() guarantees to return the
> >>>>>> freshest end offsets possible, which would not be satisfied with the
> >>>>>> modification.
> >>>>>>
> >>>>>> Regarding the naming,
Eduwer Camacaro created KAFKA-17098:
---
Summary: Error Opening RocksDBStore
Key: KAFKA-17098
URL: https://issues.apache.org/jira/browse/KAFKA-17098
Project: Kafka
Issue Type: Bug
Eduwer Camacaro created KAFKA-18032:
---
Summary: ProducerFencedExceptions should wipe out the state store
only for the tasks that are related to the failed transaction
Key: KAFKA-18032
URL: https
