goka 在单节点 kafka 上创建 topic

要在单节点 Kafka 上使用 Goka 创建主题（topic），您需要遵循以下步骤：

1. 首先，您需要安装和启动 Kafka。您可以从 Kafka 官方网站下载 Kafka 并按照说明进行安装和启动。
2. 然后，您需要安装 Goka。您可以通过运行以下命令来安装 Goka：

go get github.com/lovoo/goka

3. 接下来，您需要编写一个 Goka 应用程序并在其中定义您的主题（topic）。下面是一个示例应用程序：

package main

import (
	"context"
	"fmt"
	"log"

	"github.com/lovoo/goka"
)

const (
	brokers     = "localhost:9092"
	topic       = "my-topic"
	group       = "my-group"
	storagePath = "/tmp/goka-example"
)

func main() {
	g := goka.DefineGroup(group,
		goka.Input(topic, new(goka.StringCodec), func(ctx context.Context, msg interface{}) {
			log.Printf("Received message: %s", msg.(string))
		}),
	)

	p, _, err := goka.NewProcessor(brokers, g, goka.WithStorageBuilder(goka.MemoryStorageBuilder()))
	if err != nil {
		log.Fatalf("Error creating processor: %v", err)
	}

	if err := p.Start(); err != nil {
		log.Fatalf("Error starting processor: %v", err)
	}
	defer p.Stop()

	emitter, err := goka.NewEmitter(brokers, topic, new(goka.StringCodec))
	if err != nil {
		log.Fatalf("Error creating emitter: %v", err)
	}

	if err := emitter.EmitSync("hello world!"); err != nil {
		log.Fatalf("Error emitting message: %v", err)
	}

	fmt.Println("Press any key to exit...")
	fmt.Scanln()
}

这个应用程序定义了一个名为“my-topic”的主题，并将消息打印到控制台。它还使用了内存存储，但您可以使用任何支持的存储类型。最后，它使用了一个发射器（emitter），将“hello world！”消息发送到“my-topic”主题。

4. 最后，您可以使用以下命令运行应用程序：

go run main.go

这将启动应用程序并将“hello world！”消息发送到“my-topic”主题。您可以在控制台中看到收到的消息。

请注意，这只是一个简单的示例，您可以根据您的需求修改它。此外，如果您使用的是真实的 Kafka 集群，您需要将“brokers”变量设置为您的 Kafka 集群的地址。