Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  1. Deprecate the below two configs in org.apache.kafka.streams.StreamsConfig
    1. default.deserialization.exception.handler
    2. default.production.exception.handler
  2. Configs to be added to org.apache.kafka.streams.StreamsConfig
    1. deserialization.exception.handler
    2. production.exception.handler
  3. Define 
  4. Rename the below template configs
    1. DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_DOC to DESERIALIZATION_EXCEPTION_HANDLER_CLASS_DOC
    2. DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_DOC to PRODUCTION_EXCEPTION_HANDLER_CLASS_DOC
  5. Update all the relevant dependency classes, so that both old and new configs are supported
    1. TopologyConfig 
    2. RecordDeserializer
  6. Mark the tests depending on old configs as deprecated and introduce new tests
    1. InternalTopologyBuilderTest
    2. StreamTaskTest
    3. StreamThreadTest

Compatibility, Deprecation, and Migration Plan

...

Describe in few sentences how the KIP will be tested. We are mostly interested in system tests (since unit-tests are specific to implementation details). How will we know that the implementation works as expected? How will we know nothing broke?

The test plan for this change includes the following making sure functionality remains the same for old and new configs.

  • Deprecate tests which are using old configs
  • Add new tests for newly introduced configs

Rejected Alternatives

None