[jira] [Commented] (FLUME-3027) Kafka Channel should clear offsets map after commit

[ https://issues.apache.org/jira/browse/FLUME-3027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16168999#comment-16168999 ] Jeff Holoman commented on FLUME-3027: - Yes, I think this will address that as well. It has been some

[jira] [Commented] (FLUME-3086) KafkaChannel commits consume offset to Zookeeper every time causing performance problem

[ https://issues.apache.org/jira/browse/FLUME-3086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1597#comment-1597 ] Jeff Holoman commented on FLUME-3086: - I don't think I was clear enough earlier. The channel doesn't

[jira] [Commented] (FLUME-3086) KafkaChannel commits consume offset to Zookeeper every time causing performance problem

[ https://issues.apache.org/jira/browse/FLUME-3086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15969211#comment-15969211 ] Jeff Holoman commented on FLUME-3086: - We expect folks to be using Kafka for offset storage, and using

[jira] [Commented] (FLUME-3076) property flumeBatchSize in kafka sink confused

[ https://issues.apache.org/jira/browse/FLUME-3076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15935442#comment-15935442 ] Jeff Holoman commented on FLUME-3076: - Yes this is indeed a doc bug. Thanks for catching it. Will

[jira] [Assigned] (FLUME-3076) property flumeBatchSize in kafka sink confused

[ https://issues.apache.org/jira/browse/FLUME-3076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman reassigned FLUME-3076: --- Assignee: Jeff Holoman > property flumeBatchSize in kafka sink confused >

[jira] [Commented] (FLUME-3044) KafkaSink should avoid to call method without timeout param

[ https://issues.apache.org/jira/browse/FLUME-3044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15852565#comment-15852565 ] Jeff Holoman commented on FLUME-3044: - Thanks. I will take a look this weekend. Jeff > KafkaSink

[jira] [Commented] (FLUME-3046) Kafak Sink and Source Configuration Improvements

[ https://issues.apache.org/jira/browse/FLUME-3046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15831599#comment-15831599 ] Jeff Holoman commented on FLUME-3046: - Go for it. > Kafak Sink and Source Configuration Improvements

[jira] [Created] (FLUME-3046) Kafak Sink and Source Configuration Improvements

Jeff Holoman created FLUME-3046: --- Summary: Kafak Sink and Source Configuration Improvements Key: FLUME-3046 URL: https://issues.apache.org/jira/browse/FLUME-3046 Project: Flume Issue Type: Bug

[jira] [Created] (FLUME-3045) Document GitHub Pull Requests in How to Contribute Guide

Jeff Holoman created FLUME-3045: --- Summary: Document GitHub Pull Requests in How to Contribute Guide Key: FLUME-3045 URL: https://issues.apache.org/jira/browse/FLUME-3045 Project: Flume Issue

[jira] [Commented] (FLUME-3044) KafkaSink should avoid to call method without timeout param

[ https://issues.apache.org/jira/browse/FLUME-3044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828106#comment-15828106 ] Jeff Holoman commented on FLUME-3044: - Thanks for the patch. Do you mind either creating a new Review

[jira] [Created] (FLUME-3034) Update SL4J dependency from 1.6 to 1.7

Jeff Holoman created FLUME-3034: --- Summary: Update SL4J dependency from 1.6 to 1.7 Key: FLUME-3034 URL: https://issues.apache.org/jira/browse/FLUME-3034 Project: Flume Issue Type: Improvement

[jira] [Commented] (FLUME-2171) Add Interceptor to remove headers from event

[ https://issues.apache.org/jira/browse/FLUME-2171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15682517#comment-15682517 ] Jeff Holoman commented on FLUME-2171: - Committed to trunk. Thank you for your contributions

[jira] [Updated] (FLUME-3030) Improve Test Code Coverage for flume-configuration

[ https://issues.apache.org/jira/browse/FLUME-3030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman updated FLUME-3030: Affects Version/s: v1.7.0 > Improve Test Code Coverage for flume-configuration >

[jira] [Created] (FLUME-3030) Improve Test Code Coverage for flume-configuration

Jeff Holoman created FLUME-3030: --- Summary: Improve Test Code Coverage for flume-configuration Key: FLUME-3030 URL: https://issues.apache.org/jira/browse/FLUME-3030 Project: Flume Issue Type:

[jira] [Updated] (FLUME-3029) Update How To Contribute Documentation for PRs

[ https://issues.apache.org/jira/browse/FLUME-3029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman updated FLUME-3029: Issue Type: Sub-task (was: Improvement) Parent: FLUME-3028 > Update How To Contribute

[jira] [Created] (FLUME-3029) Update How To Contribute Documentation for PRs

Jeff Holoman created FLUME-3029: --- Summary: Update How To Contribute Documentation for PRs Key: FLUME-3029 URL: https://issues.apache.org/jira/browse/FLUME-3029 Project: Flume Issue Type:

[jira] [Created] (FLUME-3028) Introduce merge-flume-pr.py script

Jeff Holoman created FLUME-3028: --- Summary: Introduce merge-flume-pr.py script Key: FLUME-3028 URL: https://issues.apache.org/jira/browse/FLUME-3028 Project: Flume Issue Type: Improvement

[jira] [Commented] (FLUME-3026) Add Kafka 0.10 support for Flume

[ https://issues.apache.org/jira/browse/FLUME-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15681100#comment-15681100 ] Jeff Holoman commented on FLUME-3026: - The current requirement is that the Kafka version of the broker

[jira] [Commented] (FLUME-2662) Upgrade to Commons-IO 2.4

[ https://issues.apache.org/jira/browse/FLUME-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15680497#comment-15680497 ] Jeff Holoman commented on FLUME-2662: - Ran tests, LGTM > Upgrade to Commons-IO 2.4 >

[jira] [Created] (FLUME-3027) Kafka Channel should clear offsets map after commit

Jeff Holoman created FLUME-3027: --- Summary: Kafka Channel should clear offsets map after commit Key: FLUME-3027 URL: https://issues.apache.org/jira/browse/FLUME-3027 Project: Flume Issue Type:

[jira] [Assigned] (FLUME-3027) Kafka Channel should clear offsets map after commit

[ https://issues.apache.org/jira/browse/FLUME-3027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman reassigned FLUME-3027: --- Assignee: Jeff Holoman > Kafka Channel should clear offsets map after commit >

[jira] [Commented] (FLUME-3026) Add Kafka 0.10 support for Flume

[ https://issues.apache.org/jira/browse/FLUME-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15676806#comment-15676806 ] Jeff Holoman commented on FLUME-3026: - Hi [~pingwang] I'm not sure what this is intending to address

[jira] [Commented] (FLUME-2171) Add Interceptor to remove headers from event

[ https://issues.apache.org/jira/browse/FLUME-2171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663994#comment-15663994 ] Jeff Holoman commented on FLUME-2171: - I added some minor comments. After you've had a chance to take

[jira] [Commented] (FLUME-2171) Add Interceptor to remove headers from event

[ https://issues.apache.org/jira/browse/FLUME-2171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15655411#comment-15655411 ] Jeff Holoman commented on FLUME-2171: - I will do a review of this over the next couple of days.

[jira] [Created] (FLUME-3004) Provide option to skip an event in Kafka Components

Jeff Holoman created FLUME-3004: --- Summary: Provide option to skip an event in Kafka Components Key: FLUME-3004 URL: https://issues.apache.org/jira/browse/FLUME-3004 Project: Flume Issue Type:

[jira] [Updated] (FLUME-2989) Kafka Channel metrics missing eventTakeAttemptCount and eventPutAttemptCount

[ https://issues.apache.org/jira/browse/FLUME-2989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman updated FLUME-2989: Assignee: Umesh Chaudhary (was: Jeff Holoman) > Kafka Channel metrics missing

[jira] [Commented] (FLUME-2989) Kafka Channel metrics missing eventTakeAttemptCount and eventPutAttemptCount

[ https://issues.apache.org/jira/browse/FLUME-2989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15537665#comment-15537665 ] Jeff Holoman commented on FLUME-2989: - Ok sounds good. > Kafka Channel metrics missing

[jira] [Commented] (FLUME-2988) Kafka Sink metrics missing eventDrainAttemptCount

[ https://issues.apache.org/jira/browse/FLUME-2988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15534702#comment-15534702 ] Jeff Holoman commented on FLUME-2988: - Go for it. > Kafka Sink metrics missing eventDrainAttemptCount

[jira] [Commented] (FLUME-2647) File Channel must print the reason for the channel being closed in channelClosed checks

[ https://issues.apache.org/jira/browse/FLUME-2647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15503608#comment-15503608 ] Jeff Holoman commented on FLUME-2647: - [~umesh9...@gmail.com] I think you are good to take this over.

[jira] [Assigned] (FLUME-2989) Kafka Channel metrics missing eventTakeAttemptCount and eventPutAttemptCount

[ https://issues.apache.org/jira/browse/FLUME-2989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman reassigned FLUME-2989: --- Assignee: Jeff Holoman > Kafka Channel metrics missing eventTakeAttemptCount and

[jira] [Assigned] (FLUME-2988) Kafka Sink metrics missing eventDrainAttemptCount

[ https://issues.apache.org/jira/browse/FLUME-2988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman reassigned FLUME-2988: --- Assignee: Jeff Holoman > Kafka Sink metrics missing eventDrainAttemptCount >

[jira] [Updated] (FLUME-2982) Add localhost escape sequence to HDFS sink

[ https://issues.apache.org/jira/browse/FLUME-2982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman updated FLUME-2982: Attachment: (was: FLUME-2982.patch.2) > Add localhost escape sequence to HDFS sink >

[jira] [Updated] (FLUME-2982) Add localhost escape sequence to HDFS sink

[ https://issues.apache.org/jira/browse/FLUME-2982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman updated FLUME-2982: Attachment: (was: FLUME-2982.patch.1) > Add localhost escape sequence to HDFS sink >

[jira] [Updated] (FLUME-2982) Add localhost escape sequence to HDFS sink

[ https://issues.apache.org/jira/browse/FLUME-2982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman updated FLUME-2982: Attachment: FLUME-2982.patch.2 > Add localhost escape sequence to HDFS sink >

[jira] [Commented] (FLUME-2982) Add localhost escape sequence to HDFS sink

[ https://issues.apache.org/jira/browse/FLUME-2982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15449541#comment-15449541 ] Jeff Holoman commented on FLUME-2982: - Thanks @mpercy I took a look at this and tested on a few

[jira] [Updated] (FLUME-2982) Add localhost escape sequence to HDFS sink

[ https://issues.apache.org/jira/browse/FLUME-2982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman updated FLUME-2982: Attachment: FLUME-2982.patch.1 > Add localhost escape sequence to HDFS sink >

[jira] [Created] (FLUME-2982) Add localhost escape sequence to HDFS sink

Jeff Holoman created FLUME-2982: --- Summary: Add localhost escape sequence to HDFS sink Key: FLUME-2982 URL: https://issues.apache.org/jira/browse/FLUME-2982 Project: Flume Issue Type:

[jira] [Assigned] (FLUME-2982) Add localhost escape sequence to HDFS sink

[ https://issues.apache.org/jira/browse/FLUME-2982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman reassigned FLUME-2982: --- Assignee: Jeff Holoman > Add localhost escape sequence to HDFS sink >

[jira] [Updated] (FLUME-2810) Add static Schema URL to AvroEventSerializer configuration

[ https://issues.apache.org/jira/browse/FLUME-2810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman updated FLUME-2810: Attachment: FLUME-2810v7.patch > Add static Schema URL to AvroEventSerializer configuration >

[jira] [Updated] (FLUME-2810) Add static Schema URL to AvroEventSerializer configuration

[ https://issues.apache.org/jira/browse/FLUME-2810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman updated FLUME-2810: Attachment: (was: FLUME-2810v6.patch) > Add static Schema URL to AvroEventSerializer

[jira] [Commented] (FLUME-2810) Add static Schema URL to AvroEventSerializer configuration

[ https://issues.apache.org/jira/browse/FLUME-2810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15364784#comment-15364784 ] Jeff Holoman commented on FLUME-2810: - Review Board has been updated based on comments and this patch

[jira] [Updated] (FLUME-2810) Add static Schema URL to AvroEventSerializer configuration

[ https://issues.apache.org/jira/browse/FLUME-2810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman updated FLUME-2810: Attachment: FLUME-2810v6.patch > Add static Schema URL to AvroEventSerializer configuration >

[jira] [Updated] (FLUME-2810) Add static Schema URL to AvroEventSerializer configuration

[ https://issues.apache.org/jira/browse/FLUME-2810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman updated FLUME-2810: Fix Version/s: v1.7.0 > Add static Schema URL to AvroEventSerializer configuration >

[jira] [Commented] (FLUME-2820) Support New Kafka APIs

[ https://issues.apache.org/jira/browse/FLUME-2820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15323811#comment-15323811 ] Jeff Holoman commented on FLUME-2820: - Yes, this should enable all security features available in the

[jira] [Commented] (FLUME-2920) Kafka Channel Should Not Commit Offsets When Stopping

[ https://issues.apache.org/jira/browse/FLUME-2920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15323580#comment-15323580 ] Jeff Holoman commented on FLUME-2920: - +1 > Kafka Channel Should Not Commit Offsets When Stopping >

[jira] [Updated] (FLUME-2915) The kafka channel using new APIs will be stuck when the sink is avro sink

[ https://issues.apache.org/jira/browse/FLUME-2915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman updated FLUME-2915: Attachment: FLUME-2915v2.patch > The kafka channel using new APIs will be stuck when the sink is

[jira] [Updated] (FLUME-2915) The kafka channel using new APIs will be stuck when the sink is avro sink

[ https://issues.apache.org/jira/browse/FLUME-2915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman updated FLUME-2915: Attachment: FLUME-2915.patch > The kafka channel using new APIs will be stuck when the sink is avro

[jira] [Commented] (FLUME-2915) The kafka channel using new APIs will be stuck when the sink is avro sink

[ https://issues.apache.org/jira/browse/FLUME-2915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15321788#comment-15321788 ] Jeff Holoman commented on FLUME-2915: - https://reviews.apache.org/r/48457/diff/ > The kafka channel

[jira] [Assigned] (FLUME-2915) The kafka channel using new APIs will be stuck when the sink is avro sink

[ https://issues.apache.org/jira/browse/FLUME-2915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman reassigned FLUME-2915: --- Assignee: Jeff Holoman > The kafka channel using new APIs will be stuck when the sink is

[jira] [Commented] (FLUME-2915) The kafka channel using new APIs will be stuck when the sink is avro sink

[ https://issues.apache.org/jira/browse/FLUME-2915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15314879#comment-15314879 ] Jeff Holoman commented on FLUME-2915: - Thanks for spotting this. I will take a look at this over the

[jira] [Commented] (FLUME-2810) Add static Schema URL to AvroEventSerializer configuration

[ https://issues.apache.org/jira/browse/FLUME-2810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15282887#comment-15282887 ] Jeff Holoman commented on FLUME-2810: - [~jarcec], [~hshreedharan] Do you think either of you could do

[jira] [Commented] (FLUME-2901) Document Kerberos setup for Kafka channel

[ https://issues.apache.org/jira/browse/FLUME-2901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15252483#comment-15252483 ] Jeff Holoman commented on FLUME-2901: - LGTM +1 > Document Kerberos setup for Kafka channel >

[jira] [Commented] (FLUME-2901) Document Kerberos setup for Kafka channel

[ https://issues.apache.org/jira/browse/FLUME-2901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15249238#comment-15249238 ] Jeff Holoman commented on FLUME-2901: - Looks ok but the following lines need to be addressed:

[jira] [Updated] (FLUME-2821) Flume-Kafka Source with new Consumer

[ https://issues.apache.org/jira/browse/FLUME-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman updated FLUME-2821: Assignee: Grigoriy Rozhkov > Flume-Kafka Source with new Consumer >

[jira] [Resolved] (FLUME-2896) Remove support for deprecated properties for Kafka Source Sink and Channel

[ https://issues.apache.org/jira/browse/FLUME-2896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman resolved FLUME-2896. - Resolution: Duplicate > Remove support for deprecated properties for Kafka Source Sink and

[jira] [Commented] (FLUME-2896) Remove support for deprecated properties for Kafka Source Sink and Channel

[ https://issues.apache.org/jira/browse/FLUME-2896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15211134#comment-15211134 ] Jeff Holoman commented on FLUME-2896: - This is covered by FLUME-2895 > Remove support for deprecated

[jira] [Updated] (FLUME-2821) Flume-Kafka Source with new Consumer

[ https://issues.apache.org/jira/browse/FLUME-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman updated FLUME-2821: Assignee: (was: Ted Malaska) > Flume-Kafka Source with new Consumer >

[jira] [Assigned] (FLUME-2895) Remove Old Properties from Kafka components

[ https://issues.apache.org/jira/browse/FLUME-2895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman reassigned FLUME-2895: --- Assignee: Jeff Holoman > Remove Old Properties from Kafka components >

[jira] [Updated] (FLUME-2895) Remove Old Properties from Kafka components

[ https://issues.apache.org/jira/browse/FLUME-2895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman updated FLUME-2895: Description: In the a future Flume release we need to remove the old kafka properties from the

[jira] [Created] (FLUME-2895) Remove Old Properties from Kafka components

Jeff Holoman created FLUME-2895: --- Summary: Remove Old Properties from Kafka components Key: FLUME-2895 URL: https://issues.apache.org/jira/browse/FLUME-2895 Project: Flume Issue Type:

[jira] [Updated] (FLUME-2823) Flume-Kafka-Channel with new APIs

[ https://issues.apache.org/jira/browse/FLUME-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman updated FLUME-2823: Attachment: FLUME-2823v6.patch > Flume-Kafka-Channel with new APIs >

[jira] [Updated] (FLUME-2823) Flume-Kafka-Channel with new APIs

[ https://issues.apache.org/jira/browse/FLUME-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman updated FLUME-2823: Attachment: FLUME-2823v4.patch > Flume-Kafka-Channel with new APIs >

[jira] [Updated] (FLUME-2822) Flume-Kafka-Sink with new Producer

[ https://issues.apache.org/jira/browse/FLUME-2822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman updated FLUME-2822: Attachment: FLUME-2822.patch > Flume-Kafka-Sink with new Producer >

[jira] [Commented] (FLUME-2799) Kafka Source - Message Offset and Partition add to headers

[ https://issues.apache.org/jira/browse/FLUME-2799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15097141#comment-15097141 ] Jeff Holoman commented on FLUME-2799: - I haven't had a chance to look at the patch but it's worth

[jira] [Updated] (FLUME-2852) Kafka Source/Sink should optionally read/write Avro Datums

[ https://issues.apache.org/jira/browse/FLUME-2852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman updated FLUME-2852: Assignee: Tristan Stevens > Kafka Source/Sink should optionally read/write Avro Datums >

[jira] [Commented] (FLUME-2852) Kafka Source/Sink should optionally read/write Avro Datums

[ https://issues.apache.org/jira/browse/FLUME-2852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15097138#comment-15097138 ] Jeff Holoman commented on FLUME-2852: - Ok by me > Kafka Source/Sink should optionally read/write Avro

[jira] [Updated] (FLUME-2852) Kafka Source/Sink should optionally read/write Avro Datums

[ https://issues.apache.org/jira/browse/FLUME-2852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman updated FLUME-2852: Assignee: (was: Jeff Holoman) > Kafka Source/Sink should optionally read/write Avro Datums >

[jira] [Commented] (FLUME-2821) Flume-Kafka Source with new Consumer

[ https://issues.apache.org/jira/browse/FLUME-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15070170#comment-15070170 ] Jeff Holoman commented on FLUME-2821: - [~malaskat] Is it ok if we assign this to [~groghkov] ?

[jira] [Commented] (FLUME-2852) Kafka Source/Sink should optionally read/write Avro Datums

[ https://issues.apache.org/jira/browse/FLUME-2852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15068966#comment-15068966 ] Jeff Holoman commented on FLUME-2852: - Tristan, This seems like a reasonable feature request to me.

[jira] [Commented] (FLUME-2820) Support New Kafka APIs

[ https://issues.apache.org/jira/browse/FLUME-2820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15068770#comment-15068770 ] Jeff Holoman commented on FLUME-2820: - There are patches in review for the Sink and Channel, and I

[jira] [Commented] (FLUME-2822) Flume-Kafka-Sink with new Producer

[ https://issues.apache.org/jira/browse/FLUME-2822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15068172#comment-15068172 ] Jeff Holoman commented on FLUME-2822: - Sorry Xin I didn't see this. I've uploaded a patch to Review

[jira] [Commented] (FLUME-2823) Flume-Kafka-Channel with new APIs

[ https://issues.apache.org/jira/browse/FLUME-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15068173#comment-15068173 ] Jeff Holoman commented on FLUME-2823: - Review Board Updated > Flume-Kafka-Channel with new APIs >

[jira] [Commented] (FLUME-2855) Add kafka 0.9 support for Flume

[ https://issues.apache.org/jira/browse/FLUME-2855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15055962#comment-15055962 ] Jeff Holoman commented on FLUME-2855: - Hi Grigory, There is already an umbrella jira for this

[jira] [Commented] (FLUME-2852) Kafka Source/Sink should optionally read/write Avro Datums

[ https://issues.apache.org/jira/browse/FLUME-2852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15046919#comment-15046919 ] Jeff Holoman commented on FLUME-2852: - Just want to make sure I understand the issue as I'm working on

[jira] [Assigned] (FLUME-2852) Kafka Source/Sink should optionally read/write Avro Datums

[ https://issues.apache.org/jira/browse/FLUME-2852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman reassigned FLUME-2852: --- Assignee: Jeff Holoman > Kafka Source/Sink should optionally read/write Avro Datums >

[jira] [Assigned] (FLUME-2821) Flume-Kafka Source with new Consumer

[ https://issues.apache.org/jira/browse/FLUME-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman reassigned FLUME-2821: --- Assignee: Jeff Holoman > Flume-Kafka Source with new Consumer >

[jira] [Assigned] (FLUME-2822) Flume-Kafka-Sink with new Producer

[ https://issues.apache.org/jira/browse/FLUME-2822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman reassigned FLUME-2822: --- Assignee: Jeff Holoman > Flume-Kafka-Sink with new Producer >

[jira] [Assigned] (FLUME-2823) Flume-Kafka-Channel with new APIs

[ https://issues.apache.org/jira/browse/FLUME-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman reassigned FLUME-2823: --- Assignee: Jeff Holoman > Flume-Kafka-Channel with new APIs >

[jira] [Commented] (FLUME-2821) Flume-Kafka Source with new Consumer

[ https://issues.apache.org/jira/browse/FLUME-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14970192#comment-14970192 ] Jeff Holoman commented on FLUME-2821: - Sure thing. > Flume-Kafka Source with new Consumer >

[jira] [Updated] (FLUME-2821) Flume-Kafka Source with new Consumer

[ https://issues.apache.org/jira/browse/FLUME-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman updated FLUME-2821: Assignee: Ted Malaska (was: Jeff Holoman) > Flume-Kafka Source with new Consumer >

[jira] [Created] (FLUME-2821) Flume-Kafka Source with new Consumer

Jeff Holoman created FLUME-2821: --- Summary: Flume-Kafka Source with new Consumer Key: FLUME-2821 URL: https://issues.apache.org/jira/browse/FLUME-2821 Project: Flume Issue Type: Sub-task

[jira] [Created] (FLUME-2823) Flume-Kafka-Channel with new APIs

Jeff Holoman created FLUME-2823: --- Summary: Flume-Kafka-Channel with new APIs Key: FLUME-2823 URL: https://issues.apache.org/jira/browse/FLUME-2823 Project: Flume Issue Type: Sub-task

[jira] [Created] (FLUME-2820) Support New Kafka APIs

Jeff Holoman created FLUME-2820: --- Summary: Support New Kafka APIs Key: FLUME-2820 URL: https://issues.apache.org/jira/browse/FLUME-2820 Project: Flume Issue Type: Improvement

[jira] [Created] (FLUME-2822) Flume-Kafka-Sink with new Producer

Jeff Holoman created FLUME-2822: --- Summary: Flume-Kafka-Sink with new Producer Key: FLUME-2822 URL: https://issues.apache.org/jira/browse/FLUME-2822 Project: Flume Issue Type: Sub-task

[jira] [Commented] (FLUME-2760) Flafka configuration seems unclear and I get either serialized data for serialized schema in HDFS file.

[ https://issues.apache.org/jira/browse/FLUME-2760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14952319#comment-14952319 ] Jeff Holoman commented on FLUME-2760: - [~mqchrisw] Did you manage to get this sorted out? > Flafka

[jira] [Assigned] (FLUME-2810) Add static Schema URL to AvroEventSerializer configuration

[ https://issues.apache.org/jira/browse/FLUME-2810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman reassigned FLUME-2810: --- Assignee: Jeff Holoman > Add static Schema URL to AvroEventSerializer configuration >

[jira] [Created] (FLUME-2810) Add static Schema URL to AvroEventSerializer configuration

Jeff Holoman created FLUME-2810: --- Summary: Add static Schema URL to AvroEventSerializer configuration Key: FLUME-2810 URL: https://issues.apache.org/jira/browse/FLUME-2810 Project: Flume Issue