Open panyicheng123 opened 2 years ago
这个是无法实现的,因为在拉取消息的时候可以指定 offset,而多个 partition 中的 offset 是会重复的。
谢谢作者的回复,提出这个疑问是受到kafka tool工具的启发, 当我选择某个Topic的分区时,我可以将该分区提交的数据进行时间戳排序
当我选择该Topic时,我可以将该Topic下所有分区提交的数据进行时间戳排序
最后感谢作者做出这个很实用的工具,已经打算替代kafka tool
谢谢作者的回复,提出这个疑问是受到kafka tool工具的启发, 当我选择某个Topic的分区时,我可以将该分区提交的数据进行时间戳排序
当我选择该Topic时,我可以将该Topic下所有分区提交的数据进行时间戳排序
最后感谢作者做出这个很实用的工具,已经打算替代kafka tool
非常抱歉,前段时间太忙了。kafka tool 是先把数据获取到本地再进行排序的,kafka-map 则是在服务端完成的从指定位置读取和筛选,后续看下如果有很多都需要这种需求是可以增加的。
谢谢作者的回复,提出这个疑问是受到kafka tool工具的启发, 当我选择某个Topic的分区时,我可以将该分区提交的数据进行时间戳排序
当我选择该Topic时,我可以将该Topic下所有分区提交的数据进行时间戳排序
最后感谢作者做出这个很实用的工具,已经打算替代kafka tool
您好 我想请教一个问题 我的云服务器 kafka listeners=PLAINTEXT://192.168.1.24:9092 配置的是内网地址
而配置了内网地址 offset exploere 外网无法连接上报超时。 这个但是如果我设置的主机名的话 是可以的 但是我还是需要用主机内网IP 这个要怎么解决呢
谢谢作者的回复,提出这个疑问是受到kafka tool工具的启发, 当我选择某个Topic的分区时,我可以将该分区提交的数据进行时间戳排序 当我选择该Topic时,我可以将该Topic下所有分区提交的数据进行时间戳排序 最后感谢作者做出这个很实用的工具,已经打算替代kafka tool
您好 我想请教一个问题 我的云服务器 kafka listeners=PLAINTEXT://192.168.1.24:9092 配置的是内网地址
而配置了内网地址 offset exploere 外网无法连接上报超时。 这个但是如果我设置的主机名的话 是可以的 但是我还是需要用主机内网IP 这个要怎么解决呢
本地的机器也可以使用主机名进行访问,如果你本地机器无法访问外部网络需要在本地搭建一个DNS服务器并配置。
谢谢作者的回复,提出这个疑问是受到kafka tool工具的启发, 当我选择某个Topic的分区时,我可以将该分区提交的数据进行时间戳排序 当我选择该Topic时,我可以将该Topic下所有分区提交的数据进行时间戳排序 最后感谢作者做出这个很实用的工具,已经打算替代kafka tool
您好 我想请教一个问题 我的云服务器 kafka listeners=PLAINTEXT://192.168.1.24:9092 配置的是内网地址
而配置了内网地址 offset exploere 外网无法连接上报超时。 这个但是如果我设置的主机名的话 是可以的 但是我还是需要用主机内网IP 这个要怎么解决呢
你好,你可以尝试以下操作来完成你的预期 配置kafka/config/server.properties
打开listeners的注释,改为 listeners=PLAINTEXT://内网IP:kafka端口
打开advertised.listeners的注释,改为 advertised.listeners=PLAINTEXT://外网IP:外网端口
添加一项: advertised.host.name=主机名