amareshmad commented on issue #116:
URL:
https://github.com/apache/pulsar-dotpulsar/issues/116#issuecomment-1283640007
@blankensteiner: pulsar supports with raw bytes & specific schema to
transmit/receive.
Creating consumer with schema like string, bytearray,sequence . when I
convert the consumer message data bytes to string,
stringData = Encoding.UTF8.GetString(message.Data.ToArray()). there is no
change in the received stringData format.
What is best way to parse this kind of data. Producer side (java) saying
they are creating properties and putting them into map, converting them and
sending to pulsar server, the server is also nothing changes, when we receive
lot of ascii, how can we avoid these by converting raw bytes.
I saw few people are using in Java they have PulsarTextMessage to convert
the bytes streams into data. (Similar to active mq ITextMessage)
ByteArrayInputStream bais = new ByteArrayInputStream((byte[]) msg.getBody());
ObjectInputStream in = null;
PulsarTextMessage pulsarTextMessage = null;
Map<String, Object> headersMap = new HashMap<>();
try {
in = new ObjectInputStream(bais);
pulsarTextMessage = ((PulsarTextMessage) in.readObject());
System.out.println("from pulsar-jms-client:, msg is retreived from
pulsarTextMessage "+pulsarTextMessage.getText());
System.out.println("from pulsar-jms-client:, headers will be retrieved from
pulsarTextMessage");
System.out.println(pulsarTextMessage.getJMSDeliveryMode());
System.out.println(pulsarTextMessage.getJMSDestination());
System.out.println(pulsarTextMessage.getJMSType());
}
--
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]
