Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

kafka 订阅通配符主题报错 #69

Closed
fredmuyu opened this issue Dec 19, 2023 · 3 comments
Closed

kafka 订阅通配符主题报错 #69

fredmuyu opened this issue Dec 19, 2023 · 3 comments

Comments

@fredmuyu
Copy link

我订阅主题为:admin*invokereply,结果一直报错,不适用通配符主题就是正常的,不知道是我哪里理解不对吗?

caller=kafka/logger.go:16 trace_id= span_id= msg=Failed to join group local1: [17] Invalid Topic: a request which attempted to access an invalid topic (e.g. one which has an illegal name), or if an attempt was made to write to an internal topic (such as the consumer offsets topic)
caller=kafka/kafka.go:615 trace_id= span_id= msg=[kafka] FetchMessage error: [admin*invokereply][17] Invalid Topic: a request which attempted to access an invalid topic (e.g. one which has an illegal name), or if an attempt was made to write to an internal topic (such as the consumer offsets topic)
caller=kafka/logger.go:16 trace_id= span_id= msg=Failed to sync group local1: [27] Rebalance In Progress: the coordinator has begun rebalancing the group, the client should rejoin the group
caller=kafka/logger.go:16 trace_id= span_id= msg=Failed to sync group local1: [27] Rebalance In Progress: the coordinator has begun rebalancing the group, the client should rejoin the group
caller=kafka/logger.go:16 trace_id= span_id= msg=[17] Invalid Topic: a request which attempted to access an invalid topic (e.g. one which has an illegal name), or if an attempt was made to write to an internal topic (such as the consumer offsets topic)
caller=kafka/logger.go:16 trace_id= span_id= msg=[27] Rebalance In Progress: the coordinator has begun rebalancing the group, the client should rejoin the group
caller=kafka/logger.go:16 trace_id= span_id= msg=[27] Rebalance In Progress: the coordinator has begun rebalancing the group, the client should rejoin the group

@fredmuyu
Copy link
Author

另外关闭程序的时候会有大量EOF日志,

caller=kafka/server.go:125 trace_id= span_id= kafka=server stopping
caller=kafka/kafka.go:615 trace_id= span_id= msg=[kafka] FetchMessage error: EOF
caller=kafka/kafka.go:615 trace_id= span_id= msg=[kafka] FetchMessage error: EOF
caller=kafka/kafka.go:615 trace_id= span_id= msg=[kafka] FetchMessage error: EOF
caller=kafka/kafka.go:615 trace_id= span_id= msg=[kafka] FetchMessage error: EOF
...

@tx7do
Copy link
Owner

tx7do commented Mar 9, 2024

FetchMessage error: EOF 这个问题我知道,官方有相关的Issue,还不知道该如何处理比较好。反正不影响,我也就暂时没去管这茬子事儿了。

@tx7do
Copy link
Owner

tx7do commented May 24, 2024

segmentio/kafka-go#283
segmentio/kafka-go#131

官方的Issue显示,他们暂时不支持通配符订阅。

@tx7do tx7do closed this as completed May 24, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants