You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@pulsar.apache.org by Apache Pulsar Slack <ap...@gmail.com> on 2018/03/28 09:11:02 UTC
Slack digest for #dev - 2018-03-28
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>
----