ProducerRecord specifies a key/value pair to be sent to Kafka cluster to create a record with the partition using the following syntax -
public ProducerRecord (string topic, int partition, k key, v value)
Here, topic corresponds to the topic name defined by the user
Partition refers to partition count
Key is the value included in the record
Value refers to record contents
Here’s the syntax used to create a record with key, value pairs and without partition using the ProducerRecord class constructor -
public ProducerRecord (string topic, k key, v value)
Here’s the syntax used to create a record without partition and key -
public ProducerRecord (string topic, v value)
Some examples of ProducerRecord class methods are listed below -
- public string topic()
To add a topic to the record
- partition()
Add partition count to the record
- public K key()
The key value to be included in the record. In case of no key, NULL will be returned here which means that the data is sent without the key.
- public V value()
To record contents
