rdhabalia opened a new pull request #9035:
URL: https://github.com/apache/pulsar/pull/9035
### Motivation
Right now, kafka-source-connector creates invalid topic name which causes
error while creating producer in debezium io-source.
```
21:22:41,772 DEBUG [my-property/us-west/my-ns/debezium-postgres-source-0]
[instance: 0] JavaInstance - Got result: object: (key = "[B@3bbd472c", value =
"[B@1aa204ba")
21:22:41,780 ERROR [my-property/us-west/my-ns/debezium-postgres-source-0]
[instance: 0] PulsarSink - Failed to create Producer while doing user publish
org.apache.pulsar.client.api.PulsarClientException$InvalidTopicNameException:
Invalid topic name: 'my-property/us-west/my-ns/topic1'
at
org.apache.pulsar.client.api.PulsarClientException.unwrap(PulsarClientException.java:892)
~[org.apache.pulsar-pulsar-client-api-2.6.2.jar:2.6.2]
at
org.apache.pulsar.client.impl.ProducerBuilderImpl.create(ProducerBuilderImpl.java:93)
~[org.apache.pulsar-pulsar-client-original-2.6.2.jar:2.6.2]
at
org.apache.pulsar.functions.sink.PulsarSink$PulsarSinkProcessorBase.createProducer(PulsarSink.java:107)
~[org.apache.pulsar-pulsar-functions-instance-2.6.2.jar:2.6.2]
at
org.apache.pulsar.functions.sink.PulsarSink$PulsarSinkProcessorBase.lambda$getProducer$0(PulsarSink.java:117)
[org.apache.pulsar-pulsar-functions-instance-2.6.2.jar:2.6.2]
at
java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1705)
[?:?]
at
org.apache.pulsar.functions.sink.PulsarSink$PulsarSinkProcessorBase.getProducer(PulsarSink.java:115)
[org.apache.pulsar-pulsar-functions-instance-2.6.2.jar:2.6.2]
at
org.apache.pulsar.functions.sink.PulsarSink$PulsarSinkProcessorBase.getProducer(PulsarSink.java:111)
[org.apache.pulsar-pulsar-functions-instance-2.6.2.jar:2.6.2]
at
org.apache.pulsar.functions.sink.PulsarSink$PulsarSinkAtMostOnceProcessor.newMessage(PulsarSink.java:184)
[org.apache.pulsar-pulsar-functions-instance-2.6.2.jar:2.6.2]
at
org.apache.pulsar.functions.sink.PulsarSink.write(PulsarSink.java:295)
[org.apache.pulsar-pulsar-functions-instance-2.6.2.jar:2.6.2]
at
org.apache.pulsar.functions.instance.JavaInstanceRunnable.sendOutputMessage(JavaInstanceRunnable.java:449)
[org.apache.pulsar-pulsar-functions-instance-2.6.2.jar:2.6.2]
at
org.apache.pulsar.functions.instance.JavaInstanceRunnable.lambda$processResult$0(JavaInstanceRunnable.java:431)
[org.apache.pulsar-pulsar-functions-instance-2.6.2.jar:2.6.2]
at
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
[?:?]
at
java.util.concurrent.CompletableFuture.uniWhenCompleteStage(CompletableFuture.java:883)
[?:?]
at
java.util.concurrent.CompletableFuture.whenComplete(CompletableFuture.java:2251)
[?:?]
at
org.apache.pulsar.functions.instance.JavaInstanceRunnable.processResult(JavaInstanceRunnable.java:422)
[org.apache.pulsar-pulsar-functions-instance-2.6.2.jar:2.6.2]
at
org.apache.pulsar.functions.instance.JavaInstanceRunnable.run(JavaInstanceRunnable.java:283)
[org.apache.pulsar-pulsar-functions-instance-2.6.2.jar:2.6.2]
at java.lang.Thread.run(Thread.java:834) [?:?]
21:22:41,781 INFO [my-property/us-west/my-ns/debezium-postgres-source-0]
[instance: 0] JavaInstanceRunnable - Encountered exception in sink write:
java.lang.RuntimeException:
org.apache.pulsar.client.api.PulsarClientException$InvalidTopicNameException:
Invalid topic name: 'my-property/us-west/my-ns/topic1'
at
org.apache.pulsar.functions.sink.PulsarSink$PulsarSinkProcessorBase.lambda$getProducer$0(PulsarSink.java:124)
~[org.apache.pulsar-pulsar-functions-instance-2.6.2.jar:2.6.2]
at
java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1705)
~[?:?]
at
org.apache.pulsar.functions.sink.PulsarSink$PulsarSinkProcessorBase.getProducer(PulsarSink.java:115)
~[org.apache.pulsar-pulsar-functions-instance-2.6.2.jar:2.6.2]
at
org.apache.pulsar.functions.sink.PulsarSink$PulsarSinkProcessorBase.getProducer(PulsarSink.java:111)
~[org.apache.pulsar-pulsar-functions-instance-2.6.2.jar:2.6.2]
at
org.apache.pulsar.functions.sink.PulsarSink$PulsarSinkAtMostOnceProcessor.newMessage(PulsarSink.java:184)
~[org.apache.pulsar-pulsar-functions-instance-2.6.2.jar:2.6.2]
at
org.apache.pulsar.functions.sink.PulsarSink.write(PulsarSink.java:295)
~[org.apache.pulsar-pulsar-functions-instance-2.6.2.jar:2.6.2]
at
org.apache.pulsar.functions.instance.JavaInstanceRunnable.sendOutputMessage(JavaInstanceRunnable.java:449)
[org.apache.pulsar-pulsar-functions-instance-2.6.2.jar:2.6.2]
at
org.apache.pulsar.functions.instance.JavaInstanceRunnable.lambda$processResult$0(JavaInstanceRunnable.java:431)
[org.apache.pulsar-pulsar-functions-instance-2.6.2.jar:2.6.2]
at
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
[?:?]
at
java.util.concurrent.CompletableFuture.uniWhenCompleteStage(CompletableFuture.java:883)
[?:?]
at
java.util.concurrent.CompletableFuture.whenComplete(CompletableFuture.java:2251)
[?:?]
at
org.apache.pulsar.functions.instance.JavaInstanceRunnable.processResult(JavaInstanceRunnable.java:422)
[org.apache.pulsar-pulsar-functions-instance-2.6.2.jar:2.6.2]
at
org.apache.pulsar.functions.instance.JavaInstanceRunnable.run(JavaInstanceRunnable.java:283)
[org.apache.pulsar-pulsar-functions-instance-2.6.2.jar:2.6.2]
at java.lang.Thread.run(Thread.java:834) [?:?]
Caused by:
org.apache.pulsar.client.api.PulsarClientException$InvalidTopicNameException:
Invalid topic name: 'my-property/us-west/my-ns/topic1'
at
org.apache.pulsar.client.api.PulsarClientException.unwrap(PulsarClientException.java:892)
~[org.apache.pulsar-pulsar-client-api-2.6.2.jar:2.6.2]
at
org.apache.pulsar.client.impl.ProducerBuilderImpl.create(ProducerBuilderImpl.java:93)
~[org.apache.pulsar-pulsar-client-original-2.6.2.jar:2.6.2]
at
org.apache.pulsar.functions.sink.PulsarSink$PulsarSinkProcessorBase.createProducer(PulsarSink.java:107)
~[org.apache.pulsar-pulsar-functions-instance-2.6.2.jar:2.6.2]
at
org.apache.pulsar.functions.sink.PulsarSink$PulsarSinkProcessorBase.lambda$getProducer$0(PulsarSink.java:117)
~[org.apache.pulsar-pulsar-functions-instance-2.6.2.jar:2.6.2]
... 13 more
21:22:41,790 INFO [my-property/us-west/my-ns/debezium-postgres-source-0]
[instance: 0] AvroDataConfig - AvroDataConfig values:
schemas.cache.config = 1000
enhanced.avro.schema.support = false
connect.meta.data = true
```
----------------------------------------------------------------
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]
