CeaserWang
CeaserWang
秒杀那个，kafka消费端要多台机器，消费一定要快，如果不快的话，由于你前边都是乐观锁，队列里边会有很多版本号一样的，这样就会有很多数据到了后期消费的时候，是失败的（当然你做了限流），然后我有个疑问是：我有多台机器去消费，比如ABC三台consumer，我用kafka的广播模式，同一条消息会被ABC得到消费，只有由于乐观锁的原因，消息在A创建了订单，在B和C都拒绝了，那这样其实ABC三台机器都是瓶颈（他们有必要不重复接受），如果我让1-26条消息，1-10让A消费，11-20让B消费，21-26让C消费，这样就得使用单播模式，，，单播模式可能就要指定分区生产和指定分区消费，这样的话扩展性不灵活，，，，楼主有没有什么方案？
> > 我用kafka的广播模式，同一条消息会被ABC得到消费， > > 如果是采取的消费组模式，同时 `group.id` 是一样的那肯定不会被 ABC 都取到消息，只会有一个消费者拿到消息。 那这样，得到消费机会的那台机器会一直得到消费机会，其他的2台一直得不到消费机会。多态部署也就失去意思了，，啊~~~~好矛盾~~~
> > 那这样，得到消费机会的那台机器会一直得到消费机会，其他的2台一直得不到消费机会。多态部署也就失去意思了，，啊~~~~好矛盾~~~ > > 并不会啊，假设一个 `Topic` 有 4 个分区，启动了三个进程去消费这个 `Topic` 。 > > * A 进程启动了 2 个 `Consumer` 实例。 > * B 进程 3 个 `Consumer` 实例。 >...