Confluent
CCAAK · Question #34
CCAAK Question #34: Real Exam Question with Answer & Explanation
The correct answer is B. Increase the number of Connect Tasks (tasks.max value).. Increasing the number of tasks allows the connector to parallelize table reads and process more data concurrently. Since tasks.max is currently set to 1, the connector is limited to a single task, which creates a bottleneck and causes lag. Raising tasks.max enables higher through
Question
Kafka Connect is running on a two-node cluster in distributed mode. The connector: - Is a source connector pulling data from relational database tables (users/payment/orders) - Writes to topics with two partitions - Has a replication factor of two You observe a data lag in the Connect source. The Connector definition is listed below: { "name": "confluent-mysql-source", "connector.class":"io.confluent.connect.jdbc.JdbcSourceConnector" "topic.prefix": "mysql_", "table.whitelist": "users,payment,orders", "timestamp.column.name": "created_at", "db.timezone": "UTC", "tasks.max" : "1" } How can you reduce the data lag?
Options
- AIncrease the number of Connect Nodes.
- BIncrease the number of Connect Tasks (tasks.max value).
- CIncrease the number of partitions.
- DIncrease the replication factor and increase the number of Connect Tasks.
Explanation
Increasing the number of tasks allows the connector to parallelize table reads and process more data concurrently. Since tasks.max is currently set to 1, the connector is limited to a single task, which creates a bottleneck and causes lag. Raising tasks.max enables higher throughput and
Community Discussion
No community discussion yet for this question.