Skip to content
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

feat: add 'show connector plugins' syntax #7284

Merged
merged 3 commits into from
Mar 29, 2021

Conversation

spena
Copy link
Member

@spena spena commented Mar 23, 2021

Description

What behavior do you want to change, why, how does your patch achieve the changes?
Feature #4623

Add new SHOW CONNECTOR PLUGINS syntax that displays the all available connector plugins from Connect.

ksql> show connector plugins;

 Class                                                     | Type   | Version    
---------------------------------------------------------------------------------
 io.confluent.connect.replicator.ReplicatorSourceConnector | SOURCE | 6.1.0-0    
 org.apache.kafka.connect.file.FileStreamSinkConnector     | SINK   | 6.1.0-0-ce 
 org.apache.kafka.connect.file.FileStreamSourceConnector   | SOURCE | 6.1.0-0-ce 
 org.apache.kafka.connect.mirror.MirrorCheckpointConnector | SOURCE | 1          
 org.apache.kafka.connect.mirror.MirrorHeartbeatConnector  | SOURCE | 1          
 org.apache.kafka.connect.mirror.MirrorSourceConnector     | SOURCE | 1          
---------------------------------------------------------------------------------

Testing done

Describe the testing strategy. Unit and integration tests are expected for any behavior changes.
Added unit tests
Verified manually in CLI

Reviewer checklist

  • Ensure docs are updated if necessary. (eg. if a user visible feature is being added or changed).
  • Ensure relevant issues are linked (description should include text like "Fixes #")

@spena spena requested a review from a team March 23, 2021 22:42
return Optional.of(
new ConnectorPluginsList(
configuredStatement.getStatementText(),
warnings,
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
warnings,
warnings,

Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Done

}

final List<SimpleConnectorPluginInfo> pluginInfos = new ArrayList<>();
final List<KsqlWarning> warnings = new ArrayList<>();
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Is this supposed to be an empty list? If so, could we remove warnings from ConnectorPluginsList?

Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Done

Copy link
Contributor

@jzaralim jzaralim left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

lgtm

@spena spena force-pushed the feat_show_connector_plugins branch from 511c910 to 88fa268 Compare March 29, 2021 15:05
@spena spena merged commit be50d2d into confluentinc:master Mar 29, 2021
@spena spena deleted the feat_show_connector_plugins branch March 29, 2021 16:19
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants