{"action":"created","issue":{"url":"https://api.github.com/repos/druid-io/druid/issues/3714","repository_url":"https://api.github.com/repos/druid-io/druid","labels_url":"https://api.github.com/repos/druid-io/druid/issues/3714/labels{/name}","comments_url":"https://api.github.com/repos/druid-io/druid/issues/3714/comments","events_url":"https://api.github.com/repos/druid-io/druid/issues/3714/events","html_url":"https://github.com/druid-io/druid/issues/3714","id":191389736,"number":3714,"title":"Getting IllegalArgumentException when using Kafka Indexing service with Confluent Schema registry","user":{"login":"gurdeep18","id":11895775,"avatar_url":"https://avatars.githubusercontent.com/u/11895775?v=3","gravatar_id":"","url":"https://api.github.com/users/gurdeep18","html_url":"https://github.com/gurdeep18","followers_url":"https://api.github.com/users/gurdeep18/followers","following_url":"https://api.github.com/users/gurdeep18/following{/other_user}","gists_url":"https://api.github.com/users/gurdeep18/gists{/gist_id}","starred_url":"https://api.github.com/users/gurdeep18/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/gurdeep18/subscriptions","organizations_url":"https://api.github.com/users/gurdeep18/orgs","repos_url":"https://api.github.com/users/gurdeep18/repos","events_url":"https://api.github.com/users/gurdeep18/events{/privacy}","received_events_url":"https://api.github.com/users/gurdeep18/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":3,"created_at":"2016-11-23T22:04:37Z","updated_at":"2016-11-28T21:08:05Z","closed_at":null,"body":"I am getting an Illegal Argument exception when posting a supervisor spec using the kafka indexing service.\r\n\r\nHere is my snapshot of the spec\r\n`{\r\n  \"type\": \"kafka\",\r\n  \"dataSchema\": {\r\n    \"dataSource\": \"PinPromo\",\r\n    \"parser\": {\r\n      \"type\": \"avro_stream\",\r\n      \"avroBytesDecoder\": {\r\n        \"type\": \"schema_registry\",\r\n        \"registry\": {\r\n          \"url\": \"http://xx.xx.xxx.xxx:8081\",\r\n          \"capacity\": 1000\r\n        }\r\n      },\r\n      \"parseSpec\": {\r\n        \"format\": \"timeAndDims\",\r\n        \"timestampSpec\": {\r\n          \"column\": \"eventDate\",\r\n          \"format\": \"auto\"\r\n        },\r\n        \"dimensionsSpec\": {\r\n          \"dimensions\":[]\r\n        }\r\n      }\r\n    },`\r\n\r\nI am getting the following stack trace\r\n\r\n`2016-11-23T21:55:37,332 INFO [KafkaSupervisor-PinPromo] io.druid.indexing.kafka.supervisor.KafkaSupervisor - Number of tasks [0] does not match configured numReplicas [1] in task group [0], creating more tasks\r\n2016-11-23T21:55:37,338 ERROR [KafkaSupervisor-PinPromo] io.druid.indexing.kafka.supervisor.KafkaSupervisor - KafkaSupervisor[PinPromo] failed to handle notice: {class=io.druid.indexing.kafka.supervisor.KafkaSupervisor, exceptionType=class java.lang.IllegalArgumentException, exceptionMessage=Instantiation of [simple type, class io.druid.data.input.avro.SchemaRegistryBasedAvroBytesDecoder] value failed: null, noticeClass=RunNotice}\r\njava.lang.IllegalArgumentException: Instantiation of [simple type, class io.druid.data.input.avro.SchemaRegistryBasedAvroBytesDecoder] value failed: null\r\n\tat com.fasterxml.jackson.databind.ObjectMapper._convert(ObjectMapper.java:2774) ~[jackson-databind-2.4.6.jar:2.4.6]\r\n\tat com.fasterxml.jackson.databind.ObjectMapper.convertValue(ObjectMapper.java:2700) ~[jackson-databind-2.4.6.jar:2.4.6]\r\n\tat io.druid.segment.indexing.DataSchema.getParser(DataSchema.java:102) ~[druid-server-0.9.3-SNAPSHOT.jar:0.9.3-SNAPSHOT]\r\n\tat io.druid.indexing.kafka.KafkaIndexTask.<init>(KafkaIndexTask.java:204) ~[druid-kafka-indexing-service-0.9.3-SNAPSHOT.jar:0.9.3-SNAPSHOT]\r\n\tat io.druid.indexing.kafka.supervisor.KafkaSupervisor.createKafkaTasksForGroup(KafkaSupervisor.java:1275) ~[druid-kafka-indexing-service-0.9.3-SNAPSHOT.jar:0.9.3-SNAPSHOT]\r\n\tat io.druid.indexing.kafka.supervisor.KafkaSupervisor.createNewTasks(KafkaSupervisor.java:1232) ~[druid-kafka-indexing-service-0.9.3-SNAPSHOT.jar:0.9.3-SNAPSHOT]\r\n\tat io.druid.indexing.kafka.supervisor.KafkaSupervisor.runInternal(KafkaSupervisor.java:547) ~[druid-kafka-indexing-service-0.9.3-SNAPSHOT.jar:0.9.3-SNAPSHOT]\r\n\tat io.druid.indexing.kafka.supervisor.KafkaSupervisor$RunNotice.handle(KafkaSupervisor.java:462) ~[druid-kafka-indexing-service-0.9.3-SNAPSHOT.jar:0.9.3-SNAPSHOT]`"},"comment":{"url":"https://api.github.com/repos/druid-io/druid/issues/comments/263394649","html_url":"https://github.com/druid-io/druid/issues/3714#issuecomment-263394649","issue_url":"https://api.github.com/repos/druid-io/druid/issues/3714","id":263394649,"user":{"login":"gurdeep18","id":11895775,"avatar_url":"https://avatars.githubusercontent.com/u/11895775?v=3","gravatar_id":"","url":"https://api.github.com/users/gurdeep18","html_url":"https://github.com/gurdeep18","followers_url":"https://api.github.com/users/gurdeep18/followers","following_url":"https://api.github.com/users/gurdeep18/following{/other_user}","gists_url":"https://api.github.com/users/gurdeep18/gists{/gist_id}","starred_url":"https://api.github.com/users/gurdeep18/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/gurdeep18/subscriptions","organizations_url":"https://api.github.com/users/gurdeep18/orgs","repos_url":"https://api.github.com/users/gurdeep18/repos","events_url":"https://api.github.com/users/gurdeep18/events{/privacy}","received_events_url":"https://api.github.com/users/gurdeep18/received_events","type":"User","site_admin":false},"created_at":"2016-11-28T21:08:05Z","updated_at":"2016-11-28T21:08:05Z","body":"I got this working, had to remove the \"registry\" from my spec above. Even used flattenSpec with this and it is flattening out my nested kafka schema"}}
{"actor":{"display_login":"gurdeep18"}}