Why distributed architecture ensures reliability in Kafka - Test Your Understanding

Practice - 5 Tasks

1fill in blank

easy

Complete the code to create a Kafka producer that sends messages to a topic.

Kafka

producer = KafkaProducer(bootstrap_servers='localhost:9092')
producer.send('[1]', b'Hello Kafka')
producer.flush()

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

Alocalhost

Bmessage_topic

Ckafka_server

Dmy_topic

Attempts:

3 left

💡 Hint

Common Mistakes

Using server names instead of topic names in the send method.

The send method requires the topic name as the first argument. Here, my_topic is the correct topic name.

2fill in blank

medium

Complete the code to consume messages from a Kafka topic.

Kafka

consumer = KafkaConsumer('[1]', bootstrap_servers='localhost:9092')
for message in consumer:
    print(message.value)

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

Aserver

Bmy_topic

Cconsumer_group

Dlocalhost

Attempts:

3 left

💡 Hint

Common Mistakes

Using server or group names instead of topic names.

The consumer needs the topic name to subscribe to messages. my_topic is the correct topic name.

3fill in blank

hard

Fix the error in the code to ensure the Kafka consumer joins the correct consumer group.

Kafka

consumer = KafkaConsumer('my_topic', bootstrap_servers='localhost:9092', group_id=[1])
for message in consumer:
    print(message.value)

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

A'my_group'

B123

CNone

Dlocalhost

Attempts:

3 left

💡 Hint

Common Mistakes

Passing None or numbers instead of a string for group_id.

The group_id must be a string identifying the consumer group, like 'my_group'.

4fill in blank

hard

Fill both blanks to create a Kafka topic with 3 partitions and a replication factor of 2.

Kafka

topic_config = NewTopic(name='my_topic', num_partitions=[1], replication_factor=[2])

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

A3

B1

C2

D5

Attempts:

3 left

💡 Hint

Common Mistakes

Using replication factor 1 which does not provide redundancy.

The topic needs 3 partitions and a replication factor of 2 to ensure reliability through distribution.

5fill in blank

hard

Fill all three blanks to configure a Kafka producer with retries, acks, and a timeout for reliability.

Kafka

producer = KafkaProducer(bootstrap_servers='localhost:9092', retries=[1], acks=[2], request_timeout_ms=[3])

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

A0

B'all'

C30000

D5

Attempts:

3 left

💡 Hint

Common Mistakes

Setting retries to 0 disables retrying.

Using acks=1 or acks=0 reduces reliability.

Retries set to 5 allow resending messages on failure, acks='all' waits for all replicas to confirm, and request_timeout_ms=30000 sets a 30-second timeout for requests.