为什么给topic添加额外的partionNumber

[caibirdme]

订阅的是topic是"foo"，但是收到的message：

msg.Topic == "foo-partition-0"

这样我都没办法对topic进行switch case了…

swtich msg.Topic {
  case "foo":
    doFoo(msg)
  case "bar":
    doBar(msg)
  default:
    doOther(msg)
}

[edocevol]

通过分区来提高吞吐率的

[caibirdme]

通过分区来提高吞吐率的

我的意思是，msgID里已经包含了分区信息了，Topic里再包含partition似乎没太大意义，而且还造成了额外的负担，消费时想针对不同topic进行处理还得做字符串切分