There are two consumers C1 and C2 belonging to the same group G subscribed to topics T1 and T2. Each of the topics has 3 partitions. How will the partitions be assigned to consumers with Partition Assigner being Round Robin Assigner?

• A.C1 will be assigned partitions 0 and 2 from T1 and partition 1 from T2. C2 will have partition 1 from T1 and partitions 0 and 2 from T2.
• B.Two consumers cannot read from two topics at the same time
• C.C1 will be assigned partitions 0 and 1 from T1 and T2, C2 will be assigned partition 2 from T1 and T2.
• D.All consumers will read from all partitions

Comment: *

Name: *

Email: *

Verification: *

while (true) {
ConsumerRecords<String, String> records = consumer.poll(100);
try {
consumer.commitSync();
} catch (CommitFailedException e) {
log.error("commit failed", e)
}
for (ConsumerRecord<String, String> record records)
{
System.out.printf("topic = %s, partition = %s, offset =
%d, customer = %s, country = %s
",
record.topic(), record.partition(),
record.offset(), record.key(), record.value());
}
}
What kind of delivery guarantee this consumer offers?

• A.Exactly-once
• B.At-least-once
• C.At-most-once

Comment: *

Name: *

Email: *

Verification: *

Which KSQL queries write to Kafka?

• A.COUNT and JOIN
• B.SHOW STREAMS and EXPLAIN <query> statements
• C.CREATE STREAM WITH <topic> and CREATE TABLE WITH <topic>
• D.CREATE STREAM AS SELECT and CREATE TABLE AS SELECT

Comment: *

Name: *

Email: *

Verification: *

We want the average of all events in every five-minute window updated every minute. What kind of Kafka Streams window will be required on the stream?

• A.Session window
• B.Tumbling window
• C.Sliding window
• D.Hopping window

Comment: *

Name: *

Email: *

Verification: *

The Controller is a broker that is... (select two)

• A.elected by Zookeeper ensemble
• B.is responsible for partition leader election
• C.elected by broker majority
• D.is responsible for consumer group rebalances

Comment: *

Name: *

Email: *

Verification: *