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.