不能创建topic

[testwill]

output不能直接创建topic

[childe]

Kafka 中配置了不能自动创建Topic，我建议要么配置成允许自动创建，要么事先创建好？

目前没有规划捕获这个报错并再次尝试创建Topic，后面有时间我拿 AI 来帮我编码下。

[testwill]

你说的是kafka服务吗？ 这个我配置了自动创建的， 通过github.com/IBM/sarama 这个是可以自动创建出来的

[childe]

你说的不能直接创建Topic是指什么？

output不能直接创建topic

[testwill]

就是不存在的kafka topic， 我不想通过手动去先创建好，希望程序output可以创建出来

[childe]

https://kafka.apache.org/documentation/#brokerconfigs_auto.create.topics.enable

这个参数是配置了 true ? 那感觉应该是可以的。

[testwill]

auto.create.topics.enable=true
这个配置不行吗？ 默认就是开启的

[childe]

auto.create.topics.enable=true 这个配置不行吗？ 默认就是开启的

按我的理解是可以的，你可以发一下你的Gohangout的报错吗？

[testwill]

F0721 09:51:50.485311 2894392 kafka_output.go:63] could not create kafka producer: update current simple consumer of this_is_a_test error: get metadata of this_is_a_test error: this_is_a_test error: This server does not host this topic-partition.

[childe]

F0721 09:51:50.485311 2894392 kafka_output.go:63] could not create kafka producer: update current simple consumer of this_is_a_test error: get metadata of this_is_a_test error: this_is_a_test error: This server does not host this topic-partition.

我这边测下来，复现不了。

1. 你的Gohangout 版本是啥？
2. gohangout 配置文件发一下？

[childe]

报错日志里面有 "update current simple consumer" 这样的字眼，是一个笔误，在 bde7f0d 里面修改了，是今年4.8号的。问下你的版本是啥，我再测一下看。

[testwill]

同事基于这个定制了 不知道怎么看版本信息 应该至少是去年的版本

[childe]

同事基于这个定制了 不知道怎么看版本信息 应该至少是去年的版本

go.mod 里面直接把 healer 升级到 github.com/childe/healer v0.6.22 再build一下， 我觉得应该是可以的。

[testwill]

你说的是这个呀 我的版本是 github.com/childe/healer v0.6.0

[childe]

我也用 github.com/childe/healer v0.6.0 这个版本测试了，也没复现你的问题。Topic都是自动创建的。

Kafka用 2.5.1 和 3.7.1 都测了，都是没问题的。

[testwill]

bitnami/kafka:4.0.0 我用的是这个镜像