Skip to content

Commit 034e6a4

Browse files
authored
[fix][test] Fix testLargeMessage doesn't respect the parameter clientSizeMaxMessageSize (#18452)
Signed-off-by: Zike Yang <zike@apache.org>
1 parent c47f2ed commit 034e6a4

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

pulsar-broker/src/test/java/org/apache/pulsar/client/impl/MessageChunkingTest.java

+4-4
Original file line numberDiff line numberDiff line change
@@ -116,10 +116,10 @@ public void testInvalidConfig() throws Exception {
116116
public void testLargeMessage(boolean ackReceiptEnabled, boolean clientSizeMaxMessageSize) throws Exception {
117117

118118
log.info("-- Starting {} test --", methodName);
119-
clientSizeMaxMessageSize = false;
120-
this.conf.setMaxMessageSize(50);
121119
if (clientSizeMaxMessageSize) {
122-
this.conf.setMaxMessageSize(5);
120+
this.conf.setMaxMessageSize(35);
121+
} else {
122+
this.conf.setMaxMessageSize(50);
123123
}
124124
final int totalMessages = 5;
125125
final String topicName = "persistent://my-property/my-ns/my-topic1";
@@ -130,7 +130,7 @@ public void testLargeMessage(boolean ackReceiptEnabled, boolean clientSizeMaxMes
130130

131131
ProducerBuilder<byte[]> producerBuilder = pulsarClient.newProducer().topic(topicName);
132132
if (clientSizeMaxMessageSize) {
133-
producerBuilder.chunkMaxMessageSize(5);
133+
producerBuilder.chunkMaxMessageSize(35);
134134
}
135135

136136
Producer<byte[]> producer = producerBuilder.compressionType(CompressionType.LZ4).enableChunking(true)

0 commit comments

Comments
 (0)