Producer API basics in Kafka - Interactive Code Practice

Practice - 5 Tasks

1fill in blank

easy

Complete the code to create a Kafka producer.

Kafka

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", [1]);
KafkaProducer<String, String> producer = new KafkaProducer<>(props);

Drag options to blanks, or click blank then click option'

A"org.apache.kafka.common.serialization.StringSerializer"

B"org.apache.kafka.common.serialization.IntegerSerializer"

C"org.apache.kafka.common.serialization.ByteArraySerializer"

D"org.apache.kafka.common.serialization.LongSerializer"

Attempts:

3 left

💡 Hint

Common Mistakes

Using IntegerSerializer when sending strings.

Forgetting to set value.serializer property.

The value.serializer must be set to StringSerializer to send string messages.

2fill in blank

medium

Complete the code to send a message to topic "my-topic".

Kafka

ProducerRecord<String, String> record = new ProducerRecord<>("my-topic", [1], "Hello Kafka");
producer.send(record);

Drag options to blanks, or click blank then click option'

A"key1"

Bnull

C"value1"

D"my-key"

Attempts:

3 left

💡 Hint

Common Mistakes

Using a value instead of a key in the ProducerRecord constructor.

Passing an undefined variable as key.

You can send a message without a key by passing null.

3fill in blank

hard

Fix the error in the code to properly close the producer.

Kafka

producer.[1]();

Drag options to blanks, or click blank then click option'

Aclose

Bstop

Cflush

Dshutdown

Attempts:

3 left

💡 Hint

Common Mistakes

Using flush() instead of close(), which does not close the producer.

Using shutdown() or stop(), which are not valid methods.

The close() method properly closes the producer and releases resources.

4fill in blank

hard

Fill both blanks to create a ProducerRecord with a key and value.

Kafka

ProducerRecord<String, String> record = new ProducerRecord<>("my-topic", [1], [2]);

Drag options to blanks, or click blank then click option'

A"user1"

B"Hello"

C"World"

D"key1"

Attempts:

3 left

💡 Hint

Common Mistakes

Swapping key and value positions.

Using invalid strings for key or value.

The first blank is the key "user1", the second blank is the value "World".

5fill in blank

hard

Fill all three blanks to send a message and flush the producer.

Kafka

ProducerRecord<String, String> record = new ProducerRecord<>("my-topic", [1], [2]);
producer.send(record);
producer.[3]();

Drag options to blanks, or click blank then click option'

A"key123"

B"Kafka Rocks"

Cflush

Dclose

Attempts:

3 left

💡 Hint

Common Mistakes

Using close() instead of flush() before sending more messages.

Mixing up key and value positions.

The key is "key123", the value is "Kafka Rocks", and flush() sends all buffered records.