Question 51
What is a generic unique id that I can use for messages I receive from a consumer?
Question 52
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?
Question 53
A client connects to a broker in the cluster and sends a fetch request for a partition in a topic. It gets an exception Not Leader For Partition Exception in the response. How does client handle this situation?
Question 54
Where are KSQL-related data and metadata stored?
Question 55
Which Kafka CLI should you use to consume from a topic?