Versions Compared

Key

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

Table of Contents

Status

Current state: Under Discussion Accepted

Discussion thread: here [Change the link from the KIP proposal email archive to your own email thread] 

Vote thread: here 

JIRA:

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-10790

...

If the `Producer` detects that the `flush` method is invoked within the callback of the `close` method, throw a `KafkaException`.

This approach would require modifying org.apache.kafka.clients.producer.Producer#flush  to include KafkaException .

...