Confluent Certified Developer for Apache Kafka Certification Examination
Last Update May 18, 2024
Total Questions : 150
We are offering FREE CCDAK Confluent exam questions. All you do is to just go and sign up. Give your details, prepare CCDAK free exam questions and then go for complete pool of Confluent Certified Developer for Apache Kafka Certification Examination test questions that will help you more.
An ecommerce wesbite sells some custom made goods. What's the natural way of modeling this data in Kafka streams?
What exceptions may be caught by the following producer? (select two)
ProducerRecord
new ProducerRecord<>("topic1", "key1", "value1");
try {
producer.send(record);
} catch (Exception e) {
e.printStackTrace();
}
Suppose you have 6 brokers and you decide to create a topic with 10 partitions and a replication factor of 3. The brokers 0 and 1 are on rack A, the brokers 2 and 3 are on rack B, and the brokers 4 and 5 are on rack C. If the leader for partition 0 is on broker 4, and the first replica is on broker 2, which broker can host the last replica? (select two)
What is a generic unique id that I can use for messages I receive from a consumer?
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?
To produce data to a topic, a producer must provide the Kafka client with...
A consumer wants to read messages from a specific partition of a topic. How can this be achieved?
There are 3 producers writing to a topic with 5 partitions. There are 10 consumers consuming from the topic as part of the same group. How many consumers will remain idle?
How do you create a topic named test with 3 partitions and 3 replicas using the Kafka CLI?
Which of the following errors are retriable from a producer perspective? (select two)
How do Kafka brokers ensure great performance between the producers and consumers? (select two)
A topic receives all the orders for the products that are available on a commerce site. Two applications want to process all the messages independently - order fulfilment and monitoring. The topic has 4 partitions, how would you organise the consumers for optimal performance and resource usage?
Which of the following Kafka Streams operators are stateful? (select all that apply)
If I want to send binary data through the REST proxy, it needs to be base64 encoded. Which component needs to encode the binary data into base 64?
How much should be the heap size of a broker in a production setup on a machine with 256 GB of RAM, in PLAINTEXT mode?
StreamsBuilder builder = new StreamsBuilder();
KStream
KTable
.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?