[Solved] What is wrong with this Kafka producer code snippet?Properties props = new Properties(); props.put("bootstrap.servers", "localhost:9092"); props.put("key.serializer", "org.apache.kafka.common.... | Kafka

Kafka - with Java/Python

What is wrong with this Kafka producer code snippet?

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
KafkaProducer producer = new KafkaProducer<>(props);
ProducerRecord record = new ProducerRecord<>("topic", null, "value");
producer.send(record);
producer.close();

ASending a record with null key is allowed and no error occurs

BNull key causes NullPointerException

CProducerRecord constructor is incorrect

DProducer must not be closed immediately after send

Step-by-Step Solution

Solution:

Step 1: Check if null keys are allowed
Kafka allows null keys in ProducerRecord; it means no key is assigned.
Step 2: Verify other options
Constructor is correct; closing producer after send is valid (send is async but close flushes).
Final Answer:
Sending a record with null key is allowed and no error occurs -> Option A
Quick Check:
Null keys allowed in ProducerRecord [OK]

Quick Trick: Null keys are valid in Kafka producer records [OK]

Common Mistakes:

MISTAKES

Assuming null key causes exceptions
Confusing constructor parameters
Thinking close() must wait for send callback

Master "with Java/Python" in Kafka

9 interactive learning modes - each teaches the same concept differently

Learn Why Deep Visual Try Challenge Project Recall Time

More Kafka Quizzes

What is wrong with this Kafka producer code snippet?

Step 1: Check if null keys are allowed

Step 2: Verify other options

Final Answer:

Quick Check:

Want More Practice?