Topic configuration in Kafka - Interactive Code Practice

Practice - 5 Tasks

1fill in blank

easy

Complete the code to create a Kafka topic with 3 partitions.

Kafka

bin/kafka-topics.sh --create --topic my-topic --partitions [1] --bootstrap-server localhost:9092

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

A5

B1

C0

D3

Attempts:

3 left

💡 Hint

Common Mistakes

Using 0 partitions which is invalid.

Using a string instead of a number.

The --partitions option sets the number of partitions for the topic. Here, 3 partitions are specified.

2fill in blank

medium

Complete the code to set the replication factor to 2 when creating a Kafka topic.

Kafka

bin/kafka-topics.sh --create --topic my-topic --replication-factor [1] --bootstrap-server localhost:9092

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

A3

B2

C1

D0

Attempts:

3 left

💡 Hint

Common Mistakes

Setting replication factor to 0 which is invalid.

Setting replication factor higher than available brokers.

The --replication-factor option sets how many copies of the data are kept. Here, 2 copies are specified.

3fill in blank

hard

Fix the error in the command to set the cleanup policy to 'compact' for a Kafka topic.

Kafka

bin/kafka-configs.sh --alter --entity-type topics --entity-name my-topic --add-config cleanup.policy=[1] --bootstrap-server localhost:9092

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

Adelete

Bcompact,delete

Ccompact

Dcompress

Attempts:

3 left

💡 Hint

Common Mistakes

Using an invalid cleanup policy value.

Using 'compress' which is not a valid cleanup policy.

The cleanup.policy can be set to compact to enable log compaction on the topic.

4fill in blank

hard

Fill both blanks to create a topic with 4 partitions and a retention time of 1 day (86400000 ms).

Kafka

bin/kafka-topics.sh --create --topic my-topic --partitions [1] --config retention.ms=[2] --bootstrap-server localhost:9092

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

A4

B86400000

C3600000

D2

Attempts:

3 left

💡 Hint

Common Mistakes

Confusing retention time units.

Setting partitions to an invalid number.

The --partitions option sets 4 partitions. The retention.ms config sets retention time in milliseconds; 86400000 ms equals 1 day.

5fill in blank

hard

Fill all three blanks to create a topic named 'logs' with 6 partitions, replication factor 3, and cleanup policy 'delete'.

Kafka

bin/kafka-topics.sh --create --topic logs --partitions [1] --replication-factor [2] --config cleanup.policy=[3] --bootstrap-server localhost:9092

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

A3

B6

Cdelete

Dcompact

Attempts:

3 left

💡 Hint

Common Mistakes

Mixing up partitions and replication factor values.

Using invalid cleanup policy values.

The topic is created with 6 partitions, replication factor 3, and cleanup policy set to 'delete' to remove old data.