thesquiff opened a new issue #9851:
URL: https://github.com/apache/pulsar/issues/9851
**Describe the bug**
I have been developing a couple of Pulsar IO Source connectors. They are
able to write out message bodies but properties (even though the
getProperties() message does appear to be called) are not added to the messages
published onto the destination topic.
A minimal test case can be demonstrated by adding properties to the Data
Generator Source.
**To Reproduce**
Add the following to DataGeneratorSource.java and then build and deploy the
connector:
@Override
public Map<String, String> getProperties() {
HashMap<String, String> props = new HashMap<String,
String>();
props.put("hello", "world");
props.put("foo", "bar");
return props;
}
**Expected behavior**
A message is published onto the destination topic with both the generated
message contents (json representation of a person) and the properties as hard
coded above. However the properties are missing.
Tested on Pulsar 2.7.0
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
