apache / apache/pulsar-client-cpp

disableReplication in MessageBuilder does not work in PulsarClient C++ and Java

Offen
#81 4 Kommentare 0 Reaktionen 0 zugewiesene Personen Auf GitHub ansehen
Vorherrschende Sprache
C++
Sterne
71
Forks
90
Ø Merge
2 Std. 33 Min.
Gemergte PRs (30 T.)
3

Beschreibung

**Describe the bug**
Data is still replicated when disableReplication is enabled

**To Reproduce**
Steps to reproduce the behavior:
1. Setup Geo-Replication with 3 cluster(A,B,C)
2. Set disableReplication = true in MessageBuilder
```
Message msg = MessageBuilder().setContent("repl").disableReplication(true).build();
```
3. Producer create connect in cluster C and send ```Message msg```
```
producer.sendAsync(msg, notifySendMessage);
```
**Actual output is consumer**
1. Cluster A
```
Received message: repl
```
2. Cluster A
```
Received message: repl
```
3. Cluster C
```
Received message: repl
```
**Expected output is**
1. Cluster A
```
```
2. Cluster A
```
```
3. Cluster C
```
Received message: repl
```

Pulsar version: 2.3.0

Beitragsleitfaden

Beitragsleitfaden öffnen

Rechercherichtung

Start by tracing MessageBuilder.disableReplication(true) through the C++ client and the producer.sendAsync path, using the three-cluster geo-replication steps to reproduce the behavior. Done means a message sent from cluster C remains in C and is not received by clusters A or B when replication is disabled.

Vom Indexierungsmodell aus dem Issue-Text verfasst.

Bewertung

Tech-Stack
cpp, java
Bereich
distributed-systems
Issue-Typ
Bug
Schwierigkeit
4/5
Geschätzter Aufwand
3-5 Tage
Aktivitätsstatus
Veraltet
Klarheit
Größtenteils klar
Anfängerfreundlichkeit
35/100

Neue Issues direkt in Ihr Postfach

Eine kurze Übersicht über anfängerfreundliche GitHub-Issues.