kafka-do

v0.3.4

kafka-do

What

Higher level abstraction for franz-go.

Why

We want to be able to write our kafka applications without making the same things over and over.

Batch Consume
Consume messages as much as you defined.

Batch Produce
Produce messages as a batch to a topic.

Example

For e2e example, check here.

    producer, err := kafka.NewProducer("127.0.0.1:9092")
    if err != nil {
        log.Fatal(err)
    }
    defer producer.Close()
    producer.Produce(context.Background(), []kafka.Message{
        kafka.Message("message 1"),
        kafka.Message("message 2"),
        kafka.Message("message 3"),
        kafka.Message("message 4"),
    }, "messages")
    consumer, err := kafka.NewConsumer("kafka_do", []string{"messages"}, []string{"127.0.0.1:9092"})
    if err != nil {
        log.Fatal(err)
    }
    defer consumer.Close()
    messages, errs := consumer.ConsumeBatch(context.Background(), 2)
    for _, message := range messages {
        log.Println(message)
    }
    for _, err := range errs {
        log.Println(err)
    }

Development

To run tests, start a kafka that runs on “:9092”.

go test ./... -v -cover -count=1 -race