What is the default port that the KSQL server listens on?
Correct Answer:
B
Default port of KSQL server is 8088
There are 3 producers writing to a topic with 5 partitions. There are 10 consumers consuming from the topic as part of the same group. How many consumers will remain idle?
Correct Answer:
D
One consumer per partition assignment will keep 5 consumers idle.
Kafka is configured with following parameters - log.retention.hours = 168 log.retention.minutes = 168 log.retention.ms = 168 How long will the messages be retained for?
Correct Answer:
B
If more than one similar config is specified, the smaller unit size will take precedence.
What happens if you write the following code in your producer? producer.send(producerRecord).get()
Correct Answer:
B
Using Future.get() to wait for a reply from Kafka will limit throughput.
A consumer sends a request to commit offset 2000. There is a temporary communication problem, so the broker never gets the request and therefore never responds. Meanwhile, the consumer processed another batch and successfully committed offset 3000. What should you do?
Correct Answer:
D
In this case, because the offset 3000 has been committed and all the messages between 0 and 3000 have all been processed, it is okay not to have committed offset 2000. The right answer is to do "nothing", this behaviour is acceptable