Apache Kafka Kafka Connect 2

Question 1

Which Kafka Connect SMT would you use to add a current timestamp field to every record?

Accepted Answer

InsertField with timestamp=true

Answer

The InsertField SMT with timestamp=true appends a wall-clock timestamp field to every record passing through the connector.

Question 2

What does the Kafka Connect 'offset storage topic' store?

Accepted Answer

The read positions (offsets) of source connectors so they can resume after restart

Answer

Connect stores source connector offsets (e.g., the last processed database row ID) in this internal topic to enable exactly-once or at-least-once resumption.

Question 3

What HTTP endpoint checks the status of a running connector in Kafka Connect's REST API?

Accepted Answer

GET /connectors/{name}/status

Answer

GET /connectors/{name}/status returns the current state of the connector and each of its tasks (RUNNING, PAUSED, FAILED, etc.).

Question 4

What is the 'config storage topic' used for in Kafka Connect distributed mode?

Accepted Answer

Stores all connector and task configurations so workers share a consistent view

Answer

The config storage topic persists connector configurations across all workers, ensuring every worker in the Connect cluster has the same configuration state.

Question 5

Which configuration key in a JDBC source connector controls how frequently new rows are polled from the database?

Accepted Answer

poll.interval.ms

Answer

poll.interval.ms determines the frequency (in milliseconds) at which the JDBC source connector queries the database for new or updated rows.

Apache Kafka Practice Test

Apache Kafka Practice Test

Apache Kafka Kafka Connect 2