goka example

以下是一个简单的 Goka 示例，它从一个 Kafka 主题中读取字符串，将字符串转换为大写，并将结果写入另一个 Kafka 主题中：

package main

import (
    "fmt"
    "strings"

    "github.com/lovoo/goka"
)

func main() {
    // 定义输入和输出主题名称
    inputTopic := "input-topic"
    outputTopic := "output-topic"

    // 定义处理器函数
    process := func(ctx goka.Context, msg interface{}) {
        // 将收到的消息转换为字符串并转换为大写
        str := strings.ToUpper(msg.(string))

        // 将结果写入输出主题
        ctx.Emit(outputTopic, nil, str)
    }

    // 定义 Goka 处理器
    g := goka.DefineGroup(goka.Group("my-group"),
        goka.Input(inputTopic, new(goka.StringCodec), process),
        goka.Output(outputTopic, new(goka.StringCodec)),
    )

    // 创建 Goka 处理器并启动
    p, err := goka.NewProcessor([]string{"localhost:9092"}, g)
    if err != nil {
        panic(err)
    }
    if err := p.Start(); err != nil {
        panic(err)
    }

    // 发送测试消息到输入主题
    p.Emit(inputTopic, "hello world")

    // 等待程序退出
    <-p.Done()
}

在这个示例中，我们创建了一个 Goka 处理器，定义了一个输入主题和一个输出主题，并将一个处理函数绑定到输入主题中。当接收到消息时，处理函数将消息转换为大写并将结果写入输出主题。最后，我们创建一个 Goka 处理器实例并启动它，发送一个测试消息到输入主题，并等待程序退出。