Kafka

ProducerRecord API

ProducerRecord API

 

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 


 

Top course recommendations for you

    Joins in SQL
    2 hrs
    Beginner
    10.9K+ Learners
    4.4  (720)
    Introduction to Firewall
    1 hrs
    Beginner
    26.8K+ Learners
    4.53  (2130)
    Design Thinking for Beginners
    1 hrs
    Beginner
    15.8K+ Learners
    4.38  (2045)
    Database Management System
    1 hrs
    Beginner
    43.2K+ Learners
    4.39  (6068)
    .NET Fundamentals
    2 hrs
    Beginner
    24.6K+ Learners
    4.42  (2106)
    Python Practice Codes
    1 hrs
    Beginner
    8.8K+ Learners
    4.4  (484)
    VLOOKUP in Excel
    1 hrs
    Beginner
    46.6K+ Learners
    4.57  (3855)