Member since
07-08-2019
1
Post
0
Kudos Received
0
Solutions
07-09-2019
01:48 AM
We are using Debezium to connect to SQL Server as our Producer. When running connect-standalone.sh with the workers.properties config below, we are getting this error message: Caused by: io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException: Unexpected character ('<' (code 60)): expected a valid value (number, String, array, object, 'true', 'false' or 'null') This is what our registry.log file says: INFO [2019-07-08 14:31:34.685] [dw-22] c.h.r.s.w.RewriteUriFilter - Forwarding request [com.hortonworks.registries.auth.server.AuthenticationFilter$1@4031172] to [/api/v1/confluent] WARN [2019-07-08 14:31:34.689] [dw-22] c.h.r.a.s.AuthenticationFilter - Authentication exception: GSSException: Failure unspecified at GSS-API level (Mechanism level: Request is a replay (34)) And this is what registry.out says: 10.61.101.55 - - [08/Jul/2019:18:31:34 +0000] "POST /subjects/staging.dbo.table-key/versions HTTP/1.1" 401 319 "-" "Java/1.8.0_112" 10 10.61.101.55 - - [08/Jul/2019:18:31:34 +0000] "POST /subjects/staging.dbo.table-key/versions HTTP/1.1" 403 478 "-" "Java/1.8.0_112" 63 worker.properties contents: offset.storage.file.filename=/tmp/connect.offsets
client.id=test_sqlserver-dbhistory
bootstrap.servers=:6667
offset.flush.interval.ms=10000
rest.port=10082
rest.host.name=
rest.advertised.port=10082
rest.advertised.host.name=
internal.key.converter=org.apache.kafka.connect.json.JsonConverter
internal.value.converter=org.apache.kafka.connect.json.JsonConverter
internal.key.converter.schemas.enable=false
internal.value.converter.schemas.enable=false
basic.auth.credentials.source=SASL_INHERIT
key.converter.schemas.enable=true
value.converter.schemas.enable=true
key.converter=io.confluent.connect.avro.AvroConverter
key.converter.schema.registry.url=http://:7788
value.converter=io.confluent.connect.avro.AvroConverter
value.converter.schema.registry.url=http://:7788
key.converter.basic.auth.credentials.source=USER_INFO
key.converter.schema.registry.basic.auth.user.info=user:pass
value.converter.basic.auth.credentials.source=USER_INTO
value.converter.schema.registry.basic.auth.user.info=user:pass
plugin.path=/usr/local/share/kafka/plugins/
security.protocol=PLAINTEXTSASL
security.inter.broker.protocol=PLAINTEXTSASL
sasl.mechanism=PLAIN
... View more
Labels: