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

你好作者,可以在对拉取数据的模块里面新增按所有partition排序的功能吗,而不是只能选择一个partition #40

Open
panyicheng123 opened this issue Jun 30, 2022 · 6 comments

Comments

@panyicheng123
Copy link

image

@dushixiang
Copy link
Owner

这个是无法实现的,因为在拉取消息的时候可以指定 offset,而多个 partition 中的 offset 是会重复的。

@panyicheng123
Copy link
Author

谢谢作者的回复,提出这个疑问是受到kafka tool工具的启发,
当我选择某个Topic的分区时,我可以将该分区提交的数据进行时间戳排序
image

当我选择该Topic时,我可以将该Topic下所有分区提交的数据进行时间戳排序
image

最后感谢作者做出这个很实用的工具,已经打算替代kafka tool

@dushixiang
Copy link
Owner

谢谢作者的回复,提出这个疑问是受到kafka tool工具的启发, 当我选择某个Topic的分区时,我可以将该分区提交的数据进行时间戳排序 image

当我选择该Topic时,我可以将该Topic下所有分区提交的数据进行时间戳排序 image

最后感谢作者做出这个很实用的工具,已经打算替代kafka tool

非常抱歉,前段时间太忙了。kafka tool 是先把数据获取到本地再进行排序的,kafka-map 则是在服务端完成的从指定位置读取和筛选,后续看下如果有很多都需要这种需求是可以增加的。

@chenshengshi
Copy link

chenshengshi commented May 8, 2023

谢谢作者的回复,提出这个疑问是受到kafka tool工具的启发, 当我选择某个Topic的分区时,我可以将该分区提交的数据进行时间戳排序 image

当我选择该Topic时,我可以将该Topic下所有分区提交的数据进行时间戳排序 image

最后感谢作者做出这个很实用的工具,已经打算替代kafka tool

您好 我想请教一个问题 我的云服务器 kafka listeners=PLAINTEXT://192.168.1.24:9092
配置的是内网地址
image

而配置了内网地址 offset exploere 外网无法连接上报超时。 这个但是如果我设置的主机名的话 是可以的 但是我还是需要用主机内网IP 这个要怎么解决呢

@dushixiang
Copy link
Owner

谢谢作者的回复,提出这个疑问是受到kafka tool工具的启发, 当我选择某个Topic的分区时,我可以将该分区提交的数据进行时间戳排序 image
当我选择该Topic时,我可以将该Topic下所有分区提交的数据进行时间戳排序 image
最后感谢作者做出这个很实用的工具,已经打算替代kafka tool

您好 我想请教一个问题 我的云服务器 kafka listeners=PLAINTEXT://192.168.1.24:9092 配置的是内网地址 image

而配置了内网地址 offset exploere 外网无法连接上报超时。 这个但是如果我设置的主机名的话 是可以的 但是我还是需要用主机内网IP 这个要怎么解决呢

本地的机器也可以使用主机名进行访问,如果你本地机器无法访问外部网络需要在本地搭建一个DNS服务器并配置。

@panyicheng123
Copy link
Author

谢谢作者的回复,提出这个疑问是受到kafka tool工具的启发, 当我选择某个Topic的分区时,我可以将该分区提交的数据进行时间戳排序 image
当我选择该Topic时,我可以将该Topic下所有分区提交的数据进行时间戳排序 image
最后感谢作者做出这个很实用的工具,已经打算替代kafka tool

您好 我想请教一个问题 我的云服务器 kafka listeners=PLAINTEXT://192.168.1.24:9092 配置的是内网地址 image

而配置了内网地址 offset exploere 外网无法连接上报超时。 这个但是如果我设置的主机名的话 是可以的 但是我还是需要用主机内网IP 这个要怎么解决呢

你好,你可以尝试以下操作来完成你的预期
配置kafka/config/server.properties

打开listeners的注释,改为
listeners=PLAINTEXT://内网IP:kafka端口

打开advertised.listeners的注释,改为
advertised.listeners=PLAINTEXT://外网IP:外网端口

添加一项:
advertised.host.name=主机名

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

3 participants