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

Unable to instantiate AdjustPrecisionAndScale: Plugin class must have a no-args constructor, and cannot be a non-static inner class #111

Open
aonamrata opened this issue Apr 17, 2024 · 10 comments · May be fixed by #113

Comments

@aonamrata
Copy link

Hi,

I am trying to update our connectors and transform packages to resolve security vulnerabilities, so i updated my cp-kafka-connect-base:7.6.0 and jcustenborder/kafka-connect-transform-common:0.1.0.58 .

But now when i run it i get class must have a no-args constructor, and cannot be a non-static inner class error for following classes:

  • AdjustPrecisionAndScale
  • HeaderToField
  • SetMaximumPrecision
  • CloudEventsConverter

I am not using these transformers so i could ignore it. I am only using AddPrefix,changeTopicCase transformers.
Is there a up coming release that will work with the new base image?

Full Docker file:

FROM confluentinc/cp-kafka-connect-base:7.6.0

USER root

# Run updates
RUN dnf -y upgrade && dnf clean all

# Update and install find for determing SSL configuration in entrypoint
RUN dnf -y install findutils jq

# Install Plugin

# Install Debezium Mysql connector from ConfluentHub
RUN confluent-hub install --no-prompt debezium/debezium-connector-mysql:1.9.7

RUN confluent-hub install --no-prompt jcustenborder/kafka-connect-transform-common:0.1.0.58


USER appuser

ENV CONNECTOR_NAME='debezium_mysql_source'
ENV CONNECT_REST_PORT=8083
ENV CONNECT_GROUP_UNIQUE_IDENTIFIER='namdebezium'

ENV CONNECT_KEY_CONVERTER='org.apache.kafka.connect.json.JsonConverter'
ENV CONNECT_VALUE_CONVERTER='org.apache.kafka.connect.json.JsonConverter'

ENV CONNECT_PLUGIN_PATH='/usr/share/java,/usr/share/confluent-hub-components/'
ENV CONNECT_SECURITY_PROTOCOL='SSL'
ENV CONNECT_CONFIG_PROVIDERS='file'
ENV CONNECT_CONFIG_PROVIDERS_FILE_CLASS='org.apache.kafka.common.config.provider.FileConfigProvider'
ENV CONNECT_CONSUMER_SECURITY_PROTOCOL='SSL'
ENV CONNECT_PRODUCER_SECURITY_PROTOCOL='SSL'
ENV CONNECT_CONSUMER_REQUEST_TIMEOUT_MS='20000'
ENV CONNECT_CONSUMER_RETRY_BACKOFF_MS='500'
ENV DATABASE_SERVER_ID='6000'
ENV DATABASE_TIMEZONE='America/New_York'
ENV DECIMAL_HANDLING_MODE='precise'
ENV Environment='dev'
ENV MAX_TASKS=1
ENV INCONSISTENT_SCHEMA_HANDLING_MODE='fail'
ENV CONNECT_REST_ADVERTISED_HOST_NAME='kafka-connect-debezium-mysql-source'

# Mitigate CVE-2021-44228
# https://msrc-blog.microsoft.com/2021/12/11/microsofts-response-to-cve-2021-44228-apache-log4j2/
ENV LOG4J_FORMAT_MSG_NO_LOOKUPS="true"

# Configure default log levels
ENV CONNECT_LOG4J_ROOT_LOGLEVEL="ERROR"
ENV CONNECT_LOG4J_LOGGERS="org.I0Itec.zkclient=ERROR,org.reflections=ERROR,org.eclipse.jetty=ERROR,kafka=ERROR,org.apache.kafka=ERROR,org.apache.zookeeper=ERROR,org.apache.kafka.connect.runtime.WorkerSourceTask=ERROR"

ENV CONNECT_GROUP_ID="kafka_connect_${CONNECTOR_NAME}_${CONNECT_GROUP_UNIQUE_IDENTIFIER}"
ENV CONNECT_CONFIG_STORAGE_TOPIC="_${CONNECT_GROUP_ID}-configs"
ENV CONNECT_OFFSET_STORAGE_TOPIC="_${CONNECT_GROUP_ID}-offsets"
ENV CONNECT_STATUS_STORAGE_TOPIC="_${CONNECT_GROUP_ID}-status"

# Connector topic config
ENV  DATABASE_HISTORY_KAFKA_TOPIC="_${DATABASE_SERVER_NAME}_history"


EXPOSE ${CONNECT_REST_PORT}

Full Error Log:

===> Check if Kafka is healthy ...
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/usr/share/java/kafka/slf4j-reload4j-1.7.36.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/usr/share/java/cp-base-new/slf4j-reload4j-1.7.36.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.Reload4jLoggerFactory]
Using log4j config /etc/cp-base-new/log4j.properties
===> Launching ...
===> Launching kafka-connect ...
[2024-04-17 08:24:17,691] ERROR Failed to discover Transformation in /usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common: Unable to instantiate AdjustPrecisionAndScale: Plugin class must have a no-args constructor, and cannot be a non-static inner class (org.apache.kafka.connect.runtime.isolation.ReflectionScanner)
java.lang.NoSuchMethodException: com.github.jcustenborder.kafka.connect.transform.common.AdjustPrecisionAndScale.<init>()
        at java.base/java.lang.Class.getConstructor0(Class.java:3349)
        at java.base/java.lang.Class.getDeclaredConstructor(Class.java:2553)
        at org.apache.kafka.connect.runtime.isolation.ReflectionScanner.versionFor(ReflectionScanner.java:73)
        at org.apache.kafka.connect.runtime.isolation.ReflectionScanner.getPluginDesc(ReflectionScanner.java:136)
        at org.apache.kafka.connect.runtime.isolation.ReflectionScanner.getTransformationPluginDesc(ReflectionScanner.java:106)
        at org.apache.kafka.connect.runtime.isolation.ReflectionScanner.scanPlugins(ReflectionScanner.java:91)
        at org.apache.kafka.connect.runtime.isolation.PluginScanner.scanUrlsAndAddPlugins(PluginScanner.java:79)
        at org.apache.kafka.connect.runtime.isolation.PluginScanner.discoverPlugins(PluginScanner.java:67)
        at org.apache.kafka.connect.runtime.isolation.Plugins.initLoaders(Plugins.java:90)
        at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:74)
        at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:64)
        at org.apache.kafka.connect.cli.AbstractConnectCli.startConnect(AbstractConnectCli.java:121)
        at org.apache.kafka.connect.cli.AbstractConnectCli.run(AbstractConnectCli.java:94)
        at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:116)
[2024-04-17 08:24:17,694] ERROR Failed to discover Transformation in /usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common: Unable to instantiate HeaderToField: Plugin class must have a no-args constructor, and cannot be a non-static inner class (org.apache.kafka.connect.runtime.isolation.ReflectionScanner)
java.lang.NoSuchMethodException: com.github.jcustenborder.kafka.connect.transform.common.HeaderToField.<init>()
        at java.base/java.lang.Class.getConstructor0(Class.java:3349)
        at java.base/java.lang.Class.getDeclaredConstructor(Class.java:2553)
        at org.apache.kafka.connect.runtime.isolation.ReflectionScanner.versionFor(ReflectionScanner.java:73)
        at org.apache.kafka.connect.runtime.isolation.ReflectionScanner.getPluginDesc(ReflectionScanner.java:136)
        at org.apache.kafka.connect.runtime.isolation.ReflectionScanner.getTransformationPluginDesc(ReflectionScanner.java:106)
        at org.apache.kafka.connect.runtime.isolation.ReflectionScanner.scanPlugins(ReflectionScanner.java:91)
        at org.apache.kafka.connect.runtime.isolation.PluginScanner.scanUrlsAndAddPlugins(PluginScanner.java:79)
        at org.apache.kafka.connect.runtime.isolation.PluginScanner.discoverPlugins(PluginScanner.java:67)
        at org.apache.kafka.connect.runtime.isolation.Plugins.initLoaders(Plugins.java:90)
        at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:74)
        at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:64)
        at org.apache.kafka.connect.cli.AbstractConnectCli.startConnect(AbstractConnectCli.java:121)
        at org.apache.kafka.connect.cli.AbstractConnectCli.run(AbstractConnectCli.java:94)
        at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:116)
[2024-04-17 08:24:17,695] ERROR Failed to discover Transformation in /usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common: Unable to instantiate SetMaximumPrecision: Plugin class must have a no-args constructor, and cannot be a non-static inner class (org.apache.kafka.connect.runtime.isolation.ReflectionScanner)
java.lang.NoSuchMethodException: com.github.jcustenborder.kafka.connect.transform.common.SetMaximumPrecision.<init>()
        at java.base/java.lang.Class.getConstructor0(Class.java:3349)
        at java.base/java.lang.Class.getDeclaredConstructor(Class.java:2553)
        at org.apache.kafka.connect.runtime.isolation.ReflectionScanner.versionFor(ReflectionScanner.java:73)
        at org.apache.kafka.connect.runtime.isolation.ReflectionScanner.getPluginDesc(ReflectionScanner.java:136)
        at org.apache.kafka.connect.runtime.isolation.ReflectionScanner.getTransformationPluginDesc(ReflectionScanner.java:106)
        at org.apache.kafka.connect.runtime.isolation.ReflectionScanner.scanPlugins(ReflectionScanner.java:91)
        at org.apache.kafka.connect.runtime.isolation.PluginScanner.scanUrlsAndAddPlugins(PluginScanner.java:79)
        at org.apache.kafka.connect.runtime.isolation.PluginScanner.discoverPlugins(PluginScanner.java:67)
        at org.apache.kafka.connect.runtime.isolation.Plugins.initLoaders(Plugins.java:90)
        at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:74)
        at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:64)
        at org.apache.kafka.connect.cli.AbstractConnectCli.startConnect(AbstractConnectCli.java:121)
        at org.apache.kafka.connect.cli.AbstractConnectCli.run(AbstractConnectCli.java:94)
        at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:116)
[2024-04-17 08:24:18,023] ERROR Failed to discover Converter in /usr/share/confluent-hub-components/debezium-debezium-connector-mysql: Unable to instantiate CloudEventsConverter: Failed to statically initialize plugin class (org.apache.kafka.connect.runtime.isolation.ReflectionScanner)
java.lang.ExceptionInInitializerError
        at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
        at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
        at java.base/jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
        at java.base/java.lang.reflect.Constructor.newInstance(Constructor.java:490)
        at org.apache.kafka.connect.runtime.isolation.ReflectionScanner.versionFor(ReflectionScanner.java:73)
        at org.apache.kafka.connect.runtime.isolation.ReflectionScanner.getPluginDesc(ReflectionScanner.java:136)
        at org.apache.kafka.connect.runtime.isolation.ReflectionScanner.scanPlugins(ReflectionScanner.java:89)
        at org.apache.kafka.connect.runtime.isolation.PluginScanner.scanUrlsAndAddPlugins(PluginScanner.java:79)
        at org.apache.kafka.connect.runtime.isolation.PluginScanner.discoverPlugins(PluginScanner.java:67)
        at org.apache.kafka.connect.runtime.isolation.Plugins.initLoaders(Plugins.java:90)
        at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:74)
        at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:64)
        at org.apache.kafka.connect.cli.AbstractConnectCli.startConnect(AbstractConnectCli.java:121)
        at org.apache.kafka.connect.cli.AbstractConnectCli.run(AbstractConnectCli.java:94)
        at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:116)
Caused by: org.apache.kafka.connect.errors.DataException
        at io.debezium.converters.CloudEventsConverter.<clinit>(CloudEventsConverter.java:111)
@rizvnn
Copy link

rizvnn commented Jun 18, 2024

Had a similar issue seting JAVA_OPTS ="-Xmx 2g -Xms 2g" on kafka connect container resolved it

@aonamrata
Copy link
Author

Had a similar issue seting JAVA_OPTS ="-Xmx 2g -Xms 2g" on kafka connect container resolved it

Na, that did not work. I still get the same errors. I added this ENV to my docker compose file.

@reidmeyer
Copy link

I'm having the same problem. I find the solution that @rizvnn suggested improbable..

For me, it's an issue of kafka versions..

I'm using kafka-connect-transform-common-0.1.0.58.

I did some testing, and I found that it works for for kafka version 3.5.2, but not >=3.6.0, so I think the plugin might not support kafka >=3.6.0 at this time.

marcuslinke pushed a commit to marcuslinke/kafka-connect-transform-common that referenced this issue Jul 30, 2024
marcuslinke pushed a commit to marcuslinke/kafka-connect-transform-common that referenced this issue Jul 30, 2024
@jcustenborder
Copy link
Owner

Question for you all. Does the class still work? Looking at the code we have a default constructor on the static class. We do not have a default constructor on the implementation. I think we could just change the declaration of the implementation to abstract to fix it.

marcuslinke pushed a commit to marcuslinke/kafka-connect-transform-common that referenced this issue Jul 30, 2024
@marcuslinke
Copy link

Not sure if this works with newer kafka version as connect-utils uses kafka-connect-api 2.8.0. I will experiment with it. Stay tuned.

@marcuslinke
Copy link

marcuslinke commented Jul 30, 2024

@jcustenborder With kafka 3.7.0 and your suggested solution I get the following when using connect-utils-0.7.177.jar:

java.lang.NoClassDefFoundError: com/github/jcustenborder/kafka/connect/utils/config/ValidEnum │
│ at com.github.jcustenborder.kafka.connect.transform.common.ChangeCaseConfig.config(ChangeCaseConfig.java:43) │
│ at com.github.jcustenborder.kafka.connect.transform.common.ChangeCase.config(ChangeCase.java:44) │
│ at org.apache.kafka.connect.runtime.ConnectorConfig$2.config(ConnectorConfig.java:364) │
│ at org.apache.kafka.connect.runtime.ConnectorConfig$2.config(ConnectorConfig.java:329) │
│ at org.apache.kafka.connect.runtime.ConnectorConfig$EnrichablePlugin.getConfigDefFromConfigProvidingClass(ConnectorConfig.java:519) │
│ at org.apache.kafka.connect.runtime.ConnectorConfig$EnrichablePlugin.configDefsForClass(ConnectorConfig.java:492) │
│ at org.apache.kafka.connect.runtime.ConnectorConfig$2.configDefsForClass(ConnectorConfig.java:348) │
│ at org.apache.kafka.connect.runtime.ConnectorConfig$EnrichablePlugin.populateConfigDef(ConnectorConfig.java:473) │
│ at org.apache.kafka.connect.runtime.ConnectorConfig$EnrichablePlugin.enrich(ConnectorConfig.java:457) │
│ at org.apache.kafka.connect.runtime.ConnectorConfig.enrich(ConnectorConfig.java:377) │
│ at org.apache.kafka.connect.runtime.AbstractHerder.validateConnectorConfig(AbstractHerder.java:508) │
│ at org.apache.kafka.connect.runtime.AbstractHerder.lambda$validateConnectorConfig$3(AbstractHerder.java:412) │
│ at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) │
│ at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) │
│ at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) │
│ at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)

@aonamrata
Copy link
Author

Question for you all. Does the class still work? Looking at the code we have a default constructor on the static class. We do not have a default constructor on the implementation. I think we could just change the declaration of the implementation to abstract to fix it.

We dont use these: AdjustPrecisionAndScale transforms. We only use using AddPrefix from confluent, changeTopicCase from kafka-connect-transform-common transformers and they still seem to work even with the above errors. So it might be just a few classes that are affected.

marcuslinke pushed a commit to marcuslinke/kafka-connect-transform-common that referenced this issue Jul 31, 2024
@marcuslinke marcuslinke linked a pull request Jul 31, 2024 that will close this issue
@marcuslinke
Copy link

@jcustenborder I've updated my PRs following your suggestions:

jcustenborder/connect-utils#214
#113

@walshe
Copy link

walshe commented Aug 7, 2024

I also have this issue with Kafka Connect 7.6. Is there a lower version of kafka-connect-transform-common thats works with it ok ?

RUN confluent-hub install --no-prompt jcustenborder/kafka-connect-transform-common:latest

@mot256
Copy link

mot256 commented Aug 15, 2024

@jcustenborder @marcuslinke these warnings seem to be related and also starting to appear when we upgraded to Kafka Connect 7.7.0. This also shows that the same issues appear in the kafka-connect-json-schema plugin as well

[2024-08-15 06:26:53,799] WARN One or more plugins are missing ServiceLoader manifests may not be usable with plugin.discovery=service_load: [
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-json-schema/	com.github.jcustenborder.kafka.connect.json.FromJson$Key	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-json-schema/	com.github.jcustenborder.kafka.connect.json.FromJson$Value	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-json-schema/	com.github.jcustenborder.kafka.connect.json.JsonSchemaConverter	converter	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.AdjustPrecisionAndScale$Key	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.AdjustPrecisionAndScale$Value	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.BytesToString$Key	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.BytesToString$Value	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.ChangeCase$Key	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.ChangeCase$Value	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.ChangeTopicCase	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.Debug	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.ExtractNestedField$Key	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.ExtractNestedField$Value	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.ExtractTimestamp$Key	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.ExtractTimestamp$Value	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.ExtractXPath$Key	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.ExtractXPath$Value	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.HeaderToField$Key	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.HeaderToField$Value	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.LowerCaseTopic	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.NormalizeSchema$Key	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.NormalizeSchema$Value	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.PatternFilter$Key	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.PatternFilter$Value	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.PatternMapString$Key	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.PatternMapString$Value	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.PatternRename$Key	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.PatternRename$Value	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.SchemaNameToTopic$Key	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.SchemaNameToTopic$Value	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.SetMaximumPrecision$Key	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.SetMaximumPrecision$Value	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.SetNull$Key	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.SetNull$Value	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.TimestampNow	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.TimestampNowField$Key	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.TimestampNowField$Value	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.ToJSON$Key	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.ToJSON$Value	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.ToLong$Key	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.ToLong$Value	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.TopicNameToField$Key	transformation	undefined
file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/	com.github.jcustenborder.kafka.connect.transform.common.TopicNameToField$Value	transformation	undefined

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 a pull request may close this issue.

7 participants