[jira] [Commented] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering.

[ https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15133716#comment-15133716 ] Elias Levy commented on KAFKA-2729: --- Had the same issue happen here while testing a 5 no

[jira] [Comment Edited] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering.

[ https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15133716#comment-15133716 ] Elias Levy edited comment on KAFKA-2729 at 2/5/16 5:55 AM: --- Had

[jira] [Commented] (KAFKA-2923) Improve 0.9.0 Upgrade Documents

[ https://issues.apache.org/jira/browse/KAFKA-2923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15133681#comment-15133681 ] Grant Henke commented on KAFKA-2923: I think KAFKA-3164 covered point 3. For point 2,

[jira] [Assigned] (KAFKA-2923) Improve 0.9.0 Upgrade Documents

[ https://issues.apache.org/jira/browse/KAFKA-2923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke reassigned KAFKA-2923: -- Assignee: Grant Henke > Improve 0.9.0 Upgrade Documents > > >

[jira] [Updated] (KAFKA-2589) Documentation bug: the default value for the "rebalance.backoff.ms" property is not specified correctly

[ https://issues.apache.org/jira/browse/KAFKA-2589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-2589: --- Status: Patch Available (was: Open) > Documentation bug: the default value for the "rebalance.backoff

[jira] [Commented] (KAFKA-2589) Documentation bug: the default value for the "rebalance.backoff.ms" property is not specified correctly

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

[GitHub] kafka pull request: KAFKA-2589: the default value for the "rebalan...

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/876 KAFKA-2589: the default value for the "rebalance.backoff.ms" property… … is not specified correctly You can merge this pull request into a Git repository by running: $ git pull https://gi

[jira] [Assigned] (KAFKA-2589) Documentation bug: the default value for the "rebalance.backoff.ms" property is not specified correctly

[ https://issues.apache.org/jira/browse/KAFKA-2589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke reassigned KAFKA-2589: -- Assignee: Grant Henke > Documentation bug: the default value for the "rebalance.backoff.ms" pro

[jira] [Updated] (KAFKA-3037) Number of alive brokers not known after single node cluster startup

[ https://issues.apache.org/jira/browse/KAFKA-3037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-3037: --- Status: Patch Available (was: Open) > Number of alive brokers not known after single node cluster sta

[GitHub] kafka pull request: KAFKA-3037: Test number of alive brokers known...

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/875 KAFKA-3037: Test number of alive brokers known after single node clus… …ter startup You can merge this pull request into a Git repository by running: $ git pull https://github.com/granthe

[jira] [Commented] (KAFKA-3037) Number of alive brokers not known after single node cluster startup

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

[jira] [Commented] (KAFKA-3037) Number of alive brokers not known after single node cluster startup

[ https://issues.apache.org/jira/browse/KAFKA-3037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15133656#comment-15133656 ] Grant Henke commented on KAFKA-3037: [~sslavic] I think this is resolved. I wrote a sm

[jira] [Commented] (KAFKA-3206) No reconsiliation after partitioning

[ https://issues.apache.org/jira/browse/KAFKA-3206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15133580#comment-15133580 ] TAO XIAO commented on KAFKA-3206: - This is most likely due to unclean.leader.election.enab

Build failed in Jenkins: kafka-trunk-jdk7 #1021

See Changes: [me] KAFKA-3211: Handle WorkerTask stop before start correctly -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (docker Ubuntu

Jenkins build is back to normal : kafka_0.9.0_jdk7 #113

See

[jira] [Resolved] (KAFKA-3211) Handle Connect WorkerTask shutdown before startup correctly

[ https://issues.apache.org/jira/browse/KAFKA-3211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-3211. -- Resolution: Fixed Fix Version/s: 0.9.1.0 Issue resolved by pull request 8

[jira] [Commented] (KAFKA-3211) Handle Connect WorkerTask shutdown before startup correctly

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

[GitHub] kafka pull request: KAFKA-3211: handle WorkerTask stop before star...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/874 --- 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] [Commented] (KAFKA-3211) Handle Connect WorkerTask shutdown before startup correctly

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

[GitHub] kafka pull request: KAFKA-3211: handle WorkerTask stop before star...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/874 KAFKA-3211: handle WorkerTask stop before start correctly You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-3211 Alternati

[jira] [Created] (KAFKA-3214) Add consumer system tests for compressed topics

Jason Gustafson created KAFKA-3214: -- Summary: Add consumer system tests for compressed topics Key: KAFKA-3214 URL: https://issues.apache.org/jira/browse/KAFKA-3214 Project: Kafka Issue Type:

Jenkins build is back to normal : kafka-trunk-jdk8 #347

See

[jira] [Commented] (KAFKA-3188) Add system test for KIP-31 and KIP-32 - Compatibility Test

[ https://issues.apache.org/jira/browse/KAFKA-3188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15133419#comment-15133419 ] Anna Povzner commented on KAFKA-3188: - Cool! I took compatibility test. I can take one

Build failed in Jenkins: kafka-trunk-jdk7 #1020

See Changes: [jjkoshy] KAFKA-3179; Fix seek on compressed messages -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-4 (docker Ubuntu ubun

[jira] [Assigned] (KAFKA-3188) Add system test for KIP-31 and KIP-32 - Compatibility Test

[ https://issues.apache.org/jira/browse/KAFKA-3188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner reassigned KAFKA-3188: --- Assignee: Anna Povzner > Add system test for KIP-31 and KIP-32 - Compatibility Test > ---

[jira] [Commented] (KAFKA-3188) Add system test for KIP-31 and KIP-32 - Compatibility Test

[ https://issues.apache.org/jira/browse/KAFKA-3188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15133411#comment-15133411 ] Jiangjie Qin commented on KAFKA-3188: - [~apovzner] Yes, please! I am actually busy wit

[jira] [Commented] (KAFKA-3179) Kafka consumer delivers message whose offset is earlier than sought offset.

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

[jira] [Updated] (KAFKA-3179) Kafka consumer delivers message whose offset is earlier than sought offset.

[ https://issues.apache.org/jira/browse/KAFKA-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel Koshy updated KAFKA-3179: -- Resolution: Fixed Fix Version/s: (was: 0.9.0.1) 0.9.1.0 Status:

[GitHub] kafka pull request: KAFKA-3179 Fix seek on compressed messages

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/842 --- 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

Jenkins build is back to normal : kafka-trunk-jdk7 #1019

See

[jira] [Commented] (KAFKA-3188) Add system test for KIP-31 and KIP-32 - Compatibility Test

[ https://issues.apache.org/jira/browse/KAFKA-3188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1519#comment-1519 ] Anna Povzner commented on KAFKA-3188: - [~becket_qin] Thanks! Do you mind if I take one

[jira] [Comment Edited] (KAFKA-3197) Producer can send message out of order even when in flight request is set to 1.

[ https://issues.apache.org/jira/browse/KAFKA-3197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15133305#comment-15133305 ] Jiangjie Qin edited comment on KAFKA-3197 at 2/4/16 11:30 PM: --

Build failed in Jenkins: kafka_0.9.0_jdk7 #112

See Changes: [me] MINOR: Removed unnecessary Vagrantfile hack [me] MINOR: log connect reconfiguration error only if there was an error -- [...truncated 2846 lines...] kafka.log.LogCleanerIntegra

[jira] [Commented] (KAFKA-3197) Producer can send message out of order even when in flight request is set to 1.

[ https://issues.apache.org/jira/browse/KAFKA-3197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15133305#comment-15133305 ] Jiangjie Qin commented on KAFKA-3197: - Thanks [~fpj]. > Producer can send message out

[jira] [Updated] (KAFKA-3213) [CONNECT] It looks like we are not backing off properly when reconfiguring tasks

[ https://issues.apache.org/jira/browse/KAFKA-3213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3213: Description: Looking at logs of attempt to reconfigure connector while leader is restarting, I see:

[jira] [Updated] (KAFKA-3213) [CONNECT] It looks like we are not backing off properly when reconfiguring tasks

[ https://issues.apache.org/jira/browse/KAFKA-3213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3213: Description: Looking at logs of attempt to reconfigure connector while leader is restarting, I see:

[jira] [Created] (KAFKA-3213) [CONNECT] It looks like we are not backing off properly when reconfiguring tasks

Gwen Shapira created KAFKA-3213: --- Summary: [CONNECT] It looks like we are not backing off properly when reconfiguring tasks Key: KAFKA-3213 URL: https://issues.apache.org/jira/browse/KAFKA-3213 Project:

[jira] [Commented] (KAFKA-3197) Producer can send message out of order even when in flight request is set to 1.

[ https://issues.apache.org/jira/browse/KAFKA-3197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15133265#comment-15133265 ] Flavio Junqueira commented on KAFKA-3197: - [~becket_qin] thanks for the clarificat

[GitHub] kafka pull request: MINOR: more info in error msg

GitHub user ymatsuda opened a pull request: https://github.com/apache/kafka/pull/873 MINOR: more info in error msg @guozhangwang You can merge this pull request into a Git repository by running: $ git pull https://github.com/ymatsuda/kafka hotfix Alternatively you can review

[jira] [Commented] (KAFKA-3207) StateStore seems to be writing state to one topic but restoring from another

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

[jira] [Resolved] (KAFKA-3207) StateStore seems to be writing state to one topic but restoring from another

[ https://issues.apache.org/jira/browse/KAFKA-3207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3207. -- Resolution: Fixed Fix Version/s: 0.9.1.0 Issue resolved by pull request 865 [https://gith

[GitHub] kafka pull request: KAFKA-3207: Fix StateChangeLogger to use the r...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/865 --- 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

[GitHub] kafka pull request: MINOR: KTable.count() to only take a selector ...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/872 MINOR: KTable.count() to only take a selector for key You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka KCount Alternative

[GitHub] kafka pull request: MINOR: log connect reconfiguration error only ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/871 --- 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

[GitHub] kafka pull request: MINOR: log connect reconfiguration error only ...

GitHub user gwenshap opened a pull request: https://github.com/apache/kafka/pull/871 MINOR: log connect reconfiguration error only if there was an error You can merge this pull request into a Git repository by running: $ git pull https://github.com/gwenshap/kafka fix-cc-log A

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

See Changes: [me] MINOR: Removed unnecessary Vagrantfile hack [wangguoz] HOTFIX: fix partition ordering in assignment -- [...truncated 82 lines...] /x1/jenkins/jenkins-slave/workspace/kafka-trun

[GitHub] kafka pull request: KAFKA-3192: Add unwindowed aggregations for KS...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/870 KAFKA-3192: Add unwindowed aggregations for KStream You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka K3192 Alternatively

[jira] [Commented] (KAFKA-3192) Add implicit unlimited windowed aggregation for KStream

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

[jira] [Resolved] (KAFKA-2216) ConsumerMetadataRequest does not validate consumer group exists

[ https://issues.apache.org/jira/browse/KAFKA-2216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke resolved KAFKA-2216. Resolution: Not A Problem No longer relevant with the new groups protocol. > ConsumerMetadataReques

[GitHub] kafka pull request: HOTFIX: fix partition ordering in assignment

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/868 --- 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-3208) Default security.inter.broker.protocol based on configured advertised.listeners

[ https://issues.apache.org/jira/browse/KAFKA-3208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-3208: --- Affects Version/s: 0.9.0.0 > Default security.inter.broker.protocol based on configured > advertised.

[jira] [Updated] (KAFKA-3208) Default security.inter.broker.protocol based on configured advertised.listeners

[ https://issues.apache.org/jira/browse/KAFKA-3208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-3208: --- Status: Patch Available (was: Open) > Default security.inter.broker.protocol based on configured > a

[jira] [Commented] (KAFKA-3208) Default security.inter.broker.protocol based on configured advertised.listeners

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

[GitHub] kafka pull request: KAFKA-3208: Default security.inter.broker.prot...

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/869 KAFKA-3208: Default security.inter.broker.protocol based on configure… …d advertised.listeners You can merge this pull request into a Git repository by running: $ git pull https://github.

[GitHub] kafka pull request: HOTFIX: fix partition ordering in assignment

GitHub user ymatsuda opened a pull request: https://github.com/apache/kafka/pull/868 HOTFIX: fix partition ordering in assignment workround partition ordering not preserved by the consumer group management. @guozhangwang You can merge this pull request into a Git repository by

[jira] [Resolved] (KAFKA-3212) Race Condition for Repartition Topics

[ https://issues.apache.org/jira/browse/KAFKA-3212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3212. -- Resolution: Not A Problem But the consumer will not send its first metadata request until it has

[jira] [Updated] (KAFKA-3212) Race Condition for Repartition Topics

[ https://issues.apache.org/jira/browse/KAFKA-3212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3212: - Description: One type of internal topics for Kafka Streams is re-partition topics, used for table

[jira] [Created] (KAFKA-3212) Race Condition for Repartition Topics

Guozhang Wang created KAFKA-3212: Summary: Race Condition for Repartition Topics Key: KAFKA-3212 URL: https://issues.apache.org/jira/browse/KAFKA-3212 Project: Kafka Issue Type: Sub-task

[GitHub] kafka pull request: MINOR: Removed unnecessary Vagrantfile hack

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/867 --- 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

Jenkins build is back to normal : kafka-trunk-jdk8 #345

See

Build failed in Jenkins: kafka-trunk-jdk7 #1018

See Changes: [me] HOTFIX: fix broken WorkerSourceTask test -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H10 (docker Ubuntu ubuntu yahoo-not-

[jira] [Commented] (KAFKA-3206) No reconsiliation after partitioning

[ https://issues.apache.org/jira/browse/KAFKA-3206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132862#comment-15132862 ] Vahid Hashemian commented on KAFKA-3206: I can reproduce this issue. It looks like

[jira] [Updated] (KAFKA-3211) Handle Connect WorkerTask shutdown before startup correctly

[ https://issues.apache.org/jira/browse/KAFKA-3211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3211: --- Summary: Handle Connect WorkerTask shutdown before startup correctly (was: Handle WorkerTask

[jira] [Created] (KAFKA-3211) Handle WorkerTask shutdown before startup correctly

Jason Gustafson created KAFKA-3211: -- Summary: Handle WorkerTask shutdown before startup correctly Key: KAFKA-3211 URL: https://issues.apache.org/jira/browse/KAFKA-3211 Project: Kafka Issue T

[GitHub] kafka pull request: HOTFIX: fix broken WorkerSourceTask test

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/859 --- 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

[GitHub] kafka pull request: MINOR: Removed unnecessary Vagrantfile hack

GitHub user granders opened a pull request: https://github.com/apache/kafka/pull/867 MINOR: Removed unnecessary Vagrantfile hack The hack here is no longer necessary with up-to-date versions of Vagrant, vagrant-hostmanager, and vagrant-aws. What's more, the change in c8b60b63 cause

Build failed in Jenkins: kafka-trunk-jdk7 #1017

See Changes: [wangguoz] HOTFIX: temp fix for ktable look up -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-4 (docker Ubuntu ubuntu4 ubu

[jira] [Commented] (KAFKA-3203) Add UnknownCodecException and UnknownMagicByteException to error mapping

[ https://issues.apache.org/jira/browse/KAFKA-3203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132736#comment-15132736 ] Jiangjie Qin commented on KAFKA-3203: - [~granthenke] The reason we don't use UnknownMa

[jira] [Updated] (KAFKA-3210) Using asynchronous calls through the raw ZK API in ZkUtils

[ https://issues.apache.org/jira/browse/KAFKA-3210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-3210: Assignee: (was: Neha Narkhede) > Using asynchronous calls through the raw ZK API in ZkUt

[jira] [Created] (KAFKA-3210) Using asynchronous calls through the raw ZK API in ZkUtils

Flavio Junqueira created KAFKA-3210: --- Summary: Using asynchronous calls through the raw ZK API in ZkUtils Key: KAFKA-3210 URL: https://issues.apache.org/jira/browse/KAFKA-3210 Project: Kafka

[jira] [Commented] (KAFKA-3088) 0.9.0.0 broker crash on receipt of produce request with empty client ID

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

[jira] [Updated] (KAFKA-3088) 0.9.0.0 broker crash on receipt of produce request with empty client ID

[ https://issues.apache.org/jira/browse/KAFKA-3088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-3088: --- Status: Patch Available (was: Open) > 0.9.0.0 broker crash on receipt of produce request with empty c

[GitHub] kafka pull request: KAFKA-3088: broker crash on receipt of produce...

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/866 KAFKA-3088: broker crash on receipt of produce request with empty cli… …ent ID - Adds NULLABLE_STRING Type to the protocol - Changes client_id in the REQUEST_HEADER to NULLABLE_ST

[jira] [Comment Edited] (KAFKA-3197) Producer can send message out of order even when in flight request is set to 1.

[ https://issues.apache.org/jira/browse/KAFKA-3197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132698#comment-15132698 ] Jiangjie Qin edited comment on KAFKA-3197 at 2/4/16 6:18 PM: -

[jira] [Commented] (KAFKA-3207) StateStore seems to be writing state to one topic but restoring from another

[ https://issues.apache.org/jira/browse/KAFKA-3207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132699#comment-15132699 ] Guozhang Wang commented on KAFKA-3207: -- [~tom_dearman] I have uploaded a patch in th

[jira] [Commented] (KAFKA-3197) Producer can send message out of order even when in flight request is set to 1.

[ https://issues.apache.org/jira/browse/KAFKA-3197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132698#comment-15132698 ] Jiangjie Qin commented on KAFKA-3197: - [~fpj] [~ijuma] That was my first thinking as w

[GitHub] kafka pull request: HOTFIX: temp fix for ktable look up

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/864 --- 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] [Commented] (KAFKA-3207) StateStore seems to be writing state to one topic but restoring from another

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

[GitHub] kafka pull request: KAFKA-3207: Fix StateChangeLogger to use the r...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/865 KAFKA-3207: Fix StateChangeLogger to use the right topic name You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka K3207 Alte

[GitHub] kafka pull request: HOTFIX: temp fix for ktable look up

GitHub user ymatsuda opened a pull request: https://github.com/apache/kafka/pull/864 HOTFIX: temp fix for ktable look up @guozhangwang Temporarily disabled state store access checking. You can merge this pull request into a Git repository by running: $ git pull https://git

[GitHub] kafka pull request: MINOR: Pin to system tests to ducktape 0.3.10

Github user granders closed the pull request at: https://github.com/apache/kafka/pull/863 --- 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 ena

[jira] [Created] (KAFKA-3209) Support single message transforms in Kafka Connect

Neha Narkhede created KAFKA-3209: Summary: Support single message transforms in Kafka Connect Key: KAFKA-3209 URL: https://issues.apache.org/jira/browse/KAFKA-3209 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-3208) Default security.inter.broker.protocol based on configured advertised.listeners

Grant Henke created KAFKA-3208: -- Summary: Default security.inter.broker.protocol based on configured advertised.listeners Key: KAFKA-3208 URL: https://issues.apache.org/jira/browse/KAFKA-3208 Project: Ka

[jira] [Updated] (KAFKA-3208) Default security.inter.broker.protocol based on configured advertised.listeners

[ https://issues.apache.org/jira/browse/KAFKA-3208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-3208: --- Description: Currently the default security.inter.broker.protocol is PLAINTEXT. However, when enablin

[jira] [Commented] (KAFKA-3197) Producer can send message out of order even when in flight request is set to 1.

[ https://issues.apache.org/jira/browse/KAFKA-3197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132580#comment-15132580 ] Ismael Juma commented on KAFKA-3197: I was wondering the same thing [~fpj] > Producer

[jira] [Commented] (KAFKA-3197) Producer can send message out of order even when in flight request is set to 1.

[ https://issues.apache.org/jira/browse/KAFKA-3197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132571#comment-15132571 ] Flavio Junqueira commented on KAFKA-3197: - Treating it as a bug sounds right. In t

[jira] [Assigned] (KAFKA-3207) StateStore seems to be writing state to one topic but restoring from another

[ https://issues.apache.org/jira/browse/KAFKA-3207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-3207: Assignee: Guozhang Wang > StateStore seems to be writing state to one topic but restoring f

Re: Pluggable Log Compaction Policy

Becket, I put together a commit with a timestamp-based deletion policy, at https://github.com/apache/kafka/commit/2c51ae3cead99432ebf19f0303f8cc797723c939 Is this a small enough change that you'd be comfortable incorporating it into your work KIP 32, or do I need to open a separate KIP? Thanks, B

[jira] [Resolved] (KAFKA-3178) Expose a method in AdminUtils to manually truncate a specific partition to a particular offset

[ https://issues.apache.org/jira/browse/KAFKA-3178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Warshaw resolved KAFKA-3178. - Resolution: Won't Fix > Expose a method in AdminUtils to manually truncate a specific partition to

[jira] [Created] (KAFKA-3207) StateStore seems to be writing state to one topic but restoring from another

Tom Dearman created KAFKA-3207: -- Summary: StateStore seems to be writing state to one topic but restoring from another Key: KAFKA-3207 URL: https://issues.apache.org/jira/browse/KAFKA-3207 Project: Kafka

[jira] [Created] (KAFKA-3206) No reconsiliation after partitioning

Arkadiusz Firus created KAFKA-3206: -- Summary: No reconsiliation after partitioning Key: KAFKA-3206 URL: https://issues.apache.org/jira/browse/KAFKA-3206 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-3204) ConsumerConnector blocked on Authenticated by SASL Failed.

[ https://issues.apache.org/jira/browse/KAFKA-3204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132370#comment-15132370 ] Ismael Juma commented on KAFKA-3204: ZooKeeper SASL authentication is only supported i

Build failed in Jenkins: kafka_0.9.0_jdk7 #111

See Changes: [cshapi] KAFKA-3198: Ticket Renewal Thread exits prematurely due to inverted c… -- [...truncated 2915 lines...] kafka.api.ConsumerBounceTest > testConsumptionWithBrokerFailures PA

[jira] [Commented] (KAFKA-3205) Error in I/O with host (java.io.EOFException) raised in producer

[ https://issues.apache.org/jira/browse/KAFKA-3205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132073#comment-15132073 ] Jonathan Raffre commented on KAFKA-3205: KAFKA-2078 seems to resemble this, althou

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

See Changes: [cshapi] KAFKA-3198: Ticket Renewal Thread exits prematurely due to inverted c… -- [...truncated 4656 lines...] org.apache.kafka.connect.json.JsonConverterTest > mapToConnectStri

[jira] [Updated] (KAFKA-3205) Error in I/O with host (java.io.EOFException) raised in producer

[ https://issues.apache.org/jira/browse/KAFKA-3205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Raffre updated KAFKA-3205: --- Description: In a situation with a Kafka broker in 0.9 and producers still in 0.8.2.x, produc

[jira] [Created] (KAFKA-3205) Error in I/O with host (java.io.EOFException) raised in procuder

Jonathan Raffre created KAFKA-3205: -- Summary: Error in I/O with host (java.io.EOFException) raised in procuder Key: KAFKA-3205 URL: https://issues.apache.org/jira/browse/KAFKA-3205 Project: Kafka

[jira] [Updated] (KAFKA-3205) Error in I/O with host (java.io.EOFException) raised in producer

[ https://issues.apache.org/jira/browse/KAFKA-3205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Raffre updated KAFKA-3205: --- Summary: Error in I/O with host (java.io.EOFException) raised in producer (was: Error in I/O

[jira] [Created] (KAFKA-3204) ConsumerConnector blocked on Authenticated by SASL Failed.

shenyuan wang created KAFKA-3204: Summary: ConsumerConnector blocked on Authenticated by SASL Failed. Key: KAFKA-3204 URL: https://issues.apache.org/jira/browse/KAFKA-3204 Project: Kafka Issu

Build failed in Jenkins: kafka-trunk-jdk7 #1016

See Changes: [cshapi] KAFKA-3198: Ticket Renewal Thread exits prematurely due to inverted c… -- [...truncated 1379 lines...] kafka.log.FileMessageSetTest > testIterationDoesntChangePosition

  1   2   >