Free Confluent CCDAK Exam Dumps Questions & Answers

You are working on an Orders microservice Thai is publishing messages lo an Orders topic. II is a business requirement that the Orders for a given customer are processed sequentially. Also, the Orders topic is partitioned tor scalability.
Which factors would you need to address during application development?

• A.  Enable producer Idempotence. set max-in-flight requests per connection to 1. and number of partitions is not changed.
• B.  Ensure the message key is set to customer id, max-in-flight requests per connection is set to less than or equal to 5, and number of partitions is not changed.
• C.  Enable producer Idempotence. set batch.size = 1. and set lioq.er.ms to 0. and number ot partitions is not changed.
• D.  Enable producer Idempotence. set llnger.ms to 0. set acks='all\ and number of partitions is not changed.

What is returned by a producer.send() call in the Java API?

• A.  A Boolean indicating if the call succeeded
• B.  Unit
• C.  Future<RecordMetadata> object
• D.  Future<ProducerRecord> object

Which partition assignment minimizes partition movements between two assignments?

• A.  RangeAssignor
• B.  PartitionAssignor
• C.  StickyAssignor
• D.  RoundRobinAssignor

You have a consumer group with default configuration settings reading messages from your Kafka cluster.
You need to optimize throughput so the consumer group processes more messages in the same amount of time.
Which change should you make?

• A.  Disable auto commit and have the consumers manually commit offsets.
• B.  Decrease the session timeout of each consumer.
• C.  Remove some consumers from the consumer group.
• D.  Increase the number of bytes the consumers read with each fetch request.

Which of the following is a push query?

• A.  CREATE STREAM STUDENTS (ID STRING KEY, SCORE INT)
  WITH (kafka_topic='students_topic', value_format='JSON', partitions=4);
• B.  SELECT *
  FROM NUMBER_OF_TESTS
  WHERE ID='10';
• C.  SELECT windowstart, windowend, item_id, SUM(quantity)
  FROM orders
  WINDOW TUMBLING (SIZE 20 SECONDS)
  GROUP BY item_id
  EMIT CHANGES;
• D.  CREATE TABLE LEFT_TABLE (ID BIGINT PRIMARY KEY, NAME varchar, VALUE bigint) WITH (kafka_topic='left_topic', value_format='JSON', partitions=4);