GitHub user smuehlmann edited a discussion: Pulsar 3.2.2 correct Message Format send to InfluxDBv2 sink connector with Python Producer
Hi, i have problems to send a message with a python producer which should be processed by an InfluxDBv2 sink connector. With a java test code it is possible. Java class: `public String measurement; public long timestamp; public Map<String, String> tags; public Map<String, Object> fields;` Set values: `Device device = new Device(); device.measurement = "test5"; device.timestamp = Instant.now().toEpochMilli(); device.tags = Maps.newHashMap(); device.tags.put("foo", "bar"); device.fields = Maps.newHashMap(); device.fields.put("temp", 14.8);` Send message: ` MessageId msgID = producer.newMessage() .key("test") .value(device) .send(); ` Any suggestions how to do with Python ? Thanks GitHub link: https://github.com/apache/pulsar/discussions/22558 ---- This is an automatically sent email for commits@pulsar.apache.org. To unsubscribe, please send an email to: commits-unsubscr...@pulsar.apache.org