DP-420: Designing and Implementing Cloud-Native Applications Using Microsoft Azure Cosmos DBDemo

By Microsoft · Question Mode

QuestionQ65

Integrate an Azure Cosmos DB solution

You must configure an Apache Kafka instance to ingest data from an Azure Cosmos DB Core (SQL) API account. 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.

Choose three
  • 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"
Explanation

The Azure Cosmos DB source connector reads the Cosmos DB change feed and publishes it to Kafka. Its connect.cosmos.containers.topicmap setting uses the format topic#container, so iot#telemetry sends data from the telemetry container to the iot topic. Avro uses a compact binary representation, and io.confluent.connect.avro.AvroConverter configures Kafka Connect to use that format.

Learn more

Community Discussion

No comments yet. Be the first to start the discussion!