CCDAK無料問題集「Confluent Certified Developer for Apache Kafka Certification Examination」

質問 1

An application is consuming messages from Kafka.
The application logs show that partitions are frequently being reassigned within the consumer group.
Which two factors may be contributing to this?
(Select two.)

（A）The number of partitions does not match the number of application instances.

（B）An instance of the application is crashing and being restarted.

（C）There is a slow consumer processing application.

（D）There is a storage issue on the broker.

正解：B、C 解答を投票する

解説: (JPNTest メンバーにのみ表示されます)

質問 2

You use Kafka Connect with the JDBC source connector to extract data from a large database and push it into Kafka.
The database contains tens of tables, and the current connector is unable to process the data fast enough.
You add more Kafka Connect workers, but throughput doesn't improve.
What should you do next?

（A）Increase the number of Kafka partitions for the topics.

（B）Increase the value of the connector's property tasks.max.

（C）Modify the database schemas to enable horizontal sharding.

（D）Add more Kafka brokers to the cluster.

正解：B 解答を投票する

解説: (JPNTest メンバーにのみ表示されます)

質問 3

We want the average of all events in every five-minute window updated every minute. What kind of Kafka Streams window will be required on the stream?

（A）Tumbling window

（B）Hopping window

（C）Session window

（D）Sliding window

正解：B 解答を投票する

解説: (JPNTest メンバーにのみ表示されます)

質問 4

Which configuration determines how many bytes of data are collected before sending messages to the Kafka broker?

（A）buffer, memory

（B）batch .size

（C）send. buffer, bytes

（D）max. request.size

正解：B 解答を投票する

質問 5

Which two statements are correct about transactions in Kafka?
(Select two.)

（A）Transactions are only possible when writing messages to a topic with single partition.

（B）All messages from a failed transaction will be deleted from a Kafka topic.

（C）Transactions guarantee at least once delivery of messages.

（D）Information about producers and their transactions is stored in the _transaction_state topic.

（E）Consumers can consume both committed and uncommitted transactions.

正解：D、E 解答を投票する

解説: (JPNTest メンバーにのみ表示されます)

質問 6

Which of the following Kafka Streams operators are stateful? (select all that apply)

（A）reduce

（B）flatmap

（C）count

（D）joining

（E）aggregate

（F）peek

正解：A、C、D、E 解答を投票する

解説: (JPNTest メンバーにのみ表示されます)

質問 7

StreamsBuilder builder = new StreamsBuilder();
KStream<String, String> textLines = builder.stream("word-count-input"); KTable<String, Long> wordCounts = textLines
.mapValues(textLine -> textLine.toLowerCase())
.flatMapValues(textLine -> Arrays.asList(textLine.split("\W+")))
.selectKey((key, word) -> word)
.groupByKey()
.count(Materialized.as("Counts"));
wordCounts.toStream().to("word-count-output", Produced.with(Serdes.String(), Serdes.Long())); builder.build(); What is an adequate topic configuration for the topic word-count-output?

（A）cleanup.policy=delete

（B）max.message.bytes=10000000

（C）compression.type=lz4

（D）cleanup.policy=compact

正解：D 解答を投票する

解説: (JPNTest メンバーにのみ表示されます)

質問 8

I am producing Avro data on my Kafka cluster that is integrated with the Confluent Schema Registry. After a schema change that is incompatible, I know my data will be rejected. Which component will reject the data?

（A）The Kafka Producer itself

（B）The Confluent Schema Registry

（C）The Kafka Broker

（D）Zookeeper

正解：B 解答を投票する

解説: (JPNTest メンバーにのみ表示されます)

質問 9

What is the default maximum size of a message the Apache Kafka broker can accept?

（A）10MB

（B）1MB

（C）5MB

（D）2MB

正解：B 解答を投票する

解説: (JPNTest メンバーにのみ表示されます)

質問 10

Which of the following is true regarding thread safety in the Java Kafka Clients?

（A）One Producer can be safely used in multiple threads

（B）One Producer needs to be run in one thread

（C）One Consumer needs to run in one thread

（D）One Consumer can be safely used in multiple threads

正解：A、C 解答を投票する

解説: (JPNTest メンバーにのみ表示されます)

質問 11

Which is an optional field in an Avro record?

（A）fields

（B）doc

（C）namespace

（D）name

正解：B 解答を投票する

解説: (JPNTest メンバーにのみ表示されます)

質問 12

Select all the way for one consumer to subscribe simultaneously to the following topics - topic.history, topic.
sports, topic.politics? (select two)

（A）consumer.subscribePrefix("topic.");

（B）consumer.subscribe(Pattern.compile("topic\..*"));

（C）consumer.subscribe(Arrays.asList("topic.history", "topic.sports", "topic.politics"));

（D）consumer.subscribe("topic.history"); consumer.subscribe("topic.sports"); consumer.subscribe("topic.
politics");

正解：B、C 解答を投票する

解説: (JPNTest メンバーにのみ表示されます)

CCDAK 無料問題集「Confluent Certified Developer for Apache Kafka Certification Examination」

弊社を連絡する

関連リンク

トップ試験