OrcHome OrcHome
OrcHome个人中心.

小八路

已关注 关注

关注

暂无关注.....

粉丝

暂无粉丝.....


半兽人 回复 小八路 kafka steams中ktable中的数据,会失效吗? 中:
ok,感谢分享。
3月前
小八路 回复 半兽人 kafka steams中ktable中的数据,会失效吗? 中:
是的
3月前
半兽人 回复 小八路 kafka steams中ktable中的数据,会失效吗? 中:
是过了有效期进行的重启吗?
3月前
小八路 回复 半兽人 kafka steams中ktable中的数据,会失效吗? 中:
我实验了一下,在 stream 中关联ktable,如果stream 程序不重启,则该stream会一直持有这个table中的变化,并保证这种关联有效;
如果重启,则在启动的时候报一个错误,说的是 offset 不一致。然后正常运行,并丢失之前保存的ktable数据,如果这个时候再进行关联,则无法关联。
如果有其他人有不同的实验结果,欢迎交流~
3月前
发表了 kafka steams中ktable中的数据,会失效吗?
3月前
小八路 回复 小八路 kafka-stream运行报错 中:
Problem solved by changing jre 32-bit to 64-bit.
3月前
小八路 kafka-stream运行报错 发表评论:
https://github.com/confluentinc/kafka-streams-examples/issues/91
3月前
小八路 回复 落樱留独殇 KafkaStreams客户端(0.10.1.1 API) 中:
我在例子中这样将结果输出到两个topic的
  wordCounts.toStream().to("streams-plaintext-output", Produced.with(Serdes.String(), Serdes.Long()));
  wordCounts.toStream().to("my-replicated-topic", Produced.with(Serdes.String(), Serdes.Long()));

4月前
小八路 收藏了 kafka 主题!
4月前

半兽人 回复 小八路 kafka steams中ktable中的数据,会失效吗? 评论:
ok,感谢分享。
3月前
小八路 回复 半兽人 kafka steams中ktable中的数据,会失效吗? 评论:
是的
3月前
半兽人 回复 小八路 kafka steams中ktable中的数据,会失效吗? 评论:
是过了有效期进行的重启吗?
3月前
小八路 回复 半兽人 kafka steams中ktable中的数据,会失效吗? 评论:
我实验了一下,在 stream 中关联ktable,如果stream 程序不重启,则该stream会一直持有这个table中的变化,并保证这种关联有效;
如果重启,则在启动的时候报一个错误,说的是 offset 不一致。然后正常运行,并丢失之前保存的ktable数据,如果这个时候再进行关联,则无法关联。
如果有其他人有不同的实验结果,欢迎交流~
3月前
小八路 回复 小八路 kafka-stream运行报错 评论:
Problem solved by changing jre 32-bit to 64-bit.
3月前
小八路 kafka-stream运行报错 发表评论:
https://github.com/confluentinc/kafka-streams-examples/issues/91
3月前
小八路 回复 落樱留独殇 KafkaStreams客户端(0.10.1.1 API) 评论:
我在例子中这样将结果输出到两个topic的
  wordCounts.toStream().to("streams-plaintext-output", Produced.with(Serdes.String(), Serdes.Long()));
  wordCounts.toStream().to("my-replicated-topic", Produced.with(Serdes.String(), Serdes.Long()));

4月前


小八路 收藏了 kafka 主题!
4月前