Hi,

Yes, the schema is different, doesn't match with the schema. I think you
need something like this:

Schema (union of records of type "hello1" or "hello2"):

[
  {
    "type": "record",
    "name": "hello1",
    "fields": [
      {
        "name": "foo",
        "type": "int",
        "default": 1
      }
    ]
  },
  {
    "type": "record",
    "name": "hello2",
    "fields": [
      {
        "name": "bar",
        "type": "int",
        "default": 1
      }
    ]
  }
]

If you have a schema like above, you should be able to use hello1 and
hello2 type records:
{"hello1":{"foo": 5}}
{"hello2":{"bar": 10}}

Hope this solves your question.

Regards,
Nandor

On Wed, Jan 10, 2018 at 2:10 PM, kant kodali <[EMAIL PROTECTED]> wrote:
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB