Skip to content

[pulsar-flink] Use an extensible client conf to forward to pulsar native client configs #3954

@shiv4289

Description

@shiv4289

Is your feature request related to a problem? Please describe.
The current implementation of pulsar-flink takes serviceUrl and topic as params and initialises pulsar client from these params. It is not possible to pass other pulsar client params to pulsar-flink connector.

Describe the solution you'd like
pulsar-flink should accept all the params pulsar-client accepts. This should also be extensible so future pulsar-client params can be sent without any modifications to the pulsar-flink module. The idea is to accept pulsar-client params as Map<String, Object> and pass this map to the pulsar-client builder.

This would sit well with the future additions in pulsar-client in future too.

Metadata

Metadata

Assignees

No one assigned

    Labels

    type/featureThe PR added a new feature or issue requested a new feature

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions