Unable to ingest data from rabbitmq to druid

I am trying to ingest data with following spec

{
  "type": "index_realtime",
  "id": "sairam_testing_123",
  "spec": {
    "dataSchema": {
      "dataSource": "rabbitmq_test",
      "parser": {
        "type": "string",
        "parseSpec": {
          "format": "json",
          "timestampSpec" : {
            "column" : "timestamp",
            "format" : "auto"
          },
          "dimensionsSpec": {
            "dimensions": [
              "name"
            ],
            "dimensionExclusions": [],
            "spatialDimensions": []
          }
        }
      },
      "metricsSpec": [
        {
          "type": "count",
          "name": "count"
        }
      ],
      "granularitySpec": {
        "type": "uniform",
        "segmentGranularity": "hour",
        "queryGranularity": "none"
      }
    },
    "ioConfig": {
      "type": "realtime",
      "firehose": {
        "type": "rabbitmq",
        "connection": {
          "host": "127.0.0.1",
          "port": "5672",
          "username": "admin",
          "password": "admin",
          "virtualHost": "/",
          "uri": "amqp://127.0.0.1/"
        },
        "config": {
          "exchange": "sairam",
          "queue": "sairamque1",
          "durable": "true",
          "exclusive": "false",
          "autoDelete": "false",
          "maxRetries": "10",
          "retryIntervalSeconds": "1",
          "maxDurationSeconds": "300"
        },
        "plumber": {
          "type": "realtime"
        }
      }
    },
    "tuningConfig": {
        "type": "realtime",
        "maxRowsInMemory": 500000,
        "intermediatePersistPeriod": "PT10m",
        "windowPeriod": "PT10m",
        "rejectionPolicy": {
          "type": "serverTime"
        }
      }   
  }
}

I am getting following error

Failed to submit task: Could not resolve type id ‘rabbitmq’ as a subtype of org.apache.druid.data.input.FirehoseFactory: known type ids = [clipped, combining, fixedCount, http, ingestSegment, inline, local, receiver, sql, timed] (for POJO property ‘firehose’) at [Source: (org.eclipse.jetty.server.HttpInputOverHTTP); line: 1, column: 493] (through reference chain: org.apache.druid.indexing.common.task.RealtimeIndexTask[“spec”]->org.apache.druid.segment.realtime.FireDepartment[“ioConfig”]->org.apache.druid.segment.indexing.RealtimeIOConfig[“firehose”])

Notes : I added amqp-client jar file to lib directory, added druid-rabbitmq jar to extension directory. I also changed common.properties with adding druid.extensions.loadList=["druid-rabbitmq"]

Welcome @Ram! Which version of Druid are you using? I think druid-rabbitmq was removed completely in Druid 0.16.0 along with org.apache.druid.cli.Main server realtime in favor of Kafka or Kinesis.

@Mark_Herrera events thrown away. Possible causes: null events, events filtered out by transformSpec, or events outside windowPeriod.