[
https://issues.apache.org/jira/browse/KAFKA-6932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Masthan Shaik updated KAFKA-6932:
---------------------------------
Description:
Thecustomer is using
io.confluent.kafka.serializers.subject.TopicRecordNameStrategy for
AvroConverter but the avroconverter is defaulting to TopicNameStratergy
It looks like the avroconverter doesn't initialize or pass the strategy into
the deserializer.
POST with input
{"schema":"{\"type\":\"record\",\"name\":\"Channel\",\"namespace\":\"com.thing\",\"doc\":\"Channel
Object\",\"fields\":[
{\"name\":\"channelId\",\"type\":\"string\",\"doc\":\"Unique channel id for a
single time series\"}
]}"} to
in the above log it is using newgen.changelog.v1-key instead of the
newgen.changelog.v1-<type>
was:
Thecustomer is using
io.confluent.kafka.serializers.subject.TopicRecordNameStrategy for
AvroConverter but the avroconverter is defaulting to TopicNameStratergy
It looks like the avroconverter doesn't initialize or pass the strategy into
the deserializer.
POST with input
{"schema":"{\"type\":\"record\",\"name\":\"ChannelKey\",\"namespace\":\"com.uptake\",\"doc\":\"Channel
Object\",\"fields\":[
{\"name\":\"channelId\",\"type\":\"string\",\"doc\":\"Unique channel id for a
single time series\"}
]}"} to
in the above log it is using replatform.changelog.v1-key instead of the
replatform.changelog.v1-<type>
> Avroconverter does not propagate subjectname stratergy
> ------------------------------------------------------
>
> Key: KAFKA-6932
> URL: https://issues.apache.org/jira/browse/KAFKA-6932
> Project: Kafka
> Issue Type: Bug
> Components: KafkaConnect
> Affects Versions: 1.1.0
> Reporter: Masthan Shaik
> Priority: Major
>
> Thecustomer is using
> io.confluent.kafka.serializers.subject.TopicRecordNameStrategy for
> AvroConverter but the avroconverter is defaulting to TopicNameStratergy
> It looks like the avroconverter doesn't initialize or pass the strategy into
> the deserializer.
> POST with input
> {"schema":"{\"type\":\"record\",\"name\":\"Channel\",\"namespace\":\"com.thing\",\"doc\":\"Channel
> Object\",\"fields\":[
> {\"name\":\"channelId\",\"type\":\"string\",\"doc\":\"Unique channel id for a
> single time series\"}
> ]}"} to
> in the above log it is using newgen.changelog.v1-key instead of the
> newgen.changelog.v1-<type>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
