This is an automated email from the ASF dual-hosted git repository. penghui pushed a commit to branch branch-2.8 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit f5fcf57954c3cc7910b32890a0bcb33bc67ff81f Author: penghui <[email protected]> AuthorDate: Thu Oct 21 17:09:12 2021 +0800 Fix cherry-pick issue --- .../org/apache/pulsar/client/impl/BatchMessageContainerImplTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pulsar-client/src/test/java/org/apache/pulsar/client/impl/BatchMessageContainerImplTest.java b/pulsar-client/src/test/java/org/apache/pulsar/client/impl/BatchMessageContainerImplTest.java index 3d55487..3caf4bc 100644 --- a/pulsar-client/src/test/java/org/apache/pulsar/client/impl/BatchMessageContainerImplTest.java +++ b/pulsar-client/src/test/java/org/apache/pulsar/client/impl/BatchMessageContainerImplTest.java @@ -60,14 +60,14 @@ public class BatchMessageContainerImplTest { messageMetadata1.setProducerName("producer1"); messageMetadata1.setPublishTime(System.currentTimeMillis()); ByteBuffer payload1 = ByteBuffer.wrap("payload1".getBytes(StandardCharsets.UTF_8)); - final MessageImpl<byte[]> message1 = MessageImpl.create(messageMetadata1, payload1, Schema.BYTES, null); + final MessageImpl<byte[]> message1 = MessageImpl.create(messageMetadata1, payload1, Schema.BYTES); batchMessageContainer.add(message1, null); MessageMetadata messageMetadata2 = new MessageMetadata(); messageMetadata2.setSequenceId(1L); messageMetadata2.setProducerName("producer1"); messageMetadata2.setPublishTime(System.currentTimeMillis()); ByteBuffer payload2 = ByteBuffer.wrap("payload2".getBytes(StandardCharsets.UTF_8)); - final MessageImpl<byte[]> message2 = MessageImpl.create(messageMetadata2, payload2, Schema.BYTES, null); + final MessageImpl<byte[]> message2 = MessageImpl.create(messageMetadata2, payload2, Schema.BYTES); // after oom, our add can self-healing, won't throw exception batchMessageContainer.add(message2, null); }
