[ https://issues.apache.org/jira/browse/KAFKA-6675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Greg Harris resolved KAFKA-6675. -------------------------------- Fix Version/s: 3.6.0 Assignee: Greg Harris (was: Valeria Vasylieva) Resolution: Fixed This was incorporated into the bin/connect-plugin-path.sh list command, as specified in KIP-898: [https://cwiki.apache.org/confluence/display/KAFKA/KIP-898%3A+Modernize+Connect+plugin+discovery] . This can be used offline without starting the connect worker or loading any live configurations. > Connect workers should log plugin path and available plugins more clearly > ------------------------------------------------------------------------- > > Key: KAFKA-6675 > URL: https://issues.apache.org/jira/browse/KAFKA-6675 > Project: Kafka > Issue Type: Improvement > Components: connect > Affects Versions: 0.11.0.1 > Reporter: Randall Hauch > Assignee: Greg Harris > Priority: Minor > Fix For: 3.6.0 > > > Users struggle with setting the plugin path and properly installing plugins. > If users get any of this wrong, they get strange errors only after they run > the worker and attempt to deploy connectors or use transformations. > The Connect worker should more obviously output the plugin path directories > and the available plugins. For example, if the {{plugin.path}} were: > {code} > plugin.path=/usr/local/share/java,/usr/local/plugins > {code} > then the worker might output something like the following information in the > log: > {noformat} > Looking for plugins on classpath and inside plugin.path directories: > /usr/local/share/java > /usr/local/plugins > > Source Connector(s): > FileStreamSource (org.apache.kafka.connect.file.FileStreamSourceConnector) > @ classpath > FileStreamSink (org.apache.kafka.connect.file.FileStreamSinkConnector) > @ classpath > JdbcSource (io.confluent.connect.jdbc.JdbcSourceConnector) > @ /usr/local/share/java/kafka-connect-jdbc > MySql (io.debezium.connector.mysql.MySqlConnector) > @ /usr/local/plugins/debezium-connector-mysql > Converter(s): > JsonConverter (org.apache.kafka.connect.json.JsonConverter) > @ classpath > ByteArrayConverter > (org.apache.kafka.connect.converters.ByteArrayConverter) @ classpath > SimpleHeaderConverter > (org.apache.kafka.connect.converters.SimpleHeaderConverter) @ classpath > AvroConverter (io.confluent.connect.avro.AvroConverter) > @ /usr/local/share/java/kafka-serde-tools > Transformation(s): > InsertField (org.apache.kafka.connect.transforms.InsertField) > @ classpath > ReplaceField (org.apache.kafka.connect.transforms.ReplaceField) > @ classpath > MaskField (org.apache.kafka.connect.transforms.MaskField) > @ classpath > ValueToKey (org.apache.kafka.connect.transforms.ValueToKey) > @ classpath > HoistField (org.apache.kafka.connect.transforms.HoistField) > @ classpath > ExtractField (org.apache.kafka.connect.transforms.ExtractField) > @ classpath > SetSchemaMetadata (org.apache.kafka.connect.transforms.SetSchemaMetadata) > @ classpath > RegexRouter (org.apache.kafka.connect.transforms.RegexRouter) > @ classpath > TimestampRouter (org.apache.kafka.connect.transforms.TimestampRouter) > @ classpath > {noformat} -- This message was sent by Atlassian Jira (v8.20.10#820010)