Log4j 2
  1. Log4j 2
  2. LOG4J2-275

The send method in FlumeAvroManager quietly loses messages on a failed rpcClient connection

    Details

    • Type: Bug Bug
    • Status: Closed
    • Priority: Major Major
    • Resolution: Fixed
    • Affects Version/s: 2.0-beta6
    • Fix Version/s: 2.0-beta8
    • Component/s: Flume Appender
    • Labels:
      None

      Description

      In the FlumeAvroManager in the send method, the code looks like this:

      @Override
      public synchronized void send(final Event event) {
      if (rpcClient == null)

      { rpcClient = connect(agents, retries, connectTimeout, requestTimeout); }

      if (rpcClient != null) {
      try

      { rpcClient.append(event); }

      catch (final Exception ex) {.........

      if the rpcClient is null and the connect fails the rpcClient is still null and the method returns losing the event. I think this is a bug.

      Thanks

        Activity

          People

          • Assignee:
            Ralph Goers
            Reporter:
            Jinder Aujla
          • Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

            • Created:
              Updated:
              Resolved:

              Development