Yufan Sheng created FLINK-28351: ----------------------------------- Summary: Pulsar Sink should support dynamic generated topic from record Key: FLINK-28351 URL: https://issues.apache.org/jira/browse/FLINK-28351 Project: Flink Issue Type: Bug Components: Connectors / Pulsar Affects Versions: 1.15.0 Reporter: Yufan Sheng Fix For: 1.16.0
Some people would like to use dynamically-generated topics from messages and use the key hash range policy. This is not supported by the Pulsar sink currently. We would introduce a new interface named TopicExacter and add a new setTopics(TopicExacter) in PulsarSinkBuilder. -- This message was sent by Atlassian Jira (v8.20.10#820010)