Versions Compared

Key

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

...

To configure their own handler, the user must implement the above-introduced interface and add the class name in producer configuration with the key: custom.exception.handler.
More than that, we introduced two more configuration parameters as follows to handle the two exceptions without needing too to implement the interface.

  • drop.invalid.large.records with a default value of `false` for swallowing too large records.
  • retry.unknown.topic.partition with a default value of `true` that performs RETRY for `max.block.ms` encountering the UnknownTopicOrPartitionException.

...