new sync/async producer to topic with option(requiredAcks,retryMaxCn,partitioning,compressions,TLS...etc).

kafka brokers ip:port,ip:port.

The client ID sent with every request to the brokers.

key partition: partition(manual),hash,random - manual partitioning if a partition number is provided - hash partitioning by msg key - random partitioning otherwise.

RequiredAcks is used in Produce Requests to tell the broker how many replica acknowledgements it must see before responding.

The duration the producer will wait to receive -required-acks.

kafka version support kafka min version 0.8.2.0.