GitHub user Shalima added a comment to the discussion: Test / Experiment
Batching locally
Producer.
```
Producer<byte[]> producer = client.newProducer().topic(topicName).create();
log.info("Created producer: " + topicName);
for (int i = 0; i < numMsgs; i++) {
String msg = "Message " + i;
byte[] bytePayload = msg.getBytes();
MessageId msgId =
producer.newMessage().value(bytePayload).send();
log.info("Message Produced. Producer Name: " +
producer.getProducerName() + " Message Id: " + msgId);
}
producer.close();
```
Consumer
```
Consumer consumer = client.newConsumer()
.topic(topicName)
.subscriptionName(subscriptionName).subscribe();
List<String> msgReceived = new ArrayList<String>();
while(true){
Message msg = consumer.receive();
byte[] plainPayload = decryptor.decrypt(msg.getData());
String msgText = new String(plainPayload);
msgReceived.add(msgText);
log.info("Consumer Name: " + consumer.getConsumerName()
+ " Message : " + msgText);
System.out.println(String.format("Message Recieved
consumer_name=%s message=%s",
consumer.getConsumerName(), msgText));
consumer.acknowledge(msg);
}
consumer.close();
client.close();
```
GitHub link:
https://github.com/apache/pulsar/discussions/17027#discussioncomment-3363364
----
This is an automatically sent email for [email protected].
To unsubscribe, please send an email to: [email protected]
