DP-420 · Question #24
You need to configure an Apache Kafka instance to ingest data from an Azure Cosmos DB for NoSQL account. The data from a container named telemetry must be added to a Kafka topic named iot. The…
The correct answer is A. "connector.class": "com.azure.cosmos.kafka.connect.source.CosmosDBSourceConnector" C. "key.converter": "io.confluent.connect.avro.AvroConverter" D. "connect.cosmos.containers.topicmap": "iot#telemetry". Three configuration items are required: (A) 'connector.class': 'CosmosDBSourceConnector' - this is the correct connector class for reading (sourcing) data FROM Cosmos DB into Kafka; the SinkConnector (option F) writes TO Cosmos DB, which is the wrong direction. (C)…
Question
You need to configure an Apache Kafka instance to ingest data from an Azure Cosmos DB for NoSQL account. The data from a container named telemetry must be added to a Kafka topic named iot. The solution must store the data in a compact binary format. Which three configuration items should you include in the solution? Each correct answer presents part of the solution. NOTE: Each correct selection is worth one point.
Options
- A"connector.class": "com.azure.cosmos.kafka.connect.source.CosmosDBSourceConnector"
- B"key.converter": "org.apache.kafka.connect.json.JsonConverter"
- C"key.converter": "io.confluent.connect.avro.AvroConverter"
- D"connect.cosmos.containers.topicmap": "iot#telemetry"
- E"connect.cosmos.containers.topicmap": "iot"
- F"connector.class": "com.azure.cosmos.kafka.connect.source.CosmosDBSinkConnector"
How the community answered
(63 responses)- A84% (53)
- B2% (1)
- E5% (3)
- F10% (6)
Explanation
Three configuration items are required: (A) 'connector.class': 'CosmosDBSourceConnector' - this is the correct connector class for reading (sourcing) data FROM Cosmos DB into Kafka; the SinkConnector (option F) writes TO Cosmos DB, which is the wrong direction. (C) 'key.converter': 'io.confluent.connect.avro.AvroConverter' - Avro is a compact binary serialization format, satisfying the requirement to store data in compact binary format. Option B (JsonConverter) uses text-based JSON, which is not binary-compact. (D) 'connect.cosmos.containers.topicmap': 'iot#telemetry' - this is the correct syntax for mapping a Cosmos DB container to a Kafka topic, in the format 'topic#container'. Option E ('iot' alone) is missing the required container name and uses incorrect syntax.
Topics
Community Discussion
No community discussion yet for this question.