Your company has three Kafka clusters: Development, Testing, and Production.
The Production cluster is running out of storage, so you add a new node.
Which two statements about the new node are true?
(Select two.)
A. A newly added node will have KRaft controller role by default.
B. A node ID will be assigned to the new node automatically.
C. A new node will not have any partitions assigned to it unless a new topic is created or reassignment occurs.
D. A new node can be added without stopping existing cluster nodes.
正解:C,D
解説: (Pass4Test メンバーにのみ表示されます)
質問 2:
(Which configuration is valid for deploying a JDBC Source Connector to read all rows from the orders table and write them to the dbl-orders topic?)
A. {"name": "jdbc-source","connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector","tasks.
max": "1","connection.url": "jdbc:mysql://mysql:3306/dbl?user=user&password=pas","topic.prefix":
"dbl-","table.whitelist": "orders"}
B. {"name": "orders-connect","connector.class": "io.confluent.connect.jdbc.DdbcSourceConnector","tasks.
max": "1","connection.url": "jdbc:mysql://mysql:3306/dbl","topic.whitelist": "orders","auto.create":
"true"}
C. {"name": "jdbc-source","connector.class": "io.confluent.connect.jdbc.DdbcSourceConnector","tasks.
max": "1","connection.url": "jdbc:mysql://mysql:3306/dbl?user=user&useAutoAuth=true","topic.
prefix": "dbl-","table.whitelist": "orders"}
D. {"name": "dbl-orders","connector.class": "io.confluent.connect.jdbc.DdbcSourceConnector","tasks.
max": "1","connection.url": "jdbc:mysql://mysql:3306/dbl?user=user&password=pas","topic.prefix":
"dbl-","table.blacklist": "ord*"}
正解:A
解説: (Pass4Test メンバーにのみ表示されます)
質問 3:
What is the default maximum size of a message the Apache Kafka broker can accept?
A. 5MB
B. 2MB
C. 1MB
D. 10MB
正解:C
解説: (Pass4Test メンバーにのみ表示されます)
質問 4:
You are writing to a topic with acks=all.
The producer receives acknowledgments but you notice duplicate messages.
You find that timeouts due to network delay are causing resends.
Which configuration should you use to prevent duplicates?
A. enable.auto.commit=true
B. retries=0max.in.flight.requests.per.connection=5enable.idempotence=true
C. retries=2147483647max.in.flight.requests.per.connection=1enable.idempotence=false
D. retries=2147483647max.in.flight.requests.per.connection=5enable.idempotence=true
正解:D
解説: (Pass4Test メンバーにのみ表示されます)
質問 5:
Which tool can you use to modify the replication factor of an existing topic?
A. kafka-recreate-topic.sh
B. kafka-reassign-partitions.sh
C. kafka-reassign-topics.sh
D. kafka-topics.sh
正解:B
解説: (Pass4Test メンバーにのみ表示されます)
質問 6:
You need to collect logs from a host and write them to a Kafka topic named 'logs-topic'. You decide to use Kafka Connect File Source connector for this task.
What is the preferred deployment mode for this connector?
A. Distributed mode
B. Standalone mode
C. SingleCluster mode
D. Parallel mode
正解:B
解説: (Pass4Test メンバーにのみ表示されます)
質問 7:
What is a consequence of increasing the number of partitions in an existing Kafka topic?
A. Existing data will be redistributed across the new number of partitions temporarily increasing cluster load.
B. The acknowledgment process will increase latency for producers using acks=all.
C. Consumers will need to process data from more partitions which will significantly increase consumer lag.
D. Records with the same key could be located in different partitions.
正解:C
解説: (Pass4Test メンバーにのみ表示されます)
質問 8:
(You want to read messages from all partitions of a topic in every consumer instance of your application.
How do you do this?)
A. Use the assign() method using all topic-partitions of the topic as argument.
B. Use the subscribe() method with a regular expression argument.
C. Use the subscribe() method with an empty consumer group name configuration.
D. Use the assign() method with the topic name as argument.
正解:A
解説: (Pass4Test メンバーにのみ表示されます)
質問 9:
Which statement is true about how exactly-once semantics (EOS) work in Kafka Streams?
A. EOS in Kafka Streams is implemented by creating a separate Kafka topic for deduplication of all messages processed by the application.
B. EOS in Kafka Streams relies on transactional producers to atomically commit state updates to changelog topics and output records to Kafka.
C. Kafka Streams disables log compaction on internal changelog topics to preserve all state changes for potential recovery.
D. Kafka Streams provides EOS by periodically checkpointing state stores and replaying changelogs to recover only unprocessed messages during failure.
正解:B
解説: (Pass4Test メンバーにのみ表示されます)
773 お客様のコメント





徳永** -
Pass4Testいちばんやさしい、とうたうだけあって、丁寧に解説されています。
効率的にまとまっているCCDAK参考書だと思います。