Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-7480

GlobalThread should honor custom auto.offset.reset policy

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: streams
    • Labels:

      Description

      With KAFKA-6121 we improved Kafka Streams resilience and correctness with regard to consumer auto.offset.reset and state cleanup.

      Back than, we decided to let GlobalStreamThread die and not handle InvalidOffsetException during regular processing, because this error indicates a fatal issue and the user should be notified about it. However, as reported on the user mailing list, the only thing a user can do is, to restart the application (and investigate the root cause). During restart, the state will be cleaned up and bootstrapped correctly.

      Thus, we might want to allow users to specify a more resilient configuration for this case and log an ERROR message if the error occurs. To ensure consistency, we might not allow to set reset policy "latest" though (need discussion)? By default, we can still keep "none" and fail.

      Note: `Topology.addGlobalStore` does not allow to set a reset policy. Thus, this might require a KIP to extend `Topology.addGlobalStore` accordingly.

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              mjsax Matthias J. Sax
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated: