[jira] [Commented] (KAFKA-2843) when consumer got empty messageset, fetchResponse.highWatermark != current_offset?

[ https://issues.apache.org/jira/browse/KAFKA-2843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15020378#comment-15020378 ] jin xing commented on KAFKA-2843: - cannot reproduce this > when consumer got empty messag

[jira] [Updated] (KAFKA-2843) when consumer got empty messageset, fetchResponse.highWatermark != current_offset?

[ https://issues.apache.org/jira/browse/KAFKA-2843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jin xing updated KAFKA-2843: Assignee: (was: jin xing) > when consumer got empty messageset, fetchResponse.highWatermark != > curren

[jira] [Commented] (KAFKA-2003) Add upgrade tests

[ https://issues.apache.org/jira/browse/KAFKA-2003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15020476#comment-15020476 ] Ismael Juma commented on KAFKA-2003: [~geoffra], isn't this done? > Add upgrade tests

[GitHub] kafka pull request: KAFKA-2872 Fixed addSink method connecting sin...

GitHub user bbejeck opened a pull request: https://github.com/apache/kafka/pull/572 KAFKA-2872 Fixed addSink method connecting sink with parent source(s)… Starting a KafkaStream was getting an error due to the fact that the TopologyBuilder.addSink method was not connecting the sin

[jira] [Commented] (KAFKA-2872) Error starting KafkaStream caused by sink not being connected to parent source/processor nodes

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

[jira] [Work started] (KAFKA-2872) Error starting KafkaStream caused by sink not being connected to parent source/processor nodes

[ https://issues.apache.org/jira/browse/KAFKA-2872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2872 started by Bill Bejeck. -- > Error starting KafkaStream caused by sink not being connected to parent > source/p

[jira] [Work stopped] (KAFKA-2872) Error starting KafkaStream caused by sink not being connected to parent source/processor nodes

[ https://issues.apache.org/jira/browse/KAFKA-2872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2872 stopped by Bill Bejeck. -- > Error starting KafkaStream caused by sink not being connected to parent > source/p

Contribution

Hi, I would like to start contributing Kafka. Could you add me to the contributor list? I am looking forward to hearing from you. Regards, Konrad Kalita

Re: Contribution

Hello Konrad, What is your apache id? Guozhang On Sat, Nov 21, 2015 at 7:53 AM, Konrad Kalita wrote: > Hi, > I would like to start contributing Kafka. Could you add me to the > contributor list? > > I am looking forward to hearing from you. > > Regards, > Konrad Kalita > -- -- Guozhang

[jira] [Updated] (KAFKA-2865) Improve Request API Error Code Documention

[ https://issues.apache.org/jira/browse/KAFKA-2865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2865: - Labels: newbiee (was: ) > Improve Request API Error Code Documention > --

[jira] [Commented] (KAFKA-2718) Reuse of temporary directories leading to transient unit test failures

[ https://issues.apache.org/jira/browse/KAFKA-2718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15020591#comment-15020591 ] Guozhang Wang commented on KAFKA-2718: -- [~rsivaram] Still saw this error after mergin

[jira] [Commented] (KAFKA-2843) when consumer got empty messageset, fetchResponse.highWatermark != current_offset?

[ https://issues.apache.org/jira/browse/KAFKA-2843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15020604#comment-15020604 ] Guozhang Wang commented on KAFKA-2843: -- If you have a controller log on the brokers,

[jira] [Assigned] (KAFKA-2804) Create / Update changelog topics upon state store initialization

[ https://issues.apache.org/jira/browse/KAFKA-2804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-2804: Assignee: Guozhang Wang > Create / Update changelog topics upon state store initialization

[jira] [Work stopped] (KAFKA-2872) Error starting KafkaStream caused by sink not being connected to parent source/processor nodes

[ https://issues.apache.org/jira/browse/KAFKA-2872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2872 stopped by Bill Bejeck. -- > Error starting KafkaStream caused by sink not being connected to parent > source/p

[jira] [Updated] (KAFKA-2872) Error starting KafkaStream caused by sink not being connected to parent source/processor nodes

[ https://issues.apache.org/jira/browse/KAFKA-2872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-2872: --- Fix Version/s: 0.9.0.0 Status: Patch Available (was: Open) Updated the ToplogyBuilder.addS

[jira] [Commented] (KAFKA-2872) Error starting KafkaStream caused by sink not being connected to parent source/processor nodes

[ https://issues.apache.org/jira/browse/KAFKA-2872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15020741#comment-15020741 ] Bill Bejeck commented on KAFKA-2872: There appears to be a test failure (kafka.api.Ss

[jira] [Commented] (KAFKA-2872) Error starting KafkaStream caused by sink not being connected to parent source/processor nodes

[ https://issues.apache.org/jira/browse/KAFKA-2872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15020801#comment-15020801 ] Guozhang Wang commented on KAFKA-2872: -- [~bbejeck] Yeah I think that is unrelated, ha

[GitHub] kafka pull request: KAFKA-2872 Fixed addSink method connecting sin...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/572 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[jira] [Updated] (KAFKA-2872) Error starting KafkaStream caused by sink not being connected to parent source/processor nodes

[ https://issues.apache.org/jira/browse/KAFKA-2872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2872: - Resolution: Fixed Fix Version/s: (was: 0.9.0.0) 0.9.1.0 St

[jira] [Commented] (KAFKA-2872) Error starting KafkaStream caused by sink not being connected to parent source/processor nodes

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

Build failed in Jenkins: kafka-trunk-jdk8 #177

See Changes: [guozhang] KAFKA-2872: unite sink nodes with parent nodes in addSink -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-2 (dock