Partitioner behavior in Kafka - Interactive Code Practice

Practice - 5 Tasks

1fill in blank

easy

Complete the code to specify the partition key for a Kafka message.

Kafka

producer.send(topic, key=[1], value="message")

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

A"user123"

B123

CNone

Dvalue

Attempts:

3 left

💡 Hint

Common Mistakes

Using an integer as key without serialization

Passing None as key when a key is expected

The partition key is usually a string or bytes that Kafka uses to decide the partition. Here, a string key "user123" is correct.

2fill in blank

medium

Complete the code to create a custom partitioner class in Kafka.

Kafka

class CustomPartitioner:
    def partition(self, key, partitions, [1]):
        return hash(key) % len(partitions)

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

Aconfig

Bvalue

Ctopic

Dmetadata

Attempts:

3 left

💡 Hint

Common Mistakes

Using wrong parameter names

Ignoring the metadata parameter

The partition method usually receives key, partitions, and metadata. Metadata provides extra info about the message.

3fill in blank

hard

Fix the error in the partitioner code to correctly compute the partition index.

Kafka

def partition(key, partitions):
    index = hash(key) [1] len(partitions)
    return index

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

A+

B%

C-

D//

Attempts:

3 left

💡 Hint

Common Mistakes

Using division or subtraction instead of modulo

Returning a value outside partition range

The modulo operator % is used to ensure the partition index is within the range of available partitions.

4fill in blank

hard

Fill both blanks to create a dictionary comprehension that maps partitions to message counts greater than 10.

Kafka

partition_counts = {p: counts[p] [1] p [2] counts if counts[p] > 10}

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

Afor

Bin

Cif

Delse

Attempts:

3 left

💡 Hint

Common Mistakes

Using 'if' or 'else' in place of 'for' or 'in'

Incorrect comprehension syntax

The syntax for dictionary comprehension is: {key: value for key in iterable if condition}. Here, 'for' and 'in' are needed.

5fill in blank

hard

Fill all three blanks to create a dictionary comprehension that maps uppercase keys to values greater than 5.

Kafka

filtered = [1]: [2] for [3] in data if data[[3]] > 5

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

Ak.upper()

Bdata[k]

Ck

Dv

Attempts:

3 left

💡 Hint

Common Mistakes

Using values instead of keys in iteration

Not transforming keys to uppercase

Incorrect comprehension syntax

The comprehension maps uppercase keys (k.upper()) to their values (data[k]) for keys k in data where value > 5.