What happens if you write the following code in your producer? producer.send(producerRecord).get()
A. Batching will be increased
B. It will force all brokers in Kafka to acknowledge the producerRecord
C. Throughput will be decreased
D. Compression will be increased
正解:C
解説: (Pass4Test メンバーにのみ表示されます)
質問 2:
A stream processing application is tracking the user activity of online shopping carts. The application tracks items added to the cart, items removed from the cart, and items ordered from the cart throughout the day for each user.
You need to capture the data to identify possible periods of user inactivity.
Which type of Kafka Streams window should you use?
A. Session
B. Tumbling
C. Sliding
D. Hopping
正解:A
質問 3:
Which of the following Kafka Streams operators are stateful? (select all that apply)
A. count
B. reduce
C. aggregate
D. peek
E. flatmap
F. joining
正解:A,B,C,F
解説: (Pass4Test メンバーにのみ表示されます)
質問 4:
What is true about partitions? (select two)
A. A partition has one replica that is a leader, while the other replicas are followers
B. A broker can have different partitions numbers for the same topic on its disk
C. You cannot have more partitions than the number of brokers in your cluster
D. A broker can have a partition and its replica on its disk
E. Only out of sync replicas are replicas, the remaining partitions that are in sync are also leader
正解:A,B
解説: (Pass4Test メンバーにのみ表示されます)
質問 5:
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. Create a custom partitioner
B. 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
C. Add metadata to the producer record
D. Define a Kafka Broker routing rule
正解:A
解説: (Pass4Test メンバーにのみ表示されます)
質問 6:
A Zookeeper configuration has tickTime of 2000, initLimit of 20 and syncLimit of 5. What's the timeout value for followers to connect to Zookeeper?
A. 2000 ms
B. 10 sec
C. 20 sec
D. 40 sec
正解:D
解説: (Pass4Test メンバーにのみ表示されます)
質問 7:
An application is consuming messages from Kafka. You observe partitions being frequently reassigned to the consumer group from the application logs.
Which factors may be contributing to this? (Choose 2.)
A. An instance of the application is crashing and getting restarted
B. The number of partitions is not matching the number of application instances.
C. There is a storage issue on the broker.
D. There is a slow consumer processing application.
正解:D
質問 8:
What information isn't stored inside of Zookeeper? (select two)
A. Schema Registry schemas
B. Controller registration
C. Consumer offset
D. Broker registration info
E. ACL inforomation
正解:C
解説: (Pass4Test メンバーにのみ表示されます)
冈本** -
試験を見事でパスしました。このCCDAK問題集は読むのもあまり苦がなく、とにかくやる気が起こるテキスト