Kafka MCQs – Kafka Connect

11.) What command lists all running connectors via REST?

A) curl localhost:8083/connector-list
B) curl localhost:8083/connectors
C) connect list
D) kafka-connect list

Answer: Option B

Explanation: This endpoint lists all active connectors on the Kafka Connect worker.

12.) A Kafka Connect connector plugin must implement which interface?

A) KafkaPlugin
B) ConnectInterface
C) Connector
D) KafkaSource

Answer: Option C

Explanation: Custom connector plugins implement the Connector interface from the Connect API.

13.) Kafka Connect stores connector offsets in:

A) Kafka topics
B) Zookeeper
C) Filesystem
D) Redis

Answer: Option A

Explanation: Offsets for connectors are stored in internal Kafka topics in distributed mode.

14.) Which file defines the worker configuration in Kafka Connect?

A) connect-standalone.properties
B) connect-worker.properties
C) worker-standalone.properties
D) worker.properties

Answer: Option A

Explanation: This file configures the Kafka Connect worker in standalone mode.

15.) What is the purpose of REST API in Kafka Connect?

A) Monitoring brokers
B) Executing SQL queries
C) Managing connectors
Triggering Kafka Streams

Answer: Option C

Explanation: Kafka Connect exposes a REST API to manage and monitor connectors (create, pause, delete).

16.) What is the default port for Kafka Connect REST API?

A) 8090
B) 8083
C) 8080
D) 9092

Answer: Option B

Explanation: Kafka Connect REST API typically runs on port 8083.

17.) Which connector is used to capture data from MySQL database?

A) FileStreamSourceConnector
B) MongoDB Connector
C) JDBC Sink Connector
D) Debezium MySQL Connector

Answer: Option D

Explanation: Debezium provides a CDC (Change Data Capture) connector for MySQL.

18.) What format can Kafka Connect use to serialize data?

A) CSV
B) JSON
C) Avro
D) All of the above

Answer: Option D

Explanation: Kafka Connect supports JSON, Avro, Protobuf, and other formats.

19.) Kafka Connect uses which configuration to specify the Kafka broker address?

A) bootstrap.servers
B) kafka.broker
C) server.address
D) brokers

Answer: Option A

Explanation: This config specifies the address(es) of the Kafka brokers.

20.) How do you pause a connector using REST API?

A) POST /connectors/{name}/pause
B) GET /connectors/pause/{name}
C) DELETE /connectors/{name}
D) PUT /connectors/{name}/status

Answer: Option A

Explanation: You pause a connector with a POST request to the specific connector’s pause endpoint.

Leave a Reply

Your email address will not be published. Required fields are marked *