goka change default path

如果你想要改变 Goka 默认的路径，你可以使用 `WithStorageBuilder` 方法来指定一个自定义的存储路径。具体来说，你需要实现 `goka.StorageBuilder` 接口，该接口包含一个 `BuildStorage` 方法，用于创建一个存储实例。在这个方法中，你可以使用自定义的存储路径来创建存储实例。

以下是一个示例代码：

package main

import (
	"fmt"

	"github.com/lovoo/goka"
	"github.com/lovoo/goka/storage"
)

type customStorageBuilder struct {
	basePath string
}

func (b *customStorageBuilder) BuildStorage(topic string, partition int32) (storage.Storage, error) {
	// 使用自定义的路径
	path := fmt.Sprintf("%s/%s/%d", b.basePath, topic, partition)
	return storage.NewDisk(path)
}

func main() {
	// 创建一个自定义存储路径的 StorageBuilder
	builder := &customStorageBuilder{
		basePath: "/path/to/custom/storage",
	}

	// 使用自定义的 StorageBuilder 创建 ProcessorGraph
	g := goka.DefineGroup("my-group",
		goka.Input("my-input-topic", new(myInputCodec), handler),
		goka.Output("my-output-topic", new(myOutputCodec)),
		goka.Persist(new(myTableCodec), builder),
	)

	// 创建一个新的 Processor
	p, err := goka.NewProcessor([]string{"localhost:9092"}, g)
	if err != nil {
		panic(err)
	}

	// 启动 Processor
	if err := p.Run(); err != nil {
		panic(err)
	}
}

在这个示例中，我们创建了一个 `customStorageBuilder` 结构体，它包含一个 `basePath` 字段，表示自定义的存储路径。在 `BuildStorage` 方法中，我们使用自定义的路径来创建存储实例。最后，我们使用自定义的 `customStorageBuilder` 来创建 `Persist` 方法的 Processor。