Why topics organize messages in Kafka - Challenge Your Understanding

Challenge - 5 Problems

🧠 Conceptual

intermediate

Why does Kafka use topics to organize messages?

Kafka organizes messages into topics. What is the main reason for this design?

A To encrypt messages automatically for security

B To store messages in a random order for faster retrieval

C To limit the number of messages a producer can send

D To group related messages so consumers can subscribe to specific streams of data

💡 Hint

Think about how consumers get messages they want.

Topics group related messages so consumers can subscribe to only the data they need, making message handling efficient and organized.

❓ Predict Output

intermediate

What is the output when subscribing to a Kafka topic?

Given a Kafka topic named 'orders' with messages: 'order1', 'order2', 'order3', what will a consumer receive when subscribed to this topic?

A The consumer receives only the last message: 'order3'

B The consumer receives all messages: 'order1', 'order2', 'order3' in order

C The consumer receives messages in random order

D The consumer receives no messages until a new one is produced

💡 Hint

Think about how Kafka delivers messages from a topic.

Consumers subscribed to a topic receive all messages in the order they were produced, ensuring no message is missed.

🔧 Debug

advanced

Why does this Kafka consumer miss some messages?

Consider this Kafka consumer code snippet that subscribes to a topic but misses some messages:

consumer.subscribe(['sales'])
consumer.poll(0)
consumer.close()

What is the likely reason?

A The consumer polls with zero timeout and closes immediately, not waiting for messages

B The topic name 'sales' is incorrect and does not exist

C The consumer group ID is missing causing no messages to be assigned

D Kafka topics do not support polling messages

💡 Hint

Think about how polling works in Kafka consumers.

Polling with zero timeout returns immediately without waiting for messages. Closing the consumer right after means no messages are processed.

📝 Syntax

advanced

Identify the syntax error in Kafka topic subscription code

Which option contains a syntax error in subscribing a Kafka consumer to a topic?

Kafka

consumer.subscribe('payments')

A consumer.subscribe('payments')

B consumer.subscribe({'payments'})

C consumer.subscribe(['payments'])

D consumer.subscribe(('payments'))

💡 Hint

Check the expected argument type for subscribe method.

The subscribe method expects a list of topics, not a single string. Passing a string causes an error.

🚀 Application

expert

How do Kafka topics help scale message processing?

Kafka topics are divided into partitions. How does this help scale message processing?

A Partitions limit the number of messages stored in a topic

B Partitions encrypt messages to improve security

C Partitions allow multiple consumers to read from the same topic in parallel, increasing throughput

D Partitions automatically delete old messages to save space

💡 Hint

Think about how dividing work helps many workers process faster.

Partitions split a topic into parts so multiple consumers can read different partitions at the same time, making processing faster and scalable.