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>
----