Where are KSQL-related data and metadata stored?
A. Kafka Topics
B. Zookeeper
C. PostgreSQL database
D. Schema Registry
The exactly once guarantee in the Kafka Streams is for which flow of data?
A. Kafka => Kafka
B. Kafka => External
C. External => Kafka
The kafka-console-consumer CLI, when used with the default options
A. uses a random group id
B. always uses the same group id
C. does not use a group id
To prevent network-induced duplicates when producing to Kafka, I should use
A. max.in.flight.requests.per.connection=1
B. enable.idempotence=true
C. retries=200000
D. batch.size=1
There are 3 producers writing to a topic with 5 partitions. There are 5 consumers consuming from the topic. How many Controllers will be present in the cluster?
A. 3
B. 5
C. 2
D. 1
There are five brokers in a cluster, a topic with 10 partitions and replication factor of 3, and a quota of producer_bytes_rate of 1 MB/sec has been specified for the client. What is the maximum throughput allowed for the client?
A. 10 MB/s
B. 0.33 MB/s
C. 1 MB/s
D. 5 MB/s
What's a Kafka partition made of?
A. One file and one index
B. One file
C. One file and two indexes per segment
D. One file and two indexes
A consumer is configured with enable.auto.commit=false. What happens when close() is called on the consumer object?
A. The uncommitted offsets are committed
B. A rebalance in the consumer group will happen immediately
C. The group coordinator will discover that the consumer stopped sending heartbeats. It will cause rebalance after session.timeout.ms
To allow consumers in a group to resume at the previously committed offset, I need to set the proper value for...
A. value.deserializer
B. auto.offset.resets
C. group.id
D. enable.auto.commit