CCDAK 試験問題を無料オンラインアクセス

You are receiving orders from different customer in an "orders" topic with multiple partitions. Each message has the customer name as the key. There is a special customer named ABC that generates a lot of orders and you would like to reserve a partition exclusively for ABC. The rest of the message should be distributed among other partitions. How can this be achieved?

• A.Define a Kafka Broker routing rule
• B.Create a custom partitioner
• C.All messages with the same key will go the same partition, but the same partition may have messages with different keys. It is not possible to reserve
• D.Add metadata to the producer record

You need to consume messages from Kafka using the command-line interface (CLI).
Which command should you use?

• A.kafka-consume
• B.kafka-console-consumer
• C.kafka-consumer
• D.kafka-get-messages

How do you read a table or stream from the beginning of a topic?

• A.id as orderId
• B.CREATE STREAM shipped_orders AS
  SELECT
• C.SET 'auto.offset.reset' = 'latest';
  SELECT STRUCT(f1 := v1, f2 := v2) FROM s1 EMIT CHANGES;
• D.id as paymentId
  FROM orders o
  INNER JOIN payments p WITHIN 1 HOURS ON p.id = o.id
  INNER JOIN shipments s WITHIN 2 HOURS ON s.id
  = o.id;
• E.SET 'auto.offset.reset' = 'earliest';
  SELECT STRUCT(f1 := v1, f2 := v2) FROM s1 EMIT CHANGES;
• F.itemId as itemId,
• G.id as shipmentId,
• H.SELECT STRUCT(f1 := v1, f2 := v2) FROM s1 EMIT CHANGES;

Which of the following is not an Avro primitive type?

• A.string
• B.date
• C.null
• D.int
• E.long

You are experiencing low throughput from a Java producer. You monitor the Kafka metrics and notice that the metrics for that producer show low I/O thread ratio and low I/O thread wait ratio.
What is most likely the cause of the slow producer performance?

• A.Compression is enabled.
• B.The producer code has an expensive callback function.
• C.There is a bad data link layer (layer 2) connection from the producer to the cluster.
• D.The producer is sending large batches of messages.