infinilabs / infinilabs/framework
疑问: kafka prefix 为什么不生效？
Open
Nobody has claimed this yet.
- Dominant language
- Go
- Stars
- 29
- Forks
- 21
- Avg merge
- 2d 1h
- Merged PRs (30d)
- 16
Description
我们的 kafka 集群是用于多个业务。所以需要通过 prefix 来区分不同的业务。
我看配置文件定义是有 prefix 的。但是好像实际最终并没有用到 这是出于什么考虑？
Contributor guide
No contributing guide indexed for this repository
First steps
- Read the whole issue, then the project's contributing guide.
- Comment on the issue to say you are picking it up — it saves two people doing the same work.
- Fork the repository and make your change on a branch.
- Open a pull request that references the issue number.
Research direction
Start by locating the Kafka configuration and the code that constructs or uses Kafka topic names, then trace whether the configured prefix reaches the final topic name. Reproduce the behavior with multiple business prefixes and determine whether the prefix is intentionally unused or should affect topic naming; document the finding and expected behavior.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- go, kafka
- Domain
- backend, distributed-systems
- Issue type
- Bug
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 35/100