[jira] [Commented] (KAFKA-4385) producer is sending too many unnecessary meta data request if the meta data for a topic is not available and "auto.create.topics.enable" =false

[ https://issues.apache.org/jira/browse/KAFKA-4385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15641989#comment-15641989 ] Jiangjie Qin commented on KAFKA-4385: - [~Jun Yao] Is this really a problem? The

[jira] [Commented] (KAFKA-4385) producer is sending too many unnecessary meta data request if the meta data for a topic is not available and "auto.create.topics.enable" =false

[ https://issues.apache.org/jira/browse/KAFKA-4385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15642072#comment-15642072 ] Jiangjie Qin commented on KAFKA-4385: - Thanks for the explanation. Sor

[jira] [Commented] (KAFKA-4385) producer is sending too many unnecessary meta data request if the meta data for a topic is not available and "auto.create.topics.enable" =false

[ https://issues.apache.org/jira/browse/KAFKA-4385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15642789#comment-15642789 ] Jiangjie Qin commented on KAFKA-4385: - It seems you are more worrying about

[jira] [Commented] (KAFKA-4381) Add per partition lag metric to KafkaConsumer.

[ https://issues.apache.org/jira/browse/KAFKA-4381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15642796#comment-15642796 ] Jiangjie Qin commented on KAFKA-4381: - Yeah, it should be a simple one. I&#x

[jira] [Updated] (KAFKA-3994) Deadlock between consumer heartbeat expiration and offset commit.

[ https://issues.apache.org/jira/browse/KAFKA-3994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-3994: Priority: Critical (was: Major) > Deadlock between consumer heartbeat expiration and offset com

[jira] [Commented] (KAFKA-4381) Add per partition lag metric to KafkaConsumer.

[ https://issues.apache.org/jira/browse/KAFKA-4381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15644978#comment-15644978 ] Jiangjie Qin commented on KAFKA-4381: - Thanks Jason. I was not sure either. That

[jira] [Commented] (KAFKA-4384) ReplicaFetcherThread stopped after ReplicaFetcherThread received a corrupted message

[ https://issues.apache.org/jira/browse/KAFKA-4384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15654659#comment-15654659 ] Jiangjie Qin commented on KAFKA-4384: - [~junhe] Thanks for the patch. Kafka actu

[jira] [Commented] (KAFKA-4398) offsetsForTimes returns false starting offset when timestamp of messages are not monotonically increasing

[ https://issues.apache.org/jira/browse/KAFKA-4398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15657795#comment-15657795 ] Jiangjie Qin commented on KAFKA-4398: - [~huxi_2b] I am not sure I understand

[jira] [Commented] (KAFKA-2076) Add an API to new consumer to allow user get high watermark of partitions.

[ https://issues.apache.org/jira/browse/KAFKA-2076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15657963#comment-15657963 ] Jiangjie Qin commented on KAFKA-2076: - [~jeffwidman] The consumer actually are

[jira] [Resolved] (KAFKA-2076) Add an API to new consumer to allow user get high watermark of partitions.

[ https://issues.apache.org/jira/browse/KAFKA-2076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved KAFKA-2076. - Resolution: Fixed Fix Version/s: 0.10.1.0 After KIP-79(https://cwiki.apache.org

[jira] [Commented] (KAFKA-4398) offsetsForTimes returns false starting offset when timestamp of messages are not monotonically increasing

[ https://issues.apache.org/jira/browse/KAFKA-4398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15658960#comment-15658960 ] Jiangjie Qin commented on KAFKA-4398: - I see, you are saying that the broker sh

[jira] [Created] (KAFKA-4401) Change the KafkaServerTestHarness and IntegrationTestHarness from trait to abstract class.

Jiangjie Qin created KAFKA-4401: --- Summary: Change the KafkaServerTestHarness and IntegrationTestHarness from trait to abstract class. Key: KAFKA-4401 URL: https://issues.apache.org/jira/browse/KAFKA-4401

[jira] [Resolved] (KAFKA-4409) ZK consumer shutdown/topic event deadlock

[ https://issues.apache.org/jira/browse/KAFKA-4409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved KAFKA-4409. - Resolution: Fixed Assignee: Joel Koshy Reviewer: Jiangjie Qin > ZK consumer shutd

[jira] [Updated] (KAFKA-4409) ZK consumer shutdown/topic event deadlock

[ https://issues.apache.org/jira/browse/KAFKA-4409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-4409: Affects Version/s: 0.10.1.0 Fix Version/s: 0.10.1.1 Component/s: core

[jira] [Commented] (KAFKA-4401) Change the KafkaServerTestHarness and IntegrationTestHarness from trait to abstract class.

[ https://issues.apache.org/jira/browse/KAFKA-4401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15665054#comment-15665054 ] Jiangjie Qin commented on KAFKA-4401: - [~ewencp] Interestingly, we have done the

[jira] [Commented] (KAFKA-3994) Deadlock between consumer heartbeat expiration and offset commit.

[ https://issues.apache.org/jira/browse/KAFKA-3994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15678587#comment-15678587 ] Jiangjie Qin commented on KAFKA-3994: - [~mjuarez] Thanks for the update. Good to

[jira] [Resolved] (KAFKA-4443) Controller should send UpdateMetadataRequest prior to LeaderAndIsrRequest during failover

[ https://issues.apache.org/jira/browse/KAFKA-4443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved KAFKA-4443. - Resolution: Fixed > Controller should send UpdateMetadataRequest prior to LeaderAndIsrRequ

[jira] [Updated] (KAFKA-4443) Controller should send UpdateMetadataRequest prior to LeaderAndIsrRequest during failover

[ https://issues.apache.org/jira/browse/KAFKA-4443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-4443: Affects Version/s: 0.10.1.0 Fix Version/s: 0.10.1.1 > Controller should s

[jira] [Updated] (KAFKA-4415) Reduce time to create and send MetadataUpdateRequest

[ https://issues.apache.org/jira/browse/KAFKA-4415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-4415: Affects Version/s: 0.10.1.0 Fix Version/s: 0.10.1.1 > Reduce time to create and s

[jira] [Resolved] (KAFKA-4415) Reduce time to create and send MetadataUpdateRequest

[ https://issues.apache.org/jira/browse/KAFKA-4415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved KAFKA-4415. - Resolution: Fixed > Reduce time to create and send MetadataUpdateRequ

[jira] [Updated] (KAFKA-4485) Follower should be in the isr if its FetchRequest has fetched up to the logEndOffset of leader

[ https://issues.apache.org/jira/browse/KAFKA-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-4485: Affects Version/s: 0.10.1.0 Reviewer: Jiangjie Qin Fix Version/s: 0.10.2.0

[jira] [Updated] (KAFKA-4445) PreferredLeaderElectionCommand should query zk only once per topic

[ https://issues.apache.org/jira/browse/KAFKA-4445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-4445: Affects Version/s: 0.10.1.0 Fix Version/s: 0.10.2.0 Issue Type: Improvement (was

[jira] [Resolved] (KAFKA-4445) PreferredLeaderElectionCommand should query zk only once per topic

[ https://issues.apache.org/jira/browse/KAFKA-4445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved KAFKA-4445. - Resolution: Fixed > PreferredLeaderElectionCommand should query zk only once per to

[jira] [Assigned] (KAFKA-4497) log cleaner breaks on timeindex

[ https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned KAFKA-4497: --- Assignee: Jiangjie Qin > log cleaner breaks on timein

[jira] [Commented] (KAFKA-4497) log cleaner breaks on timeindex

[ https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15739018#comment-15739018 ] Jiangjie Qin commented on KAFKA-4497: - I looked at the log cleaner code in 0.

[jira] [Commented] (KAFKA-4497) log cleaner breaks on timeindex

[ https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15739035#comment-15739035 ] Jiangjie Qin commented on KAFKA-4497: - To be more clear, this part of the code

[jira] [Commented] (KAFKA-4497) log cleaner breaks on timeindex

[ https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15743122#comment-15743122 ] Jiangjie Qin commented on KAFKA-4497: - [~junrao] I think 0x is actuall

[jira] [Commented] (KAFKA-4497) log cleaner breaks on timeindex

[ https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15743650#comment-15743650 ] Jiangjie Qin commented on KAFKA-4497: - The negative bit is the MSB which is

[jira] [Comment Edited] (KAFKA-4497) log cleaner breaks on timeindex

[ https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15743650#comment-15743650 ] Jiangjie Qin edited comment on KAFKA-4497 at 12/13/16 12:3

[jira] [Comment Edited] (KAFKA-4497) log cleaner breaks on timeindex

[ https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15743650#comment-15743650 ] Jiangjie Qin edited comment on KAFKA-4497 at 12/13/16 12:4

[jira] [Commented] (KAFKA-4529) tombstone may be removed earlier than it should

[ https://issues.apache.org/jira/browse/KAFKA-4529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15744529#comment-15744529 ] Jiangjie Qin commented on KAFKA-4529: - Sure, I'll submit a patch. > tomb

[jira] [Assigned] (KAFKA-4529) tombstone may be removed earlier than it should

[ https://issues.apache.org/jira/browse/KAFKA-4529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned KAFKA-4529: --- Assignee: Jiangjie Qin > tombstone may be removed earlier than it sho

[jira] [Work started] (KAFKA-4529) tombstone may be removed earlier than it should

[ https://issues.apache.org/jira/browse/KAFKA-4529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4529 started by Jiangjie Qin. --- > tombstone may be removed earlier than it sho

[jira] [Resolved] (KAFKA-4521) MirrorMaker should flush all messages before releasing partition ownership during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-4521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved KAFKA-4521. - Resolution: Fixed > MirrorMaker should flush all messages before releasing partition owners

[jira] [Updated] (KAFKA-4521) MirrorMaker should flush all messages before releasing partition ownership during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-4521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-4521: Affects Version/s: 0.10.1.0 Fix Version/s: 0.10.2.0 > MirrorMaker should flush all messa

[jira] [Updated] (KAFKA-4447) Controller resigned but it also acts as a controller for a long time

[ https://issues.apache.org/jira/browse/KAFKA-4447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-4447: Fix Version/s: 0.10.2.0 > Controller resigned but it also acts as a controller for a long t

[jira] [Updated] (KAFKA-2980) ZookeeperConsumerConnector may enter deadlock if a rebalance occurs during a stream creation.

[ https://issues.apache.org/jira/browse/KAFKA-2980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2980: Resolution: Cannot Reproduce Status: Resolved (was: Patch Available

[jira] [Commented] (KAFKA-4497) log cleaner breaks on timeindex

[ https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15786213#comment-15786213 ] Jiangjie Qin commented on KAFKA-4497: - [~sandieg] I cannot think of a good workar

[jira] [Updated] (KAFKA-3995) Add a new configuration "enable.compression.ratio.estimation" to the producer config

[ https://issues.apache.org/jira/browse/KAFKA-3995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-3995: Summary: Add a new configuration "enable.compression.ratio.estimation" to the producer co

[jira] [Commented] (KAFKA-3436) Speed up controlled shutdown.

[ https://issues.apache.org/jira/browse/KAFKA-3436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15884390#comment-15884390 ] Jiangjie Qin commented on KAFKA-3436: - [~onurkaraman] is currently working on rew

[jira] [Commented] (KAFKA-3436) Speed up controlled shutdown.

[ https://issues.apache.org/jira/browse/KAFKA-3436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15884419#comment-15884419 ] Jiangjie Qin commented on KAFKA-3436: - Sorry you are right. I was under

[jira] [Created] (KAFKA-4833) Transient unit test failure in AbstractCoordinatorTest

Jiangjie Qin created KAFKA-4833: --- Summary: Transient unit test failure in AbstractCoordinatorTest Key: KAFKA-4833 URL: https://issues.apache.org/jira/browse/KAFKA-4833 Project: Kafka Issue

[jira] [Updated] (KAFKA-4833) Transient unit test failure in AbstractCoordinatorTest

[ https://issues.apache.org/jira/browse/KAFKA-4833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-4833: Affects Version/s: 0.10.2.0 > Transient unit test failure in AbstractCoordinatorT

[jira] [Updated] (KAFKA-4833) Transient unit test failure in AbstractCoordinatorTest

[ https://issues.apache.org/jira/browse/KAFKA-4833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-4833: Description: I saw this couple of times when running unit test locally. Haven't looked into

[jira] [Resolved] (KAFKA-4833) Transient unit test failure in AbstractCoordinatorTest

[ https://issues.apache.org/jira/browse/KAFKA-4833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved KAFKA-4833. - Resolution: Invalid Just noticed that the test was failing on a review branch instead of trunk

[jira] [Commented] (KAFKA-4877) Expose TimestampType in Producer RecordMetadata

[ https://issues.apache.org/jira/browse/KAFKA-4877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904148#comment-15904148 ] Jiangjie Qin commented on KAFKA-4877: - [~hachikuji] The original idea was that

[jira] [Updated] (KAFKA-4891) kafka.request.logger TRACE regression

[ https://issues.apache.org/jira/browse/KAFKA-4891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-4891: Fix Version/s: 0.10.2.1 > kafka.request.logger TRACE regress

[jira] [Updated] (KAFKA-4891) kafka.request.logger TRACE regression

[ https://issues.apache.org/jira/browse/KAFKA-4891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-4891: Fix Version/s: (was: 0.10.2.1) 0.11.0.0 > kafka.request.logger TR

[jira] [Resolved] (KAFKA-4891) kafka.request.logger TRACE regression

[ https://issues.apache.org/jira/browse/KAFKA-4891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved KAFKA-4891. - Resolution: Fixed > kafka.request.logger TRACE regress

[jira] [Commented] (KAFKA-4907) compacted topic shouldn't reject messages with old timestamp

[ https://issues.apache.org/jira/browse/KAFKA-4907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927231#comment-15927231 ] Jiangjie Qin commented on KAFKA-4907: - [~junrao] Are you referring to the log cle

[jira] [Commented] (KAFKA-4907) compacted topic shouldn't reject messages with old timestamp

[ https://issues.apache.org/jira/browse/KAFKA-4907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927392#comment-15927392 ] Jiangjie Qin commented on KAFKA-4907: - [~junrao] Thanks for the explanation.

[jira] [Commented] (KAFKA-4907) compacted topic shouldn't reject messages with old timestamp

[ https://issues.apache.org/jira/browse/KAFKA-4907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927438#comment-15927438 ] Jiangjie Qin commented on KAFKA-4907: - [~ijuma] Hmm, if {{cleanup.policy}} is NOT

[jira] [Assigned] (KAFKA-4907) compacted topic shouldn't reject messages with old timestamp

[ https://issues.apache.org/jira/browse/KAFKA-4907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned KAFKA-4907: --- Assignee: Jiangjie Qin > compacted topic shouldn't reject messages with old t

[jira] [Commented] (KAFKA-4907) compacted topic shouldn't reject messages with old timestamp

[ https://issues.apache.org/jira/browse/KAFKA-4907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927460#comment-15927460 ] Jiangjie Qin commented on KAFKA-4907: - I see. Yeah, the default behavior prob

[jira] [Assigned] (KAFKA-5011) Replica fetchers may need to down-convert messages during a selective message format upgrade

[ https://issues.apache.org/jira/browse/KAFKA-5011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned KAFKA-5011: --- Assignee: Jiangjie Qin > Replica fetchers may need to down-convert messages durin

[jira] [Commented] (KAFKA-4401) Change the KafkaServerTestHarness and IntegrationTestHarness from trait to abstract class.

[ https://issues.apache.org/jira/browse/KAFKA-4401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15961463#comment-15961463 ] Jiangjie Qin commented on KAFKA-4401: - Sure, I just linked KAFKA-5041 to this ti

[jira] [Resolved] (KAFKA-4401) Change the KafkaServerTestHarness and IntegrationTestHarness from trait to abstract class.

[ https://issues.apache.org/jira/browse/KAFKA-4401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved KAFKA-4401. - Resolution: Fixed > Change the KafkaServerTestHarness and IntegrationTestHarness from trait

[jira] [Created] (KAFKA-5075) The position in the consumers may be advanced incorrectly when some exception is thrown from consumer.poll()

Jiangjie Qin created KAFKA-5075: --- Summary: The position in the consumers may be advanced incorrectly when some exception is thrown from consumer.poll() Key: KAFKA-5075 URL: https://issues.apache.org/jira/browse

[jira] [Updated] (KAFKA-5075) The position in the consumers may be advanced incorrectly when some exception is thrown from consumer.poll()

[ https://issues.apache.org/jira/browse/KAFKA-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-5075: Affects Version/s: 0.10.2.0 Fix Version/s: 0.10.2.1 Component/s: consumer

[jira] [Assigned] (KAFKA-5075) The position in the consumers may be advanced incorrectly when some exception is thrown from consumer.poll()

[ https://issues.apache.org/jira/browse/KAFKA-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned KAFKA-5075: --- Assignee: Dong Lin > The position in the consumers may be advanced incorrectly when s

[jira] [Commented] (KAFKA-5075) The position in the consumers may be advanced incorrectly when some exception is thrown from consumer.poll()

[ https://issues.apache.org/jira/browse/KAFKA-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969699#comment-15969699 ] Jiangjie Qin commented on KAFKA-5075: - [~gwenshap] I was actually about to repl

[jira] [Commented] (KAFKA-5075) The position in the consumers may be advanced incorrectly when some exception is thrown from consumer.poll()

[ https://issues.apache.org/jira/browse/KAFKA-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969730#comment-15969730 ] Jiangjie Qin commented on KAFKA-5075: - [~lindong] is currently working on the p

[jira] [Commented] (KAFKA-5075) Defer exception to the next pollOnce() if consumer's fetch position has already increased

[ https://issues.apache.org/jira/browse/KAFKA-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970771#comment-15970771 ] Jiangjie Qin commented on KAFKA-5075: - [~gwenshap] The patch has been checke

[jira] [Commented] (KAFKA-5075) Defer exception to the next pollOnce() if consumer's fetch position has already increased

[ https://issues.apache.org/jira/browse/KAFKA-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971639#comment-15971639 ] Jiangjie Qin commented on KAFKA-5075: - [~hachikuji] I also think it is worth fi

[jira] [Commented] (KAFKA-5075) Defer exception to the next pollOnce() if consumer's fetch position has already increased

[ https://issues.apache.org/jira/browse/KAFKA-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971892#comment-15971892 ] Jiangjie Qin commented on KAFKA-5075: - [~hachikuji] [~gwenshap] I've cher

[jira] [Commented] (KAFKA-1840) Add a simple message handler in Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-1840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14283390#comment-14283390 ] Jiangjie Qin commented on KAFKA-1840: - Created reviewboard https://reviews.apache

[jira] [Updated] (KAFKA-1840) Add a simple message handler in Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-1840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1840: Attachment: KAFKA-1840.patch > Add a simple message handler in Mirror Ma

[jira] [Updated] (KAFKA-1840) Add a simple message handler in Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-1840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1840: Assignee: Jiangjie Qin Status: Patch Available (was: Open) > Add a simple message handler

[jira] [Commented] (KAFKA-1840) Add a simple message handler in Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-1840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14284284#comment-14284284 ] Jiangjie Qin commented on KAFKA-1840: - Updated reviewboard https://reviews.apache

[jira] [Updated] (KAFKA-1840) Add a simple message handler in Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-1840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1840: Attachment: KAFKA-1840_2015-01-20_11:36:14.patch > Add a simple message handler in Mirror Ma

[jira] [Updated] (KAFKA-1839) Adding an afterRebalance callback to the ConsumerRebalanceListener of ZookeeperConsumerConnector

[ https://issues.apache.org/jira/browse/KAFKA-1839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1839: Attachment: KAFKA-1839_2015-01-20_11:49:12.patch > Adding an afterRebalance callback to

[jira] [Commented] (KAFKA-1839) Adding an afterRebalance callback to the ConsumerRebalanceListener of ZookeeperConsumerConnector

[ https://issues.apache.org/jira/browse/KAFKA-1839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14284298#comment-14284298 ] Jiangjie Qin commented on KAFKA-1839: - Updated reviewboard https://reviews.apache

[jira] [Updated] (KAFKA-1839) Adding an afterRebalance callback to the ConsumerRebalanceListener of ZookeeperConsumerConnector

[ https://issues.apache.org/jira/browse/KAFKA-1839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1839: Assignee: Jiangjie Qin Status: Patch Available (was: Open) > Adding an afterRebala

[jira] [Updated] (KAFKA-1839) Adding an afterRebalance callback to the ConsumerRebalanceListener of ZookeeperConsumerConnector

[ https://issues.apache.org/jira/browse/KAFKA-1839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1839: Attachment: KAFKA-1839_2015-01-20_13:28:25.patch > Adding an afterRebalance callback to

[jira] [Commented] (KAFKA-1839) Adding an afterRebalance callback to the ConsumerRebalanceListener of ZookeeperConsumerConnector

[ https://issues.apache.org/jira/browse/KAFKA-1839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14284449#comment-14284449 ] Jiangjie Qin commented on KAFKA-1839: - Updated reviewboard https://reviews.apache

[jira] [Created] (KAFKA-1890) Follow-up patch for KAFKA-1650

Jiangjie Qin created KAFKA-1890: --- Summary: Follow-up patch for KAFKA-1650 Key: KAFKA-1890 URL: https://issues.apache.org/jira/browse/KAFKA-1890 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-1890) Follow-up patch for KAFKA-1650

[ https://issues.apache.org/jira/browse/KAFKA-1890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14288404#comment-14288404 ] Jiangjie Qin commented on KAFKA-1890: - Yes, this is the one I'm fixing. &g

[jira] [Updated] (KAFKA-1890) Follow-up patch for KAFKA-1650

[ https://issues.apache.org/jira/browse/KAFKA-1890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1890: Status: Patch Available (was: Open) > Follow-up patch for KAFKA-1

[jira] [Updated] (KAFKA-1890) Follow-up patch for KAFKA-1650

[ https://issues.apache.org/jira/browse/KAFKA-1890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1890: Attachment: KAFKA-1890.patch > Follow-up patch for KAFKA-1

[jira] [Commented] (KAFKA-1890) Follow-up patch for KAFKA-1650

[ https://issues.apache.org/jira/browse/KAFKA-1890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14288438#comment-14288438 ] Jiangjie Qin commented on KAFKA-1890: - Created reviewboard https://reviews.apache

[jira] [Created] (KAFKA-1896) Record size funcition of record in mirror maker hit NPE when the message value is null.

Jiangjie Qin created KAFKA-1896: --- Summary: Record size funcition of record in mirror maker hit NPE when the message value is null. Key: KAFKA-1896 URL: https://issues.apache.org/jira/browse/KAFKA-1896

[jira] [Updated] (KAFKA-1896) Record size funcition of record in mirror maker hit NPE when the message value is null.

[ https://issues.apache.org/jira/browse/KAFKA-1896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1896: Attachment: KAFKA-1896.patch > Record size funcition of record in mirror maker hit NPE when

[jira] [Commented] (KAFKA-1896) Record size funcition of record in mirror maker hit NPE when the message value is null.

[ https://issues.apache.org/jira/browse/KAFKA-1896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14290130#comment-14290130 ] Jiangjie Qin commented on KAFKA-1896: - Created reviewboard https://reviews.apache

[jira] [Updated] (KAFKA-1896) Record size funcition of record in mirror maker hit NPE when the message value is null.

[ https://issues.apache.org/jira/browse/KAFKA-1896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1896: Status: Patch Available (was: Open) > Record size funcition of record in mirror maker hit NPE w

[jira] [Created] (KAFKA-1905) KafkaProducer's performance could be halved when MaxInFlightRequest is set to 1

Jiangjie Qin created KAFKA-1905: --- Summary: KafkaProducer's performance could be halved when MaxInFlightRequest is set to 1 Key: KAFKA-1905 URL: https://issues.apache.org/jira/browse/KAFKA-1905 Pr

[jira] [Assigned] (KAFKA-1905) KafkaProducer's performance could be halved when MaxInFlightRequest is set to 1

[ https://issues.apache.org/jira/browse/KAFKA-1905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned KAFKA-1905: --- Assignee: Jiangjie Qin > KafkaProducer's performance could be halved when MaxInFligh

[jira] [Commented] (KAFKA-1840) Add a simple message handler in Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-1840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14299579#comment-14299579 ] Jiangjie Qin commented on KAFKA-1840: - Updated reviewboard https://reviews.apache

[jira] [Updated] (KAFKA-1840) Add a simple message handler in Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-1840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1840: Attachment: KAFKA-1840_2015-01-30_18:25:00.patch > Add a simple message handler in Mirror Ma

[jira] [Commented] (KAFKA-1840) Add a simple message handler in Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-1840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14300109#comment-14300109 ] Jiangjie Qin commented on KAFKA-1840: - Updated reviewboard https://reviews.apache

[jira] [Updated] (KAFKA-1840) Add a simple message handler in Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-1840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1840: Attachment: KAFKA-1840_2015-02-01_00:16:53.patch > Add a simple message handler in Mirror Ma

[jira] [Commented] (KAFKA-1922) Move doubly linked list test out of UtilsTest

[ https://issues.apache.org/jira/browse/KAFKA-1922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14306665#comment-14306665 ] Jiangjie Qin commented on KAFKA-1922: - Created reviewboard https://reviews.apache

[jira] [Updated] (KAFKA-1922) Move doubly linked list test out of UtilsTest

[ https://issues.apache.org/jira/browse/KAFKA-1922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1922: Status: Patch Available (was: Open) > Move doubly linked list test out of UtilsT

[jira] [Updated] (KAFKA-1922) Move doubly linked list test out of UtilsTest

[ https://issues.apache.org/jira/browse/KAFKA-1922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1922: Attachment: KAFKA-1922.patch > Move doubly linked list test out of UtilsT

[jira] [Created] (KAFKA-1934) Add a shutdownNow() call to new producer

Jiangjie Qin created KAFKA-1934: --- Summary: Add a shutdownNow() call to new producer Key: KAFKA-1934 URL: https://issues.apache.org/jira/browse/KAFKA-1934 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-1447) Controlled shutdown deadlock when trying to send state updates

[ https://issues.apache.org/jira/browse/KAFKA-1447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311599#comment-14311599 ] Jiangjie Qin commented on KAFKA-1447: - I think KAFKA-1305 solved this i

[jira] [Commented] (KAFKA-1908) Split brain

[ https://issues.apache.org/jira/browse/KAFKA-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311617#comment-14311617 ] Jiangjie Qin commented on KAFKA-1908: - [~aozeritsky] It looks the scenario should

[jira] [Created] (KAFKA-1937) Mirror maker needs to clear the unacked offset map after rebalance.

Jiangjie Qin created KAFKA-1937: --- Summary: Mirror maker needs to clear the unacked offset map after rebalance. Key: KAFKA-1937 URL: https://issues.apache.org/jira/browse/KAFKA-1937 Project: Kafka

[jira] [Updated] (KAFKA-1937) Mirror maker needs to clear the unacked offset map after rebalance.

[ https://issues.apache.org/jira/browse/KAFKA-1937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1937: Status: Patch Available (was: Open) > Mirror maker needs to clear the unacked offset map af

[jira] [Commented] (KAFKA-1937) Mirror maker needs to clear the unacked offset map after rebalance.

[ https://issues.apache.org/jira/browse/KAFKA-1937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14313195#comment-14313195 ] Jiangjie Qin commented on KAFKA-1937: - Created reviewboard https://reviews.apache

[jira] [Updated] (KAFKA-1937) Mirror maker needs to clear the unacked offset map after rebalance.

[ https://issues.apache.org/jira/browse/KAFKA-1937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1937: Attachment: KAFKA-1937.patch > Mirror maker needs to clear the unacked offset map after rebala

<    2   3   4   5   6   7   8   9   10   11   >