Flume
  1. Flume
  2. FLUME-2734

Kafka Channel timeout property is overridden by default value

    Details

    • Type: Bug Bug
    • Status: Closed
    • Priority: Major Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: v1.7.0
    • Component/s: None
    • Labels:
      None

      Description

      Kafka Channel timeout property which will be passed to the Kafka Consumer internally, does not work as expected, as in the code, it is overridden by default value (or value specified by .timeout property which is undocumented)

        Activity

        Hide
        Johny Rufus added a comment -

        Attaching patch which enables kafka.consumer.timeout.ms specified in the config to take effect like other kafka consumer properties

        Show
        Johny Rufus added a comment - Attaching patch which enables kafka.consumer.timeout.ms specified in the config to take effect like other kafka consumer properties
        Hide
        Jarek Jarcec Cecho added a comment -

        +1

        Show
        Jarek Jarcec Cecho added a comment - +1
        Hide
        ASF subversion and git services added a comment -

        Commit d8d97db4be954fc15e4632d6c9ae5dd8f46c189c in flume's branch refs/heads/trunk from Jarek Jarcec Cecho
        [ https://git-wip-us.apache.org/repos/asf?p=flume.git;h=d8d97db ]

        FLUME-2734: Kafka Channel timeout property is overridden by default value

        (Johny Rufus via Jarek Jarcec Cecho)

        Show
        ASF subversion and git services added a comment - Commit d8d97db4be954fc15e4632d6c9ae5dd8f46c189c in flume's branch refs/heads/trunk from Jarek Jarcec Cecho [ https://git-wip-us.apache.org/repos/asf?p=flume.git;h=d8d97db ] FLUME-2734 : Kafka Channel timeout property is overridden by default value (Johny Rufus via Jarek Jarcec Cecho)
        Hide
        ASF subversion and git services added a comment -

        Commit a562820869576e512317299ac9e676c5bae41182 in flume's branch refs/heads/flume-1.7 from Jarek Jarcec Cecho
        [ https://git-wip-us.apache.org/repos/asf?p=flume.git;h=a562820 ]

        FLUME-2734: Kafka Channel timeout property is overridden by default value

        (Johny Rufus via Jarek Jarcec Cecho)

        Show
        ASF subversion and git services added a comment - Commit a562820869576e512317299ac9e676c5bae41182 in flume's branch refs/heads/flume-1.7 from Jarek Jarcec Cecho [ https://git-wip-us.apache.org/repos/asf?p=flume.git;h=a562820 ] FLUME-2734 : Kafka Channel timeout property is overridden by default value (Johny Rufus via Jarek Jarcec Cecho)
        Hide
        Jarek Jarcec Cecho added a comment -

        Thank you for your contribution Johny Rufus!

        Show
        Jarek Jarcec Cecho added a comment - Thank you for your contribution Johny Rufus !
        Hide
        Hudson added a comment -

        SUCCESS: Integrated in Flume-trunk-hbase-1 #127 (See https://builds.apache.org/job/Flume-trunk-hbase-1/127/)
        FLUME-2734: Kafka Channel timeout property is overridden by default (jarcec: http://git-wip-us.apache.org/repos/asf/flume/repo?p=flume.git&a=commit&h=d8d97db4be954fc15e4632d6c9ae5dd8f46c189c)

        • flume-ng-channels/flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java
        • flume-ng-channels/flume-kafka-channel/src/test/java/org/apache/flume/channel/kafka/TestKafkaChannel.java
        Show
        Hudson added a comment - SUCCESS: Integrated in Flume-trunk-hbase-1 #127 (See https://builds.apache.org/job/Flume-trunk-hbase-1/127/ ) FLUME-2734 : Kafka Channel timeout property is overridden by default (jarcec: http://git-wip-us.apache.org/repos/asf/flume/repo?p=flume.git&a=commit&h=d8d97db4be954fc15e4632d6c9ae5dd8f46c189c ) flume-ng-channels/flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java flume-ng-channels/flume-kafka-channel/src/test/java/org/apache/flume/channel/kafka/TestKafkaChannel.java

          People

          • Assignee:
            Johny Rufus
            Reporter:
            Johny Rufus
          • Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

            • Created:
              Updated:
              Resolved:

              Development