Could not find class io.confluent.connect.avro.ConnectDefault about kafka-streams-examples HOT 4 CLOSED

You can add your package under name. e.g:
transforms.SetSchemaName.schema.name=com.mysolution.MyClassName

from kafka-streams-examples.

@JanardhanVarikuti I was able to get the streams app working initially when reading from a single topic by just changing the avro schema file to have those default values: "name": "ConnectDefault" with "namespace": "io.confluent.connect.avro". So my generated class was just called ConnectDefault.java

In order to have multiple streams in the same application, you can use the Kafka SMT (Single Message Transforms) SetSchemaMetadata in each source connector config to set the schema names.

transforms=SetSchemaName
transforms.SetSchemaName.type=org.apache.kafka.connect.transforms.SetSchemaMetadata$Value
transforms.SetSchemaName.schema.name=MyClassName

This way you can use "name": "MyClassName" in the avro schema file. But since you cannot specify the namespace with SMT, you will need to put your streams app in the default package and omit the namespace in the avro schema files for your generated sources.

from kafka-streams-examples.

Guys, thank you. I love it when I found someone struggling for exactly the same thing.

I combined your examples @dekelmos and @jessicashin:

transforms=SetSchemaName
transforms.SetSchemaName.type=org.apache.kafka.connect.transforms.SetSchemaMetadata$Value
transforms.SetSchemaName.schema.name=com.mysolution.MyClassName

Thank you.

from kafka-streams-examples.

Hi @jessicashin , Is the above issue is resolved? If yes, could you please provide the solution?

from kafka-streams-examples.