Open
Conversation
Author
|
issue:#80 |
Collaborator
|
@Yurunsoft 你觉得呢? |
Member
|
时间有点久,记不太清了,建议测一下自动创建topic的情况 |
Author
|
我这边基于这个库做二次封装,写测试时发现了这个问题😂,就我测试而言以下两种情况均会导致死循环:
|
Member
|
作为一个库要同时兼顾各种情况,要做到禁用和启用自动创建Topic都可以正常运行 |
Author
赞同,以上说的两个问题在 kafka 开启允许自动创建 topic 并且消费者/生产者为禁用 autoCreateTopic 情况下工作正常,不会出现递归重试问题。 请大佬进一步验证。 |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
当生产者关闭自动创建 topic 参数设置,然后发起投递时会出现获取 topic meta 数据一直重试问题,代码在此陷入递归死循环。基于有问题尽早抛出原则,建议移除
ErrorCode::UNKNOWN_TOPIC_OR_PARTITION这个 case 分支,直接抛出异常。