Kafka - Broker (Kafka Server)

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