[jira] [Commented] (KAFKA-6675) Connect workers should log plugin path and available plugins more clearly

["Valeria Vasylieva (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/KAFKA-6675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16795837#comment-16795837 ] 

Valeria Vasylieva commented on KAFKA-6675:
------------------------------------------

I would like to work on it

> 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: KafkaConnect
>    Affects Versions: 0.11.0.1
>            Reporter: Randall Hauch
>            Priority: Minor
>
> 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
(v7.6.3#76005)