lhotari commented on code in PR #23942:
URL: https://github.com/apache/pulsar/pull/23942#discussion_r2322916452
##########
pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/TransactionTest.java:
##########
@@ -484,6 +485,42 @@ public void testAsyncSendOrAckForSingleFuture() throws
Exception {
});
}
+ @Test
+ public void testSendAndAckWithSchema() throws Exception {
+ String topic = NAMESPACE1 + "/testAsyncSendAndAckWithSchema";
+ String topicName = "subscription";
+
getPulsarServiceList().get(0).getConfig().setBrokerDeduplicationEnabled(false);
+
+ @Cleanup
+ Producer<byte[]> producer = pulsarClient.newProducer()
+ .topic(topic)
+ .producerName("producer")
+ .sendTimeout(0, TimeUnit.SECONDS)
+ .create();
+
+ @Cleanup
+ Consumer<byte[]> consumer = pulsarClient.newConsumer()
+ .topic(topic)
+ .subscriptionType(SubscriptionType.Exclusive)
+ .subscriptionName(topicName)
+ .subscribe();
+
+ Transaction txn = pulsarClient.newTransaction()
+ .withTransactionTimeout(10, TimeUnit.SECONDS)
+ .build()
+ .get();
+
+ MessageId messageId = producer.newMessage(Schema.STRING, txn)
+ .value("testSendAndAckWithSchema")
+ .send();
+
+ txn.commit().get();
+
+ Message<byte[]> message = consumer.receive();
Review Comment:
@congbobo184 There's already `Schema.STRING`, why wouldn't that be
representative? I'd like to get this PR merged since it's also required by
upcoming PIP-439, #24704.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
