NEW QUESTION 1
In Kafka Streams, by what value are internal topics prefixed by?

• A. tasks-<number>
• B. application.id
• C. group.id
• D. kafka-streams-

Answer: B

Explanation:
In Kafka Streams, the application.id is also the underlying group.id for your consumers, and the prefix for all internal topics (repartition and state)

NEW QUESTION 2
is KSQL ANSI SQL compliant?

• A. Yes
• B. No

Answer: B

Explanation:
KSQL is not ANSI SQL compliant, for now there are no defined standards on streaming SQL languages

NEW QUESTION 3
The rule "same key goes to the same partition" is true unless...

• A. the number of producer changes
• B. the number of kafka broker changes
• C. the number of partition changes
• D. the replication factor changes

Answer: C

Explanation:
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.

NEW QUESTION 4
What is the default port that the KSQL server listens on?

• A. 9092
• B. 8088
• C. 8083
• D. 2181

Answer: B

Explanation:
Default port of KSQL server is 8088

NEW QUESTION 5
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?

• A. Increase fetch.max.wait
• B. Increase fetch.max.bytes
• C. Decrease fetch.max.bytes
• D. Decrease fetch.min.bytes
• E. Increase fetch.min.bytes

Answer: E

Explanation:
This will allow consumers to wait and receive more bytes in each fetch request.

NEW QUESTION 6
Your streams application is reading from an input topic that has 5 partitions. You run 5 instances of your application, each with num.streams.threads set to 5. How many stream tasks will be created and how many will be active?

• A. 5 created, 1 active
• B. 5 created, 5 active
• C. 25 created, 25 active
• D. 25 created, 5 active

Answer: D

Explanation:
One partition is assigned a thread, so only 5 will be active, and 25 threads (i.e. tasks) will be created

NEW QUESTION 7
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.

• A. All the existing records will get rebalanced among the partitions to balance load
• B. New records with the same key will get written to the partition where old records with that key were written
• C. New records may get written to a different partition
• D. Old records will stay in their partitions

Answer: CD

Explanation:
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

NEW QUESTION 8
What are the requirements for a Kafka broker to connect to a Zookeeper ensemble? (select two)

• A. Unique value for each broker's zookeeper.connect parameter
• B. Unique values for each broker's broker.id parameter
• C. All the brokers must share the same broker.id
• D. All the brokers must share the same zookeeper.connect parameter

Answer: BD

Explanation:
Each broker must have a unique broker id and connect to the same zk ensemble and root zNode

NEW QUESTION 9
How often is log compaction evaluated?

• A. Every time a new partition is created
• B. Every time a segment is closed
• C. Every time a message is sent to Kafka
• D. Every time a message is flushed to disk

Answer: B

Explanation:
Log compaction is evaluated every time a segment is closed. It will be triggered if enough data is "dirty" (see dirty ratio config)

NEW QUESTION 10
Which of the following Kafka Streams operators are stateless? (select all that apply)

• A. map
• B. filter
• C. flatmap
• D. branch
• E. groupBy
• F. aggregate

Answer: ABCDE

Explanation:
Seehttps://kafka.apache.org/20/documentation/streams/developer-guide/dsl-api.html#stateless-transformations

NEW QUESTION 11
A Zookeeper ensemble contains 5 servers. What is the maximum number of servers that can go missing and the ensemble still run?

• A. 3
• B. 4
• C. 2
• D. 1

Answer: C

Explanation:
majority consists of 3 zk nodes for 5 nodes zk cluster, so 2 can fail

NEW QUESTION 12
What is the protocol used by Kafka clients to securely connect to the Confluent REST Proxy?

• A. Kerberos
• B. SASL
• C. HTTPS (SSL/TLS)
• D. HTTP

Answer: C

Explanation:
TLS - but it is still called SSL.

NEW QUESTION 13
How do Kafka brokers ensure great performance between the producers and consumers? (select two)

• A. It compresses the messages as it writes to the disk
• B. It leverages zero-copy optimisations to send data straight from the page-cache
• C. It buffers the messages on disk, and sends messages from the disk reads
• D. It transforms the messages into a binary format
• E. It does not transform the messages

Answer: BE

Explanation:
Kafka transfers data with zero-copy and sends the raw bytes it receives from the producer
straight to the consumer, leveraging the RAM available as page cache

NEW QUESTION 14
To read data from a topic, the following configuration is needed for the consumers

• A. all brokers of the cluster, and the topic name
• B. any broker to connect to, and the topic name
• C. the list of brokers that have the data, the topic name and the partitions list
• D. any broker, and the list of topic partitions

Answer: B

Explanation:
All brokers can respond to Metadata request, so a client can connect to any broker in the cluster.

NEW QUESTION 15
An ecommerce website maintains two topics - a high volume "purchase" topic with 5 partitions and low volume "customer" topic with 3 partitions. You would like to do a stream- table join of these topics. How should you proceed?

• A. Repartition the purchase topic to have 3 partitions
• B. Repartition customer topic to have 5 partitions
• C. Model customer as a GlobalKTable
• D. Do a KStream / KTable join after a repartition step

Answer: C

Explanation:
In case of KStream-KStream join, both need to be co-partitioned. This restriction is not applicable in case of join with GlobalKTable, which is the most efficient here.

NEW QUESTION 16
What's is true about Kafka brokers and clients from version 0.10.2 onwards?

• A. Clients and brokers must have the exact same version to be able to communicate
• B. A newer client can talk to a newer broker, but an older client cannot talk to a newer broker
• C. A newer client can talk to a newer broker, and an older client can talk to a newer broker
• D. A newer client can't talk to a newer broker, but an older client can talk to a newer broker

Answer: C

Explanation:
Kafka's new bidirectional client compatibility introduced in 0.10.2 allows this. Read more herehttps://www.confluent.io/blog/upgrading-apache-kafka-clients-just-got-easier/

NEW QUESTION 17
......