Versions Compared

Key

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

...

The last property "request.required.acks" tells Kafka that you want your Producer to require an acknowledgement from the Broker that the message was received. Without this setting the Producer will 'fire and forget' possibly leading to data loss. Additional information can be found here

Next you define the Producer object itself:

...