You are sending messages with keys to a topic. To increase throughput, you decide to increase the number of partitions of the topic. Select all that apply.
Answer(s): C,D
Increasing the number of partition causes new messages keys to get hashed differently, and breaks the guarantee "same keys goes to the same partition". Kafka logs are immutable and the previous messages are not re-shuffled
In Kafka Streams, by what value are internal topics prefixed by?
Answer(s): B
In Kafka Streams, the application.id is also the underlying group.id for your consumers, and the prefixfor all internal topics (repartition and state)
You are using JDBC source connector to copy data from 3 tables to three Kafka topics. There is one connector created with max.tasks equal to 2 deployed on a cluster of 3 workers. How many tasks are launched?
Answer(s): A
here, we have three tables, but the max.tasks is 2, so that's the maximum number of tasks that will be created
You are doing complex calculations using a machine learning framework on records fetched from a Kafka topic. It takes more about 6 minutes to process a record batch, and the consumer enters rebalances even though it's still running. How can you improve this scenario?
Here, we need to change the setting max.poll.interval.ms (default 300000) to its double in order to tell Kafka a consumer should be considered dead if the consumer only if it hasn't called the .poll() method in 10 minutes instead of 5.
Post your Comments and Discuss Confluent CCDAK exam with other Community members:
Testbear commented on June 13, 2023 please upload ITALY upvote
Our website is free, but we have to fight against bots and content theft. We're sorry for the inconvenience caused by these security measures. You can access the rest of the CCDAK content, but please register or login to continue.