RabbitMQ vs Kafka comparison - Interactive Practice

Practice - 5 Tasks

1fill in blank

easy

Complete the code to declare a RabbitMQ queue named 'task_queue'.

RabbitMQ

channel.queue_declare(queue='[1]')

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

Arouting_key

Bexchange

Ctopic

Dtask_queue

Attempts:

3 left

💡 Hint

Common Mistakes

Using exchange or routing_key instead of queue name.

The queue name must be 'task_queue' to declare the correct queue.

2fill in blank

medium

Complete the code to publish a message to a Kafka topic named 'logs'.

RabbitMQ

producer.send('[1]', value=b'Hello Kafka')

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

Alogs

Bqueue

Cexchange

Drouting_key

Attempts:

3 left

💡 Hint

Common Mistakes

Using RabbitMQ terms like queue or exchange in Kafka code.

Kafka uses topics to organize messages. The topic name here is 'logs'.

3fill in blank

hard

Fix the error in the RabbitMQ consumer code to acknowledge messages manually.

RabbitMQ

channel.basic_consume(queue='task_queue', on_message_callback=callback, auto_ack=[1])

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

AFalse

BNone

CTrue

Dauto

Attempts:

3 left

💡 Hint

Common Mistakes

Setting auto_ack to True disables manual acknowledgments.

Setting auto_ack to False means the consumer must manually acknowledge messages.

4fill in blank

hard

Fill both blanks to create a Kafka consumer that subscribes to 'metrics' and starts polling.

RabbitMQ

consumer = KafkaConsumer('[1]')
message = consumer.[2]()

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

Ametrics

Bpoll

Csubscribe

Dconsume

Attempts:

3 left

💡 Hint

Common Mistakes

Using subscribe() method incorrectly or wrong topic name.

The consumer subscribes to the 'metrics' topic and polls messages using the poll() method.

5fill in blank

hard

Fill all three blanks to create a RabbitMQ message publisher with exchange type 'direct' and routing key 'info'.

RabbitMQ

channel.exchange_declare(exchange='[1]', exchange_type='[2]')
channel.basic_publish(exchange='[1]', routing_key='[3]', body='Hello World')

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

Alogs

Bdirect

Cinfo

Dtopic

Attempts:

3 left

💡 Hint

Common Mistakes

Using wrong exchange type or mismatched routing key.

The exchange is named 'logs' with type 'direct'. The routing key 'info' directs the message.