Build failed in Jenkins: kafka_0.9.0_jdk7 #110

See Changes: [me] MINOR: Pin to system tests to ducktape 0.3.10 -- [...truncated 2916 lines...] kafka.integration.SaslSslTopicMetadataTest > testBasicTopicMetadata PASSED kafka.integration.SaslS

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

[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

[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-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: --- Description: In a situation with a Kafka broker in 0.9 and producers still in 0.8.2.x, produc

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] [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_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-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

[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] [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] [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

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] [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

[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] [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] [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] [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:

[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

[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: 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

[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: 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-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

[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] [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: -

[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] [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

[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] [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] [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

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

[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

[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

[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

[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] [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

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-

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

See

[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

[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

[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] [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

[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

[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.

[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

[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] [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.

[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] [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

[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

[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

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: 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

[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: 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: 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

[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

[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

[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-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

[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] [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] [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

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] [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: --

[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

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

See

[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

[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:

[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] [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 > ---

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] [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

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

See

[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:

[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] [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 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] [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

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

See

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

[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

[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

[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] [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

[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

[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] [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

[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] [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] [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] [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

  1   2   >