Question 1

A topic has three replicas and you set min.insync.replicas to 2. If two out of three replicas are not available, what happens when a consume request is sent to broker?
  • Question 2

    A consumer is configured with enable.auto.commit=false. What happens when close() is called on the consumer object?
  • Question 3

    A consumer has auto.offset.reset=latest, and the topic partition currently has data for offsets going from 45 to 2311. The consumer group never committed offsets for the topic before. Where will the consumer read from?
  • Question 4

    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?
  • Question 5

    When using the Confluent Kafka Distribution, where does the schema registry reside?