Versions Compared

Key

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

...

There is a case where an application tries to send a RENEW acknowledgement to an old broker which does not support the new type. To remedy this, we will also update the ShareConsumer.acknowledge(ConsumerRecord, AcknowledgeType) to throw an IllegalArgumentException. This on the next call to poll/commitSync/commitAsync, the share consumer will verify if the ack type is supported and notify the application using the appropriate callback handler. The exception could be UnsupportedVersionException. This will be handled completely on the client side where the share consumer will use the RPC API version to determine acknowledgement type validity.

...