Skip to content

AMQP consumer stopped if message is empty #5170

@hardiksondagar

Description

@hardiksondagar

Relevant telegraf.conf:

# Configuration for sending metrics to InfluxDB
[[outputs.influxdb]]
  urls = ["http://influx.domain.com:8086"]
  database = "sense"

# AMQP consumer plugin
[[inputs.amqp_consumer]]
  brokers = ["amqp://queue.domain.com:5672"]
  username = "RABBIT"
  password = "SECRET"
  exchange = "influx"
  queue = "influx"
  queue_durability = "durable"
  binding_key = ""
  prefetch_count = 500
  data_format = "influx"

System info:

OS

Linux version 4.15.0-1021-aws (buildd@lcy01-amd64-001) (gcc version 7.3.0 (Ubuntu 7.3.0-16ubuntu3)) #21-Ubuntu SMP Tue Aug 28 10:23:07 UTC 2018

Telegraf

Telegraf 1.9.0 (git: HEAD 2bf21c0d)

Steps to reproduce:

  1. Push blank/empty message to queue

Expected behavior:

Blank message should have dropped

Actual behavior:

It stopped consuming from the queue and connection stays idle in rabbitmq

Metadata

Metadata

Assignees

No one assigned

    Labels

    area/rabbitmqbugunexpected problem or unintended behavior

    Type

    No type

    Projects

    No projects

    Milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions