这家伙太懒,什么都没留下
可以解决。逻辑层你自己写,注意线程work会启动多个,注意线程安全。
类似于我用kafka consumer从topic的分区中采集出了一批数据,这批数据我需要启5个线程向mysql中并行的插入数据。这样的需求使用kafka stream 会不会得到解决呢?
请问我想要实现以下功能:对于一个分区来说,采集出来的数据被多个线程并行的写入到mysql中。这个需要如何实现呢?
这是自然了,资源是有限的。
暂时的情况就是集群和消费者需要在同一个集群中,所以还是需要分别启动在三台机器上比较好么?