OrcHome OrcHome
OrcHome个人中心.

▄︻┻═┳一 /hsh

已关注 关注

关注

暂无关注.....

粉丝

暂无粉丝.....


半兽人 回复 ▄︻┻═┳一 /hsh kafka中文教程 中:
已全部修复。
2月前
半兽人 回复 ▄︻┻═┳一 /hsh kafka中文教程 中:
感谢指正,下次升级,优化此错误。
2月前
▄︻┻═┳一 /hsh kafka中文教程 发表评论:
网站中很多“登录”的录字写成了“登陆”,应该是这个字吧“录”,首页最右上角在用户未登录的情况下写成“登陆”,
2月前
半兽人 回复 ▄︻┻═┳一 /hsh kafka消费者客户端(0.10.0.1API) 中:
关键在于这个参数`--from-beginning`。
一个topic有多个partition,每个partition都是有序的。但到客户端的能力不同,有序性就无法保证。如果想要绝对的有序性,那就建一个分区,也就只能有一个客户端来消费了。

7月前
▄︻┻═┳一 /hsh 回复 半兽人 kafka消费者客户端(0.10.0.1API) 中:
也就是说消费者必须先订阅,生产者发送的消息消费者才能接收的到吗?这个能理解,可是使用kafka的生产者客户端kafka-console-producer 先发送消息,再使用kafka-console-consumer.bat --zookeeper localhost:2181 --topic my-replicated-topic --from-beginning也能接收到原先发送的消息,而不会丢失,使用客户度好像好没有发送和接收的先后顺序之说
7月前
半兽人 回复 ▄︻┻═┳一 /hsh kafka消费者客户端(0.10.0.1API) 中:
跟订报纸一样,首先,你要分清楚一个概念。生产者和消费者之间是没有关联的,解耦。在消费者不存在之前,假设就已经有“报纸”在推送了。kafka是不知道谁要订阅这份报纸。当消费者第一次注册之后,之前的报纸是不会补发的。从这一刻开始,kafka才清楚哪个消费者组需要这份报纸。这个时候即使消费者组关闭,停机一段时间,开启之后,没有发给你的“报纸”你也会收到,不会丢失。
8月前
▄︻┻═┳一 /hsh 回复 半兽人 kafka消费者客户端(0.10.0.1API) 中:
刚开始我注释掉auto.offset.reset=earliest的配置,将group.id=myGroupA, 发现还是不行,再次运行API发送消息,使用kafka-console-consumer 发现能接收,我关闭了kafka-console-consumer 命令行,后来我修改了发送消息的key值和和value值,将value值该成“value:”+ i, 配置了auto.offset.reset=earliest,group.id=myGroupA,再次运行消费消息的API,莫名奇妙的API接收到了消息,一顿瞎操作,也不知道为什么就能收到了,谢谢大神指点
8月前
半兽人 回复 ▄︻┻═┳一 /hsh kafka消费者客户端(0.10.0.1API) 中:
props.put("group.id", "test");
换个名字试试。

8月前
▄︻┻═┳一 /hsh kafka消费者客户端(0.10.0.1API) 发表评论:
records = consumer.poll(100);  // 这一行始终获取不到消息,使用kafka-console-producer发送消息,和使用kafka-console-consumer也能接收到消息,使用API也能发送消息,就是使用API获取不到消息,网上有说需要设置auto.offset.reset=earliest, 设置了也还是收不到,我是在windows上单独启动单的一个zookeeper,和三个kafka,不知大神指导原因不,求解惑?

8月前
半兽人 回复 ▄︻┻═┳一 /hsh KafkaStreams客户端(0.10.1.1 API) 中:
没事 多多交流
8月前
▄︻┻═┳一 /hsh 回复 ▄︻┻═┳一 /hsh KafkaStreams客户端(0.10.1.1 API) 中:
不好意思我看错了,我没有引入kafka-streams依赖
8月前
▄︻┻═┳一 /hsh 回复 半兽人 KafkaStreams客户端(0.10.1.1 API) 中:
哦,我看 《消费者客户端(0.10.0.1API)》这章节是用的0.10.0.1,没注意这章节用的是0.10.1.1 最好能统一下版本,不知道是不是笔误,正在拜读,谢谢大神!
8月前
半兽人 回复 ▄︻┻═┳一 /hsh KafkaStreams客户端(0.10.1.1 API) 中:
有的
org.apache.kafka.streams.StreamsConfig
org.apache.kafka.streams.kstream.KStreamBuilder
org.apache.kafka.streams.KafkaStream

8月前
▄︻┻═┳一 /hsh KafkaStreams客户端(0.10.1.1 API) 发表评论:
StreamsConfig、KStreamBuilder、KafkaStreams 这几个类怎么没有,idea中没有提示
8月前
▄︻┻═┳一 /hsh 收藏了 kafka 主题!
8月前
▄︻┻═┳一 /hsh 赞了 kafka中文教程
8月前

半兽人 回复 ▄︻┻═┳一 /hsh kafka中文教程 评论:
已全部修复。
2月前
半兽人 回复 ▄︻┻═┳一 /hsh kafka中文教程 评论:
感谢指正,下次升级,优化此错误。
2月前
▄︻┻═┳一 /hsh kafka中文教程 发表评论:
网站中很多“登录”的录字写成了“登陆”,应该是这个字吧“录”,首页最右上角在用户未登录的情况下写成“登陆”,
2月前
半兽人 回复 ▄︻┻═┳一 /hsh kafka消费者客户端(0.10.0.1API) 评论:
关键在于这个参数`--from-beginning`。
一个topic有多个partition,每个partition都是有序的。但到客户端的能力不同,有序性就无法保证。如果想要绝对的有序性,那就建一个分区,也就只能有一个客户端来消费了。

7月前
▄︻┻═┳一 /hsh 回复 半兽人 kafka消费者客户端(0.10.0.1API) 评论:
也就是说消费者必须先订阅,生产者发送的消息消费者才能接收的到吗?这个能理解,可是使用kafka的生产者客户端kafka-console-producer 先发送消息,再使用kafka-console-consumer.bat --zookeeper localhost:2181 --topic my-replicated-topic --from-beginning也能接收到原先发送的消息,而不会丢失,使用客户度好像好没有发送和接收的先后顺序之说
7月前
半兽人 回复 ▄︻┻═┳一 /hsh kafka消费者客户端(0.10.0.1API) 评论:
跟订报纸一样,首先,你要分清楚一个概念。生产者和消费者之间是没有关联的,解耦。在消费者不存在之前,假设就已经有“报纸”在推送了。kafka是不知道谁要订阅这份报纸。当消费者第一次注册之后,之前的报纸是不会补发的。从这一刻开始,kafka才清楚哪个消费者组需要这份报纸。这个时候即使消费者组关闭,停机一段时间,开启之后,没有发给你的“报纸”你也会收到,不会丢失。
8月前
▄︻┻═┳一 /hsh 回复 半兽人 kafka消费者客户端(0.10.0.1API) 评论:
刚开始我注释掉auto.offset.reset=earliest的配置,将group.id=myGroupA, 发现还是不行,再次运行API发送消息,使用kafka-console-consumer 发现能接收,我关闭了kafka-console-consumer 命令行,后来我修改了发送消息的key值和和value值,将value值该成“value:”+ i, 配置了auto.offset.reset=earliest,group.id=myGroupA,再次运行消费消息的API,莫名奇妙的API接收到了消息,一顿瞎操作,也不知道为什么就能收到了,谢谢大神指点
8月前
半兽人 回复 ▄︻┻═┳一 /hsh kafka消费者客户端(0.10.0.1API) 评论:
props.put("group.id", "test");
换个名字试试。

8月前
▄︻┻═┳一 /hsh kafka消费者客户端(0.10.0.1API) 发表评论:
records = consumer.poll(100);  // 这一行始终获取不到消息,使用kafka-console-producer发送消息,和使用kafka-console-consumer也能接收到消息,使用API也能发送消息,就是使用API获取不到消息,网上有说需要设置auto.offset.reset=earliest, 设置了也还是收不到,我是在windows上单独启动单的一个zookeeper,和三个kafka,不知大神指导原因不,求解惑?

8月前
半兽人 回复 ▄︻┻═┳一 /hsh KafkaStreams客户端(0.10.1.1 API) 评论:
没事 多多交流
8月前
▄︻┻═┳一 /hsh 回复 ▄︻┻═┳一 /hsh KafkaStreams客户端(0.10.1.1 API) 评论:
不好意思我看错了,我没有引入kafka-streams依赖
8月前
▄︻┻═┳一 /hsh 回复 半兽人 KafkaStreams客户端(0.10.1.1 API) 评论:
哦,我看 《消费者客户端(0.10.0.1API)》这章节是用的0.10.0.1,没注意这章节用的是0.10.1.1 最好能统一下版本,不知道是不是笔误,正在拜读,谢谢大神!
8月前
半兽人 回复 ▄︻┻═┳一 /hsh KafkaStreams客户端(0.10.1.1 API) 评论:
有的
org.apache.kafka.streams.StreamsConfig
org.apache.kafka.streams.kstream.KStreamBuilder
org.apache.kafka.streams.KafkaStream

8月前
▄︻┻═┳一 /hsh KafkaStreams客户端(0.10.1.1 API) 发表评论:
StreamsConfig、KStreamBuilder、KafkaStreams 这几个类怎么没有,idea中没有提示
8月前


▄︻┻═┳一 /hsh 收藏了 kafka 主题!
8月前