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 actions will trigger partition rebalance for a consumer group? (select three)

• A.Increase partitions of a topic
• B.Remove a broker from the cluster
• C.Add a new consumer to consumer group
• D.A consumer in a consumer group shuts down

Comment: *

Name: *

Email: *

Verification: *

You are using JDBC source connector to copy data from 2 tables to two 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?

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

Comment: *

Name: *

Email: *

Verification: *

You are using JDBC source connector to copy data from a table to Kafka topic. There is one connector created with max.tasks equal to 2 deployed on a cluster of 3 workers. How many tasks are launched?

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

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