Table of Contents

Function

  • Manages list of partition
  • Acks the message (Producer doesn't need to resend the data}
  • Commits the message (Consumer can now read it)
  • Replicate data
  • Durability Guarantees (min.insync.replicas & request.required.acks). Set min.insync.replicas = 2, request.required.acks = -1 for replicating to two replicas before a write.

Management

Start

kafka-server-start.sh ~/kafka/config/server.properties