[GitHub] [pulsar] Shalima added a comment to the discussion: Test / Experiment Batching locally

[GitBox <gi...@apache.org>]

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 dev@pulsar.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@pulsar.apache.org