CCDAK問題集PDFでCCDAKリアル試験問題解答 [Q88-Q106]

新問題 88
What is ISR in Apache Kafka?

新問題 89
What is the default port that the KSQL server listens on?

新問題 90
If you enable an SSL endpoint in Kafka, what feature of Kafka will be lost?

新問題 91
You create a topic named stream-logs with:
* A replication factor of 3
* Four partitions
* Messages that are plain logs without a keyHow will messages be distributed across partitions?

新問題 92
You are developing a Java application using a Kafka consumer.
You need to integrate Kafka’s client logs with your own application’s logs using log4j2.
Which Java library dependency must you include in your project?

新問題 93
A producer application in a developer machine was able to send messages to a Kafka topic. After copying the producer application into another developer’s machine, the producer is able to connect to Kafka but unable to produce to the same Kafka topic because of an authorization issue. What is the likely issue?

新問題 94
You have a Kafka cluster and all the topics have a replication factor of 3. One intern at your company stopped a broker, and accidentally deleted all the data of that broker on the disk. What will happen if the broker is restarted?

新問題 95
What is the protocol used by Kafka clients to securely connect to the Confluent REST Proxy?

新問題 96
A producer just sent a message to the leader broker for a topic partition. The producer used acks=1 and therefore the data has not yet been replicated to followers. Under which conditions will the consumer see the message?

新問題 97
How would you describe a connector in ksqlDB?

新問題 98
Compaction is enabled for a topic in Kafka by setting log.cleanup.policy=compact. What is true about log compaction?

新問題 99
In the Kafka consumer metrics it is observed that fetch-rate is very high and each fetch is small. What steps will you take to increase throughput?

新問題 100
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?

新問題 101
A consumer application runs once a week and reads from a Kafka topic. The last time the application ran, the last offset processed was 217. The application is configured with auto.offset.reset set to “latest”. The current offsets in the topic start at 318 and end at 588.
What offset will the application start reading when it starts up for its next run?

新問題 102
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?

新問題 103
A consumer wants to read messages from partitions 0 and 1 of a topic topic1. Code snippet is shown below.
consumer.subscribe(Arrays.asList(“topic1”));
List<TopicPartition> pc = new ArrayList<>();
pc.add(new PartitionTopic(“topic1”, 0));
pc.add(new PartitionTopic(“topic1”, 1));
consumer.assign(pc);

新問題 104
You create a producer that writes messages about bank account transactions from tens of thousands of different customers into a topic.
* Your consumers must process these messages with low latency and minimize consumer lag
* Processing takes ~6x longer than producing
* Transactions for each bank account must be processedin orderWhich strategy should you use?

新問題 105
A Kafka producer application wants to send log messages to a topic that does not include any key. What are the properties that are mandatory to configure for the producer configuration? (select three)

新問題 106
Which statement describes the storage location for a sink connector’s offsets?