[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15992337#comment-15992337 ] ASF GitHub Bot commented on NIFI-3739: -- Github user asfgit closed the pull request at:

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15992313#comment-15992313 ] ASF GitHub Bot commented on NIFI-3739: -- GitHub user markap14 opened a pull request:

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15992307#comment-15992307 ] Joseph Witt commented on NIFI-3739: --- seeing this {code} 2017-05-02 00:00:36,541 ERROR [

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991923#comment-15991923 ] ASF GitHub Bot commented on NIFI-3739: -- Github user asfgit closed the pull request at:

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991921#comment-15991921 ] ASF subversion and git services commented on NIFI-3739: --- Commit 07989

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991867#comment-15991867 ] ASF GitHub Bot commented on NIFI-3739: -- Github user markap14 commented on the issue:

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991711#comment-15991711 ] ASF GitHub Bot commented on NIFI-3739: -- Github user joewitt commented on the issue:

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991456#comment-15991456 ] ASF GitHub Bot commented on NIFI-3739: -- Github user joewitt commented on the issue:

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991447#comment-15991447 ] ASF GitHub Bot commented on NIFI-3739: -- Github user markap14 commented on the issue:

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991341#comment-15991341 ] ASF GitHub Bot commented on NIFI-3739: -- Github user joewitt commented on the issue:

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991256#comment-15991256 ] ASF GitHub Bot commented on NIFI-3739: -- Github user joewitt commented on the issue:

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991182#comment-15991182 ] ASF GitHub Bot commented on NIFI-3739: -- Github user markap14 commented on the issue:

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991052#comment-15991052 ] ASF GitHub Bot commented on NIFI-3739: -- Github user joewitt commented on a diff in the

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991051#comment-15991051 ] ASF GitHub Bot commented on NIFI-3739: -- Github user joewitt commented on a diff in the

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991039#comment-15991039 ] ASF GitHub Bot commented on NIFI-3739: -- Github user joewitt commented on a diff in the

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991036#comment-15991036 ] ASF GitHub Bot commented on NIFI-3739: -- Github user joewitt commented on a diff in the

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991028#comment-15991028 ] ASF GitHub Bot commented on NIFI-3739: -- Github user joewitt commented on a diff in the

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15990955#comment-15990955 ] Mark Payne commented on NIFI-3739: -- I've pushed a new commit that I believe handles the ca

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15990772#comment-15990772 ] Mark Payne commented on NIFI-3739: -- [~joewitt] - thanks for review again! Will certainly a

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15990535#comment-15990535 ] Joseph Witt commented on NIFI-3739: --- [~markap14] So things left I believe 1. If we fail t

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15989764#comment-15989764 ] Joseph Witt commented on NIFI-3739: --- [~markap14] ok so i've tested it quite a bit. Thing

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15989728#comment-15989728 ] Joseph Witt commented on NIFI-3739: --- this error 2017-04-28 23:22:07,716 ERROR [Timer-Dri

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15989251#comment-15989251 ] Mark Payne commented on NIFI-3739: -- OK [~joewitt] thanks for testing! I pushed a new commi

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988134#comment-15988134 ] Joseph Witt commented on NIFI-3739: --- also think this needs to do more than single pulls a

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988131#comment-15988131 ] Joseph Witt commented on NIFI-3739: --- Switched from using the remote hwx schema reg to a l

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988122#comment-15988122 ] Joseph Witt commented on NIFI-3739: --- seeing several of these in stack dumps "Timer-Drive

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988115#comment-15988115 ] Joseph Witt commented on NIFI-3739: --- i've noticed when i stop the consumer for the record

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988107#comment-15988107 ] Joseph Witt commented on NIFI-3739: --- i'm using this command to monitor my raw consumer

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988105#comment-15988105 ] Joseph Witt commented on NIFI-3739: --- The test i'm doing is pretty straight forward. Gene

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988103#comment-15988103 ] Joseph Witt commented on NIFI-3739: --- also while testing i lost connectivity to the schema

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988069#comment-15988069 ] Joseph Witt commented on NIFI-3739: --- that appears to be a handling error for errors but t

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988068#comment-15988068 ] Joseph Witt commented on NIFI-3739: --- Seeing a lot of these when try to read prov json, wr

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15987667#comment-15987667 ] Joseph Witt commented on NIFI-3739: --- putting fix version on giving how close it is and ho

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15987666#comment-15987666 ] Joseph Witt commented on NIFI-3739: --- nice will advise of my findings too > Create Proces

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15987649#comment-15987649 ] Mark Payne commented on NIFI-3739: -- I pushed a new update that includes some performance o

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15983646#comment-15983646 ] Mark Payne commented on NIFI-3739: -- I also found a bug where we don't properly cache the s

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15983643#comment-15983643 ] Mark Payne commented on NIFI-3739: -- I still need to add unit tests to these processors and

[jira] [Commented] (NIFI-3739) Create Processors for publishing records to and consuming records from Kafka

[ https://issues.apache.org/jira/browse/NIFI-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15983641#comment-15983641 ] ASF GitHub Bot commented on NIFI-3739: -- GitHub user markap14 opened a pull request: