这个要怎么靠kafka和idea实现啊😭
主要模拟kafka的生产环境，虚拟机kafka我有，但是在代码编程中就不会了😭
求源码或是思路…😭
kafka模拟数据生产怎么实现呀！？？
- 写回答
- 好问题 0 提建议
- 追加酬金
- 关注问题
分享- 邀请回答
-
2条回答 默认 最新
sum墨 2022-06-07 16:46关注想要实现这个问题需要如下几步：
1、确定输入的志愿者数据的格式，比如：{"name":"志愿者1","age":28}
2、SpringBoot集成Kafka，创建消费者服务
3、获取Kafka中的数据，进行解析。将这三个年龄段创建三个List，将满足条件的数据塞入List，List的size大小也就是该年龄段的人数了
想要源码的话，私聊本回答被题主选为最佳回答 , 对您是否有帮助呢?解决评论 打赏无用 1举报 编辑记录 分享
- 2022-06-07 15:30回答 2 已采纳 想要实现这个问题需要如下几步：1、确定输入的志愿者数据的格式，比如：{"name":"志愿者1","age":28}2、SpringBoot集成Kafka，创建消费者服务3、获取Kafka中的数据，进
- 2022-09-01 17:56回答 2 已采纳 似乎是权限问题，你可以看看报错的文件路径权限组看看，使用 ls -l /home/…
- 2022-02-16 19:32回答 4 已采纳 重新开一个topic，然后先启动consumer，再启动producer，再发消息，你这个可能是consumer已经在broker里有了自己的offset，就会读不到之前producer发送到brok
- 2021-07-24 00:01码农_程序员的博客 我们今天介绍通过java代码实现producer，包含了上一篇对参数的介绍，我们在发送Kafka主题时，参数配置也很重要，影响数据可靠性、吞吐量 对Kafka 介绍、部署、配置参数的介绍可以参考前面的文章，我们对代码先...
- 2023-02-02 16:54回答 4 已采纳 ''该回答引用ChatGPT''如对你的问题有帮助，请点击右侧采纳即可！没有使用ZooKeeper的话，一种可行的方案是利用ClickHouse的复制功能实现双机数据同步。ClickHouse的复制功
- 2021-12-29 09:57回答 1 已采纳 可从内部看到每次加载的偏移量，以及提交时间。 gbase> select * from kafka_load_testdb_tt1_testdb_tt1;+-------+-----------
- 2022-01-10 15:46回答 3 已采纳 消费者和生产者与机器无关，这是不同的概念，消费者与生产者只是在Kafka中的角色，不同角色干不同的事情
- 2021-11-19 23:00独行侠梦的博客 在这篇文章中，我将解释Kafka Streams抑制的概念。尽管它看起来很容易理解，但还是有一些内在的问题/事情是必须要了解的。这是我上一篇博文CDC分析的延续。◆架构一个典型的CDC架构...
- 2022-07-13 14:53回答 1 已采纳 尚硅谷的电商案例里面有介绍
- 2022-01-28 09:47回答 1 已采纳 那最后写入到库了吗，如果写不进去，上游kafka肯定会延迟越来越大的，可以在sink里多打印下错误，或者设置写入超时时间，问题应该在写入
- 2022-06-11 10:41回答 1 已采纳 给你个例子，是可以收发的。验证通过再和你的对比一下，你应该哪里配错了。 springboot集成kafka、消息发送、消费使用_‘’小磊的博客-CSDN博客_spri
- 2022-04-01 10:22Gadaite的博客 02.使用python语言，对Kafka进行数据的写入 from kafka import KafkaProducer from kafka.errors import KafkaError producer = KafkaProducer(bootstrap_servers='192.168.1.10:9092') while True:
- 2022-07-13 20:33回答 3 已采纳 restclient异常，先看看taskmanager和jobmanager是否正常，然后你可以在jobmanager的节点上访问webUI查看job状态，又或者直接查看宿主机上的日志排查问题
- 2021-03-13 09:33牵牛刘先生的博客 一关于kafaka的特点 1实时流 Apache Kafka是一个实时流平台，在大大小小的...毫无疑问，Kafka是一个开源项目，它改变了企业在云和数据中心内移动数据的方式。 2架构 Kafka的架构已经被优化为在系统和应用程序之间以可伸
- 2023-05-26 11:46阿福的小书斋的博客 Spark Streaming+kafka任务实践
- 没有解决我的问题, 去提问
问题事件
已结题
（查看结题原因） 6月8日-
已采纳回答
6月8日
-
赞助了问题酬金5元
6月7日
-
创建了问题
6月7日
悬赏问题
- ¥15 csmar数据进行spss描述性统计分析
- ¥15 各位请问平行检验趋势图这样要怎么调整？说标准差差异太大了
- ¥15 delphi webbrowser组件网页下拉菜单自动选择问题
- ¥15 wpf界面一直接收PLC给过来的信号，导致UI界面操作起来会卡顿
- ¥15 init i2c:2 freq:100000[MAIXPY]: find ov2640[MAIXPY]: find ov sensor是main文件哪里有问题吗
- ¥15 运动想象脑电信号数据集.vhdr
- ¥15 三因素重复测量数据R语句编写，不存在交互作用
- ¥15 微信会员卡等级和折扣规则
- ¥15 微信公众平台自制会员卡可以通过收款码收款码收款进行自动积分吗
- ¥15 随身WiFi网络灯亮但是没有网络，如何解决？