Why schema management prevents data issues in Kafka - Test Your Understanding

Practice - 5 Tasks

1fill in blank

easy

Complete the code to define a schema for a Kafka message.

Kafka

schema = {"type": [1], "fields": [{"name": "id", "type": "int"}]}

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

A"record"

B"string"

C"array"

D"map"

Attempts:

3 left

💡 Hint

Common Mistakes

Using 'string' or 'array' instead of 'record' causes schema errors.

The schema type for Kafka messages is usually a record which defines a structured object.

2fill in blank

medium

Complete the code to register the schema with the Schema Registry.

Kafka

schema_registry_client.[1](schema_str)

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

Aregister_schema

Bget_schema

Cdelete_schema

Dupdate_schema

Attempts:

3 left

💡 Hint

Common Mistakes

Using 'get_schema' does not add a new schema.

To add a new schema, you use register_schema method in the Schema Registry client.

3fill in blank

hard

Fix the error in the code to validate a message against the schema.

Kafka

is_valid = schema_validator.[1](message)

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

Averify_message

Bcheck_schema

Cvalidate_message

Dvalidate

Attempts:

3 left

💡 Hint

Common Mistakes

Using 'validate_message' causes method not found errors.

The correct method to validate data against a schema is validate.

4fill in blank

hard

Fill both blanks to create a schema that requires a string field 'name' and an integer field 'age'.

Kafka

schema = {"type": [1], "fields": [{"name": "name", "type": [2], {"name": "age", "type": "int"}]}

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

A"record"

B"string"

C"int"

D"array"

Attempts:

3 left

💡 Hint

Common Mistakes

Using 'array' or 'int' for the 'name' field causes validation errors.

The schema type is a record and the 'name' field type is string.

5fill in blank

hard

Fill all three blanks to create a schema with a required string 'email', an optional int 'phone', and a default value for 'phone'.

Kafka

schema = {"type": [1], "fields": [{"name": "email", "type": [2], {"name": "phone", "type": ["null", [3]], "default": null}]}

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

A"record"

B"string"

C"int"

D"array"

Attempts:

3 left

💡 Hint

Common Mistakes

Using 'array' or wrong types causes schema validation failures.

The schema type is record, 'email' is a string, and 'phone' is an optional int with default null.

Practice

1. Why is schema management important in Kafka data pipelines?

easy

A. It encrypts data automatically for security.

B. It speeds up message delivery by skipping validation.

C. It ensures data formats are consistent between producers and consumers.

D. It stores messages permanently without deletion.

Solution

1. Step 1: Understand schema management role

   Schema management defines a clear data format that all producers and consumers agree on.

2. Step 2: Identify the benefit in Kafka pipelines

   This agreement prevents data format mismatches and errors during data exchange.

3. Final Answer:

   It ensures data formats are consistent between producers and consumers. -> Option C

4. Quick Check:

   Schema management = data consistency [OK]

Hint: Schema keeps data format consistent across systems [OK]

Common Mistakes:

• Thinking schema speeds delivery by skipping checks
• Confusing schema with encryption
• Assuming schema stores data permanently

2. Which of the following is the correct way to register a schema in Kafka Schema Registry?

easy

A. PUT /topics/{topic}/schemas with schema JSON in URL

B. GET /schemas/{schemaId} with schema JSON in body

C. DELETE /subjects/{subject} with schema JSON in body

D. POST /subjects/{subject}/versions with schema JSON in body

Solution

1. Step 1: Recall Schema Registry API basics

   To add a new schema version, you POST the schema JSON to /subjects/{subject}/versions.

2. Step 2: Check other options for correctness

   GET retrieves schemas, DELETE removes subjects, PUT with schema in URL is invalid.

3. Final Answer:

   POST /subjects/{subject}/versions with schema JSON in body -> Option D

4. Quick Check:

   Register schema = POST to versions endpoint [OK]

Hint: Register schema by POSTing JSON to subject versions [OK]

Common Mistakes:

• Using GET or DELETE to register schemas
• Putting schema JSON in URL instead of body
• Confusing topic and subject endpoints

3. Given this Kafka producer code snippet using Avro schema validation, what happens if the producer sends data that does not match the registered schema?

producer.send({ key: 'user1', value: { name: 'Alice', age: 'twenty' } });

Assuming the schema expects age as an integer.

medium

A. The message is rejected and an error is thrown before sending.

B. The message is sent successfully with age as a string.

C. The message is sent but the consumer will fail to deserialize.

D. The message is silently corrected to convert age to integer.

Solution

1. Step 1: Understand schema validation on producer side

   The producer validates data against the schema before sending; mismatched types cause errors.

2. Step 2: Analyze the given data mismatch

   Age is given as a string 'twenty' but schema expects integer, so validation fails and sending is blocked.

3. Final Answer:

   The message is rejected and an error is thrown before sending. -> Option A

4. Quick Check:

   Schema validation blocks invalid data [OK]

Hint: Producer blocks sending if data mismatches schema [OK]

Common Mistakes:

• Assuming message sends with wrong data type
• Thinking consumer handles invalid data silently
• Believing schema auto-corrects data types

4. You have a Kafka consumer that fails to deserialize messages due to schema mismatch errors. What is the most likely cause?

medium

A. The Kafka broker is down and not forwarding messages.

B. The consumer is using an outdated schema version incompatible with the producer's data.

C. The consumer group ID is missing in the consumer configuration.

D. The producer is sending messages without keys.

Solution

1. Step 1: Identify cause of deserialization errors

   Deserialization errors often happen when consumer schema does not match the data format sent by producer.

2. Step 2: Check other options for relevance

   Broker down or missing group ID cause connection or consumption issues, not schema errors; keys are optional.

3. Final Answer:

   The consumer is using an outdated schema version incompatible with the producer's data. -> Option B

4. Quick Check:

   Schema mismatch = outdated consumer schema [OK]

Hint: Check consumer schema version matches producer's [OK]

Common Mistakes:

• Blaming broker or group ID for schema errors
• Assuming keys are required for deserialization
• Ignoring schema version compatibility

5. You want to evolve your Kafka message schema by adding a new optional field without breaking existing consumers. Which schema management practice helps achieve this safely?

hard

A. Use backward-compatible schema changes by adding optional fields with default values.

B. Delete the old schema and register a completely new schema with all fields.

C. Change the data type of an existing required field to a different type.

D. Remove fields from the schema to simplify messages.

Solution

1. Step 1: Understand schema evolution compatibility

   Backward compatibility means new schemas can read old data and old consumers can read new data safely.

2. Step 2: Identify safe schema changes

   Adding optional fields with defaults is backward compatible; deleting or changing required fields breaks compatibility.

3. Final Answer:

   Use backward-compatible schema changes by adding optional fields with default values. -> Option A

4. Quick Check:

   Safe schema evolution = add optional fields [OK]

Hint: Add optional fields with defaults for safe schema updates [OK]

Common Mistakes:

• Replacing schemas instead of evolving them
• Changing required field types
• Removing fields breaks compatibility