Topic being populated with JDBC Connect, serialized with Avro. Can sink the topic to another database with no issue.
ksql> CREATE STREAM users2stream WITH(KAFKA_TOPIC='JDBCTESTNEXTUSERS2', VALUE_FORMAT='AVRO');
Unable to verify the AVRO schema is compatible with KSQL. Unexpected character ('<' (code 60)): expected a valid value (number, String, array, object, 'true', 'false' or 'null')
at [Source: (sun.net.www.protocol.http.HttpURLConnection$HttpInputStream); line: 1, column: 2]; error code: 50005
ksql-server appears to have the correct url for the schema registry (nn is my obfuscation)
Kafka 1.1
Topic being populated with JDBC Connect, serialized with Avro. Can sink the topic to another database with no issue.
ksql> CREATE STREAM users2stream WITH(KAFKA_TOPIC='JDBCTESTNEXTUSERS2', VALUE_FORMAT='AVRO'); Unable to verify the AVRO schema is compatible with KSQL. Unexpected character ('<' (code 60)): expected a valid value (number, String, array, object, 'true', 'false' or 'null') at [Source: (sun.net.www.protocol.http.HttpURLConnection$HttpInputStream); line: 1, column: 2]; error code: 50005
ksql-server appears to have the correct url for the schema registry (nn is my obfuscation)
ksql> show properties;
Schema registry is running and I can connect through REST API to retrieve the schema
{
'type':'record', 'name':'USERS2', 'fields':[
{
'name':'ID', 'type':{
'type':'int', 'connect.type':'int16' } }, {
'name':'USERNAME', 'type':[
'null', 'string' ], 'default':None }, {
'name':'PASSWORD', 'type':[
'null', 'string' ], 'default':None }, {
'name':'MODIFIED', 'type':{
'type':'long', 'connect.version':1, 'connect.name':'org.apache.kafka.connect.data.Timestamp', 'logicalType':'timestamp-millis' } } ], 'connect.name':'USERS2' }