richard-axual opened a new pull request #11535: URL: https://github.com/apache/kafka/pull/11535
Kafka Streams decodes the Offset Metadata to extract timestamps. If this metadata is not in Base64 the application fails, with no way to recover except creating a new custom offset commit. The change is to catch the IllegalArgumentException that the Base64 Decoder throws, log that an exception occurred and return the UNKNOWN value instead. As this is a smaller change I've only updated the decode Timestamp unit tests to test this scenario. This is my first contribution, so I probably need to take some more actions to get this accepted, any help is appreciated. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
