Enzo Dechaene created FLINK-31371:
-------------------------------------
Summary: Stream failure if the topic doesn't exist
Key: FLINK-31371
URL: https://issues.apache.org/jira/browse/FLINK-31371
Project: Flink
Issue Type: Bug
Components: Connectors / Pulsar
Affects Versions: 1.15.3
Reporter: Enzo Dechaene
*Describe the bug*
With a Pulsar 2.8.4 server, a Flink stream containing Pulsar sources or sinks
will fail at startup if the topic doesn't exist.
*To Reproduce*
Create a stream with :
* Flink 1.15.2
* Pulsar 2.8.2
* with a Pulsar source or sink linked to a non existant topic
* Start the stream
*Expected behavior*
If the topic doesn't exist, it should be created at the first connection of the
source or sink without error.
*Additional context*
In the TopicListSubscriber class of the connector, the method
getSubscribedTopicPartitions() try to get the metadata of a topic by doing that
:
{code:java}
TopicMetadata metadata = queryTopicMetadata(pulsarAdmin, topic);{code}
If the topic doesn't exist, I get a NullPointerException on the metadata
We created a previous
[ticket|https://github.com/streamnative/pulsar-flink/issues/366] on the Pulsar
connector and it was fixed
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
