[Solved] Why does this sink connector fail to start?{ "name": "elastic-sink", "connector.class": "ElasticsearchSinkConnector", "topics": "events", "connection.url": "http://localhost:9200", "tasks.max":... | Kafka

Kafka - Connect

Why does this sink connector fail to start?

{
  "name": "elastic-sink",
  "connector.class": "ElasticsearchSinkConnector",
  "topics": "events",
  "connection.url": "http://localhost:9200",
  "tasks.max": 2
}

Assume Elasticsearch is running and reachable.

Atopics property must be an array

BMissing required property 'key.converter'

Ctasks.max cannot be greater than 1

DIncorrect connector class name

Step-by-Step Solution

Solution:

Step 1: Check required properties for Elasticsearch sink
Elasticsearch sink requires 'key.converter' and 'value.converter' to deserialize data.
Step 2: Verify given config
Config lacks 'key.converter' property, causing startup failure.
Final Answer:
Missing required property 'key.converter' -> Option B
Quick Check:
Converters required for sink startup [OK]

Quick Trick: Always set key and value converters for sink connectors [OK]

Common Mistakes:

MISTAKES

Ignoring missing converter properties
Assuming tasks.max limit is 1
Thinking topics must be array always

Master "Connect" in Kafka

9 interactive learning modes - each teaches the same concept differently

Learn Why Deep Visual Try Challenge Project Recall Time

More Kafka Quizzes

Why does this sink connector fail to start?

Step 1: Check required properties for Elasticsearch sink

Step 2: Verify given config

Final Answer:

Quick Check:

Want More Practice?