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?