Apache Kafka Kafka Connect 3

Question 1

What is the Schema Registry's role when used with Kafka Connect?

Accepted Answer

Centrally stores and validates Avro/JSON/Protobuf schemas so producers and consumers share a consistent contract

Answer

The Schema Registry stores schemas by subject so that Connect converters can serialize and deserialize messages with schema versioning and compatibility enforcement.

Question 2

What does `value.converter=io.confluent.kafka.serializers.KafkaAvroSerializer` indicate in a Connect configuration?

Accepted Answer

Record values will be serialized using Avro format against the Schema Registry

Answer

Setting the value converter to KafkaAvroSerializer tells Connect workers to serialize record values as Avro binary, registering schemas with the Schema Registry.

Question 3

Which Kafka Connect mode is most suitable for development/testing with a single worker?

Accepted Answer

Standalone mode

Answer

Standalone mode runs a single Connect worker process with connectors defined in property files, ideal for development and simple deployments.

Question 4

What is the 'status storage topic' in Kafka Connect distributed mode?

Accepted Answer

Stores the runtime status of connectors and tasks so all workers have a consistent view of the cluster state

Answer

The status storage topic tracks the state transitions (RUNNING, PAUSED, FAILED) of all connectors and tasks, enabling the REST API to report accurate status.

Question 5

How do Dead Letter Queues (DLQs) work in Kafka Connect sink connectors?

Accepted Answer

Records that fail to be processed are routed to a configurable DLQ topic instead of stopping the connector

Answer

A DLQ allows a sink connector to continue processing by redirecting problematic records to a separate topic, preventing one bad record from halting the pipeline.

Apache Kafka Practice Test

Apache Kafka Practice Test

Apache Kafka Kafka Connect 3