2018-03-27 10:36:37 UTC - jia zhai: @Igor Zubchenok 2. Since BatchingEnabled, Then messages may batched together, and written in to a same message, so it will output same id. But the returned messageId is type of `BatchMessageIdImpl`, `System.out.println("A: " + (BatchMessageIdImpl)messageId);` should print the different id, which also contains the batchIndex. ---- 2018-03-27 10:39:05 UTC - jia zhai: 3. It is identified by name, so with the same topic+subscription name, There may no need additional work. but different type of subscription (exclusive, failover, shared), may behaviour different. ``` public enum SubscriptionType { /** * There can be only 1 consumer on the same topic with the same subscription name */ Exclusive,
/** * Multiple consumer will be able to use the same subscription name and the messages will be dispatched according to * a round-robin rotation between the connected consumers */ Shared, /** * Multiple consumer will be able to use the same subscription name but only 1 consumer will receive the messages. * If that consumer disconnects, one of the other connected consumers will start receiving messages. */ Failover } ``` +1 : Igor Zubchenok ---- 2018-03-27 11:08:11 UTC - Igor Zubchenok: Returned batchIndex is the same for all batched messages. Is it ok? ---- 2018-03-27 11:23:15 UTC - jia zhai: batchIndex should be different ---- 2018-03-27 11:28:07 UTC - jia zhai: ledgerid : entryid : partitionIndex : batchIndex first 3 maybe same, but batchIndex should be different. ---- 2018-03-27 13:31:19 UTC - Igor Zubchenok: So should I file an issue in github for this case? ---- 2018-03-27 13:37:11 UTC - jia zhai: please go ahead file it. ---- 2018-03-27 13:37:17 UTC - jia zhai: Thank ---- 2018-03-27 13:37:18 UTC - jia zhai: thanks ---- 2018-03-27 14:46:55 UTC - Igor Zubchenok: new issue at github: <https://github.com/apache/incubator-pulsar/issues/1455> ----