Transform and converter chains in Kafka - Interactive Code Practice

Practice - 5 Tasks

1fill in blank

easy

Complete the code to add a simple transformation to the Kafka Connect chain.

Kafka

transforms=AddPrefix
transforms.AddPrefix.type=[1]

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

Aorg.apache.kafka.connect.transforms.InsertField$Value

Borg.apache.kafka.connect.transforms.SetSchemaMetadata

Corg.apache.kafka.connect.transforms.RegexRouter

Dorg.apache.kafka.connect.transforms.ValueToKey

Attempts:

3 left

💡 Hint

Common Mistakes

Choosing a transform that modifies message keys or values instead of topic names.

The RegexRouter transform is used to modify topic names in the chain.

2fill in blank

medium

Complete the code to configure a converter chain for JSON data.

Kafka

key.converter=org.apache.kafka.connect.json.JsonConverter
value.converter=[1]

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

Aorg.apache.kafka.connect.converters.ByteArrayConverter

Borg.apache.kafka.connect.storage.StringConverter

Corg.apache.kafka.connect.avro.AvroConverter

Dorg.apache.kafka.connect.json.JsonConverter

Attempts:

3 left

💡 Hint

Common Mistakes

Using different converters for key and value causing data format mismatch.

Both key and value converters should be set to JsonConverter for JSON data.

3fill in blank

hard

Fix the error in the transform chain configuration to correctly apply a value transformation.

Kafka

transforms=MaskField
transforms.MaskField.type=[1]

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

Aorg.apache.kafka.connect.transforms.ReplaceField$Value

Borg.apache.kafka.connect.transforms.MaskField$Value

Corg.apache.kafka.connect.transforms.MaskField$Key

Dorg.apache.kafka.connect.transforms.InsertField$Value

Attempts:

3 left

💡 Hint

Common Mistakes

Using MaskField$Key when the transformation should apply to the message value.

The MaskField$Value transform masks fields in the message value, which is the intended behavior here.

4fill in blank

hard

Fill both blanks to configure a converter chain with Avro and a transform to route topics.

Kafka

key.converter=[1]
value.converter=[2]

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

Aorg.apache.kafka.connect.json.JsonConverter

Borg.apache.kafka.connect.storage.StringConverter

Cio.confluent.connect.avro.AvroConverter

Dorg.apache.kafka.connect.converters.ByteArrayConverter

Attempts:

3 left

💡 Hint

Common Mistakes

Mixing different converters for key and value causing serialization errors.

Both key and value converters should be set to AvroConverter for Avro data format.

5fill in blank

hard

Fill all three blanks to create a transform chain that renames topics and masks a field in the value.

Kafka

transforms=RouteTopic,MaskValue
transforms.RouteTopic.type=[1]
transforms.MaskValue.type=[2]
transforms.MaskValue.fields=[3]

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

Aorg.apache.kafka.connect.transforms.RegexRouter

Borg.apache.kafka.connect.transforms.MaskField$Value

Cpassword

Dorg.apache.kafka.connect.transforms.InsertField$Value

Attempts:

3 left

💡 Hint

Common Mistakes

Confusing MaskField$Key with MaskField$Value.

Not specifying the field name to mask.

The RegexRouter transform renames topics, MaskField$Value masks fields in the value, and password is the field to mask.