Examples using... log.Fatalln()

Recent
This example shows the basic usage pattern of the SyncProducer.
By default, Sarama uses the message's key to consistently assign a partition to a message using hashing. If no key is set, a random partition will be chosen. This example shows how you can partition messages randomly, even when a key is set, by overriding Config.Producer.Partitioner.
This example shows how to assign partitions to your messages manually.
This example shows how to use the consumer to read messages from a single partition.
This example shows how to use the producer while simultaneously reading the Errors channel to know about any failures.
This example uses RawMessage to delay parsing part of a JSON message.
WriteAll writes multiple CSV records to w using Write and then calls Flush, returning any error from the Flush.
A Writer writes records using CSV encoding.