[
https://issues.apache.org/jira/browse/KAFKA-10889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin resolved KAFKA-10889.
--
Resolution: Not A Bug
I am closing the issue as not a bug because the brokers were working
[
https://issues.apache.org/jira/browse/KAFKA-6029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin resolved KAFKA-6029.
-
Resolution: Fixed
> Controller should wait for the leader migration to finish before
Jiangjie Qin created KAFKA-6568:
---
Summary: LogCleanerManager.doneDeleting() should check the
partition state before deleting the in progress partition
Key: KAFKA-6568
URL: https://issues.apache.org/jira/browse
[
https://issues.apache.org/jira/browse/KAFKA-6489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin resolved KAFKA-6489.
-
Resolution: Fixed
> Fetcher.retrieveOffsetsByTimes() should add all the topics to the metad
Jiangjie Qin created KAFKA-6492:
---
Summary: LogSemgent.truncateTo() should always resize the index
file
Key: KAFKA-6492
URL: https://issues.apache.org/jira/browse/KAFKA-6492
Project: Kafka
Jiangjie Qin created KAFKA-6489:
---
Summary: Fetcher.retrieveOffsetsByTimes() should add all the
topics to the metadata refresh topics set.
Key: KAFKA-6489
URL: https://issues.apache.org/jira/browse/KAFKA-6489
Jiangjie Qin created KAFKA-6321:
---
Summary: ConsumerGroupCommand should use the new consumer to query
the log end offsets.
Key: KAFKA-6321
URL: https://issues.apache.org/jira/browse/KAFKA-6321
Project
Jiangjie Qin created KAFKA-6304:
---
Summary: The controller should allow update the partition
reassignment for the partitions being reassigned
Key: KAFKA-6304
URL: https://issues.apache.org/jira/browse/KAFKA-6304
Jiangjie Qin created KAFKA-6264:
---
Summary: Log cleaner thread may die on legacy segment containing
messages whose offsets are too large
Key: KAFKA-6264
URL: https://issues.apache.org/jira/browse/KAFKA-6264
[
https://issues.apache.org/jira/browse/KAFKA-6157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin resolved KAFKA-6157.
-
Resolution: Fixed
> Fix repeated words words in JavaDoc and comme
Jiangjie Qin created KAFKA-6083:
---
Summary: The Fetcher should add the InvalidRecordException as a
cause to the KafkaException when invalid record is found.
Key: KAFKA-6083
URL: https://issues.apache.org/jira/browse
Jiangjie Qin created KAFKA-6029:
---
Summary: Controller should wait for the leader migration to finish
before ack a ControlledShutdownRequest
Key: KAFKA-6029
URL: https://issues.apache.org/jira/browse/KAFKA-6029
Jiangjie Qin created KAFKA-6028:
---
Summary: Improve the quota throttle communication.
Key: KAFKA-6028
URL: https://issues.apache.org/jira/browse/KAFKA-6028
Project: Kafka
Issue Type
Jiangjie Qin created KAFKA-5834:
---
Summary: AbstractConfig.logUnused() may log confusing warning
information.
Key: KAFKA-5834
URL: https://issues.apache.org/jira/browse/KAFKA-5834
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-5694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin resolved KAFKA-5694.
-
Resolution: Implemented
Fix Version/s: 1.0.0
> Add ChangeReplicaDirRequ
Jiangjie Qin created KAFKA-5782:
---
Summary: Avoid unnecessary PID reset when expire batches.
Key: KAFKA-5782
URL: https://issues.apache.org/jira/browse/KAFKA-5782
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-5681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin resolved KAFKA-5681.
-
Resolution: Won't Fix
Discussed in the PR. Closing the ticket as won't fix.
> jarAll d
Jiangjie Qin created KAFKA-5681:
---
Summary: jarAll does not build all scala versions anymore.
Key: KAFKA-5681
URL: https://issues.apache.org/jira/browse/KAFKA-5681
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-5627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin resolved KAFKA-5627.
-
Resolution: Fixed
> Reduce classes needed for LeaderAndIsrPartitionSt
[
https://issues.apache.org/jira/browse/KAFKA-5453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050070#comment-16050070
]
Jiangjie Qin commented on KAFKA-5453:
-
I don't think so. This is a probably a bug since some pretty
Jiangjie Qin created KAFKA-5453:
---
Summary: Controller may miss requests sent to the broker when zk
session timeout happens.
Key: KAFKA-5453
URL: https://issues.apache.org/jira/browse/KAFKA-5453
Project
[
https://issues.apache.org/jira/browse/KAFKA-5453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-5453:
Affects Version/s: 0.11.0.0
> Controller may miss requests sent to the broker when zk sess
[
https://issues.apache.org/jira/browse/KAFKA-5453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-5453:
Component/s: core
> Controller may miss requests sent to the broker when zk session time
[
https://issues.apache.org/jira/browse/KAFKA-5453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-5453:
Fix Version/s: 0.11.1.0
> Controller may miss requests sent to the broker when zk session time
[
https://issues.apache.org/jira/browse/KAFKA-5344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-5344:
Status: Patch Available (was: Open)
> Change message.timestamp.difference.max.ms b
Jiangjie Qin created KAFKA-5344:
---
Summary: Change message.timestamp.difference.max.ms back to
Long.MaxValue
Key: KAFKA-5344
URL: https://issues.apache.org/jira/browse/KAFKA-5344
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-5078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin resolved KAFKA-5078.
-
Resolution: Fixed
> PartitionRecords.fetchRecords(...) should defer exception to the next c
[
https://issues.apache.org/jira/browse/KAFKA-5078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-5078:
Fix Version/s: 0.11.0.0
> PartitionRecords.fetchRecords(...) should defer exception to the n
[
https://issues.apache.org/jira/browse/KAFKA-5329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16026532#comment-16026532
]
Jiangjie Qin commented on KAFKA-5329:
-
[~ijuma] The ControllerContext is fine. This ticket
[
https://issues.apache.org/jira/browse/KAFKA-5329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-5329:
Summary: Replica list in the metadata cache on the broker may have
different order from zookeeper
Jiangjie Qin created KAFKA-5329:
---
Summary: Metadata cache on the broker may have replica list may
have different order from zookeeper
Key: KAFKA-5329
URL: https://issues.apache.org/jira/browse/KAFKA-5329
[
https://issues.apache.org/jira/browse/KAFKA-5211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023641#comment-16023641
]
Jiangjie Qin commented on KAFKA-5211:
-
[~enothereska] I think a KIP is only required
[
https://issues.apache.org/jira/browse/KAFKA-4340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023619#comment-16023619
]
Jiangjie Qin commented on KAFKA-4340:
-
[~edenhill] I think one of the well established guarantee
[
https://issues.apache.org/jira/browse/KAFKA-5211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-5211:
Status: Patch Available (was: In Progress)
> KafkaConsumer should not skip a corrupted rec
[
https://issues.apache.org/jira/browse/KAFKA-3995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-3995:
Resolution: Fixed
Status: Resolved (was: Patch Available)
> Split the ProducerBa
[
https://issues.apache.org/jira/browse/KAFKA-3995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-3995:
Fix Version/s: 0.11.0.0
> Split the ProducerBatch and resend when received RecordTooLargeExcept
[
https://issues.apache.org/jira/browse/KAFKA-5211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-5211 started by Jiangjie Qin.
---
> KafkaConsumer should not skip a corrupted record after throwing an except
[
https://issues.apache.org/jira/browse/KAFKA-3995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008634#comment-16008634
]
Jiangjie Qin commented on KAFKA-3995:
-
[~ijuma] done.
> Split the ProducerBatch and resend w
[
https://issues.apache.org/jira/browse/KAFKA-5211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-5211:
Fix Version/s: 0.11.0.0
> KafkaConsumer should not skip a corrupted record after throw
[
https://issues.apache.org/jira/browse/KAFKA-3995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-3995:
Summary: Split the ProducerBatch and resend when received
RecordTooLargeException (was: Add a new
Jiangjie Qin created KAFKA-5211:
---
Summary: KafkaConsumer should not skip a corrupted record after
throwing an exception.
Key: KAFKA-5211
URL: https://issues.apache.org/jira/browse/KAFKA-5211
Project
[
https://issues.apache.org/jira/browse/KAFKA-3554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16001780#comment-16001780
]
Jiangjie Qin commented on KAFKA-3554:
-
[~airbots] I lose track of this ticket... It was not checked
[
https://issues.apache.org/jira/browse/KAFKA-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15971892#comment-15971892
]
Jiangjie Qin commented on KAFKA-5075:
-
[~hachikuji] [~gwenshap] I've cherry-picked the patch to 0.10.2
[
https://issues.apache.org/jira/browse/KAFKA-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15971639#comment-15971639
]
Jiangjie Qin commented on KAFKA-5075:
-
[~hachikuji] I also think it is worth fixing. [~gwenshap] I'll
[
https://issues.apache.org/jira/browse/KAFKA-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15970771#comment-15970771
]
Jiangjie Qin commented on KAFKA-5075:
-
[~gwenshap] The patch has been checked in. Thanks
[
https://issues.apache.org/jira/browse/KAFKA-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15969730#comment-15969730
]
Jiangjie Qin commented on KAFKA-5075:
-
[~lindong] is currently working on the patch. Hopefully we can
[
https://issues.apache.org/jira/browse/KAFKA-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15969699#comment-15969699
]
Jiangjie Qin commented on KAFKA-5075:
-
[~gwenshap] I was actually about to reply on the 0.10.2.1-RC1
[
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
[
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
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
[
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 tr
[
https://issues.apache.org/jira/browse/KAFKA-4401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15961463#comment-15961463
]
Jiangjie Qin commented on KAFKA-4401:
-
Sure, I just linked KAFKA-5041 to this ticket so we can see
[
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 dur
[
https://issues.apache.org/jira/browse/KAFKA-4907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15927460#comment-15927460
]
Jiangjie Qin commented on KAFKA-4907:
-
I see. Yeah, the default behavior probably should just
[
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 timest
[
https://issues.apache.org/jira/browse/KAFKA-4907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15927438#comment-15927438
]
Jiangjie Qin commented on KAFKA-4907:
-
[~ijuma] Hmm, if {{cleanup.policy}} is NOT set to {{delete
[
https://issues.apache.org/jira/browse/KAFKA-4907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15927392#comment-15927392
]
Jiangjie Qin commented on KAFKA-4907:
-
[~junrao] Thanks for the explanation. Yes, that does sound
[
https://issues.apache.org/jira/browse/KAFKA-4907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15927231#comment-15927231
]
Jiangjie Qin commented on KAFKA-4907:
-
[~junrao] Are you referring to the log cleaner? The log cleaner
[
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
[
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
[
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
[
https://issues.apache.org/jira/browse/KAFKA-4877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904148#comment-15904148
]
Jiangjie Qin commented on KAFKA-4877:
-
[~hachikuji] The original idea was that the producer should
[
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
[
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
[
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
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
[
https://issues.apache.org/jira/browse/KAFKA-3436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15884419#comment-15884419
]
Jiangjie Qin commented on KAFKA-3436:
-
Sorry you are right. I was under the impression that patch
[
https://issues.apache.org/jira/browse/KAFKA-3436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15884390#comment-15884390
]
Jiangjie Qin commented on KAFKA-3436:
-
[~onurkaraman] is currently working on rewrite controller
[
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 produ
[
https://issues.apache.org/jira/browse/KAFKA-4757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin resolved KAFKA-4757.
-
Resolution: Fixed
> Improve NetworkClient trace logging of request deta
[
https://issues.apache.org/jira/browse/KAFKA-4757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-4757:
Affects Version/s: 0.10.2.0
> Improve NetworkClient trace logging of request deta
[
https://issues.apache.org/jira/browse/KAFKA-4757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-4757:
Fix Version/s: 0.10.3.0
> Improve NetworkClient trace logging of request deta
[
https://issues.apache.org/jira/browse/KAFKA-4340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-4340:
Resolution: Fixed
Status: Resolved (was: Patch Available)
> Change the default va
[
https://issues.apache.org/jira/browse/KAFKA-4340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15868777#comment-15868777
]
Jiangjie Qin edited comment on KAFKA-4340 at 2/15/17 11:05 PM:
---
[~junrao
[
https://issues.apache.org/jira/browse/KAFKA-4340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15868777#comment-15868777
]
Jiangjie Qin commented on KAFKA-4340:
-
[~junrao] [~ijuma] [~cmccabe] I created
https://github.com
[
https://issues.apache.org/jira/browse/KAFKA-4735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin resolved KAFKA-4735.
-
Resolution: Fixed
> Fix deadlock issue during MM shutd
[
https://issues.apache.org/jira/browse/KAFKA-4735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-4735:
Affects Version/s: 0.10.2.0
Fix Version/s: 0.10.3.0
> Fix deadlock issue during MM shutd
[
https://issues.apache.org/jira/browse/KAFKA-4401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15825006#comment-15825006
]
Jiangjie Qin commented on KAFKA-4401:
-
[~ewencp] I think it is a good suggestion. Technically speaking
[
https://issues.apache.org/jira/browse/KAFKA-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15823583#comment-15823583
]
Jiangjie Qin commented on KAFKA-3190:
-
[~ewencp] This remains an issue and confuses some
[
https://issues.apache.org/jira/browse/KAFKA-4381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15805168#comment-15805168
]
Jiangjie Qin commented on KAFKA-4381:
-
[~ijuma] Thanks for the reminder :)
I'll submit patch
[
https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15805165#comment-15805165
]
Jiangjie Qin commented on KAFKA-4497:
-
[~michael.andre.pearce] Thanks for the update. Glad to know
[
https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15800696#comment-15800696
]
Jiangjie Qin commented on KAFKA-4497:
-
[~michael.andre.pearce] Thanks for helping test this again.
I
[
https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15800498#comment-15800498
]
Jiangjie Qin commented on KAFKA-4497:
-
[~michael.andre.pearce] Sorry for the late response, just got
[
https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15786213#comment-15786213
]
Jiangjie Qin commented on KAFKA-4497:
-
[~sandieg] I cannot think of a good workaround on this without
[
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
[
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
[
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
[
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
[
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
[
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
[
https://issues.apache.org/jira/browse/KAFKA-4529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15744529#comment-15744529
]
Jiangjie Qin commented on KAFKA-4529:
-
Sure, I'll submit a patch.
> tombstone may be removed earl
[
https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15743650#comment-15743650
]
Jiangjie Qin edited comment on KAFKA-4497 at 12/13/16 12:40 AM:
The bit
[
https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15743650#comment-15743650
]
Jiangjie Qin edited comment on KAFKA-4497 at 12/13/16 12:38 AM
[
https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15743650#comment-15743650
]
Jiangjie Qin commented on KAFKA-4497:
-
The negative bit is the MSB which is 1 in 0X. The entry
[
https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15743122#comment-15743122
]
Jiangjie Qin commented on KAFKA-4497:
-
[~junrao] I think 0x is actually -1, right? In the time
[
https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15739035#comment-15739035
]
Jiangjie Qin commented on KAFKA-4497:
-
To be more clear, this part of the code has been changed
[
https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15739018#comment-15739018
]
Jiangjie Qin commented on KAFKA-4497:
-
I looked at the log cleaner code in 0.10.1. There is a bug
[
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
[
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
[
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
1 - 100 of 1443 matches
Mail list logo