Skip to content

/ pulsar

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[doc][suggest] Tell user the available values of "--sink-type" parameter #6109

Open
huangdx0726 opened this issue Jan 21, 2020 · 4 comments
Open

[doc][suggest] Tell user the available values of "--sink-type" parameter #6109

huangdx0726 opened this issue Jan 21, 2020 · 4 comments
Labels
component/documentation triage/week-16 triage/week-4 type/enhancement

Comments

@huangdx0726
Copy link
Contributor

@huangdx0726 huangdx0726 commented Jan 21, 2020

Is your feature request related to a problem? Please describe.
Tell user the available values of "--sink-type" parameter.

Describe the solution you'd like
When i create a Cassandra sink like this.

bin/pulsar-admin sinks create \
    --tenant public \
    --namespace default \
    --name cassandra-test-sink \
    --sink-type cassandra \
    --sink-config-file examples/cassandra-sink.yml \
    --inputs test_cassandra

I could't understand, Why is the value of "--sink-type" parameter cassandra ,And when i create the other sinks, What value should be set for this parameter.

Describe alternatives you've considered
Provide a available values list for this parameter.

Additional context
Add any other context or screenshots about the feature request here.
@sijie sijie mentioned this issue Jan 21, 2020
Open
@huangdx0726
Copy link
Contributor Author

@huangdx0726 huangdx0726 commented Jan 21, 2020

--source-type as above
@tuteng
Copy link
Member

@tuteng tuteng commented Jan 21, 2020

The type sink-type or source-type of the currently built-in connector should be determined according to the parameter name of this file.pulsar-io.yaml @huangdx0726

I think we can consider adding instructions about pulsar-io.yaml to the document. @Anonymitaet
@huangdx0726
Copy link
Contributor Author

@huangdx0726 huangdx0726 commented Jan 22, 2020 

@Connector(
    name = "cassandra",
    type = IOType.SINK,
    help = "The CassandraStringSink is used for moving messages from Pulsar to Cassandra.",
    configClass = CassandraSinkConfig.class)

This name is same as name of pulsar-io.yaml ?
@tuteng
Copy link
Member

@tuteng tuteng commented Jan 22, 2020

Yes, it is the same, but some connectors do not have the annotation Connector, but there must be the pulsar-io.yaml file. @huangdx0726
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
component/documentation triage/week-16 triage/week-4 type/enhancement
Projects
None yet
Milestone
No milestone
Linked pull requests

Successfully merging a pull request may close this issue.

None yet
3 participants
@sijie @tuteng @huangdx0726
You can’t perform that action at this time.

Follow Lee on X/Twitter - Father, Husband, Serial builder creating AI, crypto, games & web tools. We are friends :) AI Will Come To Life!

Check out: eBank.nz (Art Generator) | Netwrck.com (AI Tools) | Text-Generator.io (AI API) | BitBank.nz (Crypto AI) | ReadingTime (Kids Reading) | RewordGame | BigMultiplayerChess | WebFiddle | How.nz | Helix AI Assistant