DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
- Deprecate the below two configs in org.apache.kafka.streams.StreamsConfig
- default.deserialization.exception.handler
- default.production.exception.handler
- Configs to be added to org.apache.kafka.streams.StreamsConfig
- deserialization.exception.handler
- production.exception.handler
- Define
- Rename the below template configs
- DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_DOC to DESERIALIZATION_EXCEPTION_HANDLER_CLASS_DOC
- DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_DOC to PRODUCTION_EXCEPTION_HANDLER_CLASS_DOC
- Update all the relevant dependency classes, so that both old and new configs are supported
- TopologyConfig Update ConfigDef in TopologyConfig and code blocks like isTopologyOverride(DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIG, topologyOverrides)) with new configs, so that code behaves the same for both the old and new configs
- RecordDeserializer
- Mark the tests depending on old configs as deprecated and introduce new tests in the below
- InternalTopologyBuilderTest
- StreamTaskTest
- StreamThreadTest
Ex : code snippet change
Compatibility, Deprecation, and Migration Plan
...