Home

Welcome to the sarama wiki!

Common user documentation is provided via godoc: https://godoc.org/github.com/Shopify/sarama

This wiki holds more architecture and maintainer-oriented information.

Development

Sarama comes with a Vagrantfile to make it easy to set up a Kafka cluster with 5 brokers inside a virtual machine. Just run vagrant up to set it up. The IP address of the VM is 192.168.100.67.

• Kafka connection string: 192.168.100.67:6667,192.168.100.67:6668,192.168.100.67:6669,192.168.100.67:6670,192.168.100.67:6671
• Zookeeper connection string: 192.168.100.67:2181,192.168.100.67:2182,192.168.100.67:2183,192.168.100.67:2184,192.168.100.67:2185

For integration tests, always use the KAFKA_PEERS environment variables to discover the cluster. If they are not set, use the default connection string that points to the Vagrant cluster above. (For Zookeeper, use ZOOKEEPER_PEERS.)