nicolo-paganin edited a comment on issue #5454: mysql JDBC Sink - consumer error
URL: https://github.com/apache/pulsar/issues/5454#issuecomment-586896429
 
 
   @sijie 
   
   1.  Yes I am always starting form a fresh pulsar installation (removing 
`data` folder). After upgrading libpulsar to 2.5.0 I have restarted to be sure 
:-)
   2. I tried also removing the regex and using single topic as input
   
   if I put this using the topic created by the JAVA producer the sink  is 
working
   ```
   ./pulsar-admin sinks create --tenant public --namespace default --name 
influxdb-test-sink --sink-type oncode-influxdb-connector  --sink-config-file 
influxdb.yaml  --inputs "public/default/topic_java"
   ```
   
   If I use this with the topic created by the python pulsar function copying 
the values from `topic_java` to `topic_python` I have the same 
`java.lang.NullPointerException`
   
   ```
   ./pulsar-admin sinks create --tenant public --namespace default --name 
influxdb-test-sink --sink-type oncode-influxdb-connector  --sink-config-file 
influxdb.yaml  --inputs "public/default/topic_python"
   ```
   
   

----------------------------------------------------------------
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]


With regards,
Apache Git Services

Reply via email to