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

Consumer should include partition in exceptions raised during record parsing/validation

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: In Progress
    • Minor
    • Resolution: Unresolved
    • None
    • None
    • consumer

    Description

      When we encounter an exception when validating a fetched record or when deserializing it, we raise it to the user and keep the consumer's current position at the offset of the failed record. The expectation is that the user will either propagate the exception and shutdown or seek past the failed record. However, in the latter case, there is no way for the user to know which topic partition had the failed record. We should consider exposing an exception type to expose this information which users can catch.
       

       

      Attachments

        Issue Links

          Activity

            People

              sarwarb Sarwar Bhuiyan
              hachikuji Jason Gustafson
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

                Created:
                Updated: