Re: Review Request 26755: Patch for KAFKA-1706

--- Thanks, Jiangjie Qin

Re: Review Request 26755: Patch for KAFKA-1706

utils/ByteBoundedBlockingQueue.scala PRE-CREATION Diff: https://reviews.apache.org/r/26755/diff/ Testing --- Thanks, Jiangjie Qin

Re: Review Request 26373: Patch for KAFKA-1647

che.org/r/26373/diff/ Testing --- Thanks, Jiangjie Qin

Re: Review Request 26373: Patch for KAFKA-1647

/ Testing (updated) --- Followed Joel's testing step. I was able to reproduce the problem without the patch and the WARN message goes away after applied the patch. Thanks, Jiangjie Qin

Re: Review Request 26755: Patch for KAFKA-1706

main/scala/kafka/utils/ByteBoundedBlockingQueue.scala PRE-CREATION Diff: https://reviews.apache.org/r/26755/diff/ Testing --- Thanks, Jiangjie Qin

Re: Review Request 26755: Patch for KAFKA-1706

Testing --- Thanks, Jiangjie Qin

Re: Review Request 26373: Patch for KAFKA-1647

/diff/ Testing --- Followed Joel's testing step. I was able to reproduce the problem without the patch and the WARN message goes away after applied the patch. Thanks, Jiangjie Qin

Re: Review Request 26373: Patch for KAFKA-1647

://reviews.apache.org/r/26373/diff/ Testing --- Followed Joel's testing step. I was able to reproduce the problem without the patch and the WARN message goes away after applied the patch. Thanks, Jiangjie Qin

Re: Review Request 26373: Patch for KAFKA-1647

02fa3821271e97b24fd2ae25163933222797585d Diff: https://reviews.apache.org/r/26373/diff/ Testing --- Followed Joel's testing step. I was able to reproduce the problem without the patch and the WARN message goes away after applied the patch. Thanks, Jiangjie Qin

Re: Review Request 26373: Patch for KAFKA-1647

02fa3821271e97b24fd2ae25163933222797585d Diff: https://reviews.apache.org/r/26373/diff/ Testing --- Followed Joel's testing step. I was able to reproduce the problem without the patch and the WARN message goes away after applied the patch. Thanks, Jiangjie Qin

Review Request 27890: Patch for KAFKA-1764

/browse/KAFKA-1764 Repository: kafka Description --- fix for KAFKA-1764 Diffs - core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala fbc680fde21b02f11285a4f4b442987356abd17b Diff: https://reviews.apache.org/r/27890/diff/ Testing --- Thanks, Jiangjie Qin

Re: Review Request 25995: Patch for KAFKA-1650

- core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala fbc680fde21b02f11285a4f4b442987356abd17b core/src/main/scala/kafka/tools/MirrorMaker.scala f399105087588946987bbc84e3759935d9498b6a Diff: https://reviews.apache.org/r/25995/diff/ Testing --- Thanks, Jiangjie Qin

Re: Review Request 25995: Patch for KAKFA-1650

pdated) - core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala fbc680fde21b02f11285a4f4b442987356abd17b core/src/main/scala/kafka/tools/MirrorMaker.scala f399105087588946987bbc84e3759935d9498b6a Diff: https://reviews.apache.org/r/25995/diff/ Testing --- Thanks, Jiangjie Qin

Re: Review Request 27890: Patch for KAFKA-1764

ac491b4da2583ef7227c67f5b8bc0fd731d705c3 core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala fbc680fde21b02f11285a4f4b442987356abd17b Diff: https://reviews.apache.org/r/27890/diff/ Testing --- Thanks, Jiangjie Qin

Review Request 28025: Patch for KAFKA-345

--- Thanks, Jiangjie Qin

Re: Review Request 27890: Patch for KAFKA-1764

/consumer/ZookeeperConsumerConnector.scala fbc680fde21b02f11285a4f4b442987356abd17b core/src/test/scala/unit/kafka/consumer/ConsumerIteratorTest.scala 151ba7ccd006f851f5ff9edb2335c276ea803f16 Diff: https://reviews.apache.org/r/27890/diff/ Testing --- Thanks, Jiangjie Qin

Review Request 28040: Patch for KAFKA-1770

--- Thanks, Jiangjie Qin

Re: Review Request 28025: Patch for KAFKA-345

scala e1d87112a2a587aa3a2f5875f278b276c32f45ac Diff: https://reviews.apache.org/r/28025/diff/ Testing --- Thanks, Jiangjie Qin

Re: Review Request 28025: Patch for KAFKA-345

- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/28025/#review61556 --- On Nov. 15, 2014, 9:01 a.m., Jiangjie Qin wrote: >

Re: Review Request 28025: Patch for KAFKA-345

a/consumer/ZookeeperConsumerConnectorTest.scala e1d87112a2a587aa3a2f5875f278b276c32f45ac Diff: https://reviews.apache.org/r/28025/diff/ Testing --- Thanks, Jiangjie Qin

Re: Review Request 28025: Patch for KAFKA-345

cala/unit/kafka/consumer/ZookeeperConsumerConnectorTest.scala e1d87112a2a587aa3a2f5875f278b276c32f45ac Diff: https://reviews.apache.org/r/28025/diff/ Testing --- Thanks, Jiangjie Qin

Re: Review Request 25995: Patch for KAFKA-1650

d9498b6a Diff: https://reviews.apache.org/r/25995/diff/ Testing --- Thanks, Jiangjie Qin

Re: Review Request 25995: Patch for KAFKA-1650

t: https://reviews.apache.org/r/25995/#review61528 ------- On Nov. 18, 2014, 2:44 a.m., Jiangjie Qin wrote: > > --- > This is an automatically generated e-

Re: Review Request 28025: Patch for KAFKA-345

-- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/28025/#review61964 ------- On Nov. 18, 2014, 1:42 a.m., Jiangjie Qin wrote: > > --

Re: Review Request 28040: Patch for KAFKA-1770

https://reviews.apache.org/r/28040/diff/ Testing --- Thanks, Jiangjie Qin

Re: Review Request 25995: Patch for KAFKA-1650

/reviews.apache.org/r/25995/diff/ Testing --- Thanks, Jiangjie Qin

Re: Review Request 25995: Patch for KAFKA-1650

teBoundedBlockingQueue.scala 6a85d7e494f6c88798133a17f6180b61029dff58 core/src/test/scala/unit/kafka/consumer/ZookeeperConsumerConnectorTest.scala 8c4687b2c96fddab7c8454a5a8011c3bab0897a0 Diff: https://reviews.apache.org/r/25995/diff/ Testing --- Thanks, Jiangjie Qin

Re: Review Request 25995: Patch for KAFKA-1650

umer/ZookeeperConsumerConnectorTest.scala 8c4687b2c96fddab7c8454a5a8011c3bab0897a0 Diff: https://reviews.apache.org/r/25995/diff/ Testing --- Thanks, Jiangjie Qin

Re: Review Request 25995: Patch for KAFKA-1650

6180b61029dff58 core/src/test/scala/unit/kafka/consumer/ZookeeperConsumerConnectorTest.scala 8c4687b2c96fddab7c8454a5a8011c3bab0897a0 Diff: https://reviews.apache.org/r/25995/diff/ Testing --- Thanks, Jiangjie Qin

Re: Review Request 25995: Patch for KAFKA-1650

ducer.send() called, increment numMessageUnacked. > > 6. data duplicate happens when the rebalance finished. > > > > I think on line 599 we should use "while" instead of "if", but this > > alone does not fix this. > > Jiangjie Qin wrote: &

Re: Review Request 25995: Patch for KAFKA-1650

ot;Customized consumer rebalance listener should extends MirrorMakerConsumerRebalanceListener and take datachannel as argument." - Jiangjie ------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/2599

Re: [DISCUSSION] adding the serializer api back to the new java producer

I'm just thinking instead of binding serialization with producer, another option is to bind serializer/deserializer with ProducerRecord/ConsumerRecord (please see the detail proposal below.) The arguments for this option is: A. A single producer could send different message type

Re: Review Request 25995: Patch for KAFKA-1650

afka/utils/ByteBoundedBlockingQueue.scala 6a85d7e494f6c88798133a17f6180b61029dff58 core/src/test/scala/unit/kafka/consumer/ZookeeperConsumerConnectorTest.scala 8c4687b2c96fddab7c8454a5a8011c3bab0897a0 Diff: https://reviews.apache.org/r/25995/diff/ Testing --- Thanks, Jiangjie Qin

Re: Build failed in Jenkins: Kafka-trunk #351

I reran locally all the tests as well as the failed tests, and all the tests passed. It seems to be a transient failure. ‹Jiangjie (Becket) Qin On 12/5/14, 4:14 PM, "Apache Jenkins Server" wrote: >See > >Changes: > >[guwang] KAFKA-1650; av

Re: Review Request 25995: Patch for KAFKA-1650

8c4687b2c96fddab7c8454a5a8011c3bab0897a0 Diff: https://reviews.apache.org/r/25995/diff/ Testing --- Thanks, Jiangjie Qin

Re: Review Request 25995: Patch for KAFKA-1650

; 0 then wait] is atomic to notify, and 2.[numMessageUnacked = 0] happens before notify notify should not be missed. - Jiangjie --- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/25995/#review64152 --

Re: Review Request 25995: Patch for KAFKA-1650

here is partitioning key? > > > > It would be useful to add some comments to describe why a two-level > > offset map is needed. > > Jiangjie Qin wrote: > The iterator only iterates over the key that exits in the map, i.e. > offset exists. > >

Re: Review Request 25995: Patch for KAFKA-1650

here is partitioning key? > > > > It would be useful to add some comments to describe why a two-level > > offset map is needed. > > Jiangjie Qin wrote: > The iterator only iterates over the key that exits in the map, i.e. > offset exists. > >

Re: Review Request 25995: Patch for KAFKA-1650

e2154ba87b388af core/src/main/scala/kafka/tools/MirrorMaker.scala b06ff6000183b257005b5ac3ccc7ba8976f1ab8d Diff: https://reviews.apache.org/r/25995/diff/ Testing --- Thanks, Jiangjie Qin

Re: Review Request 25995: Patch for KAFKA-1650

sumer in ZookeeperConsumerConnector in rebalance listener test. So it causes later on server shutdown test failure. Really sorry for this... I could not reproduce the issue on my desktop probably because it is fast. I actually found that I could reproduce it on my laptop. - Jiangjie --- This is

Re: Review Request 25995: Patch for KAFKA-1650

Connector.scala 9baad34a9793e5067d11289ece2154ba87b388af core/src/main/scala/kafka/tools/MirrorMaker.scala 77d951d13b8d8ad00af40257fe51623cc2caa61a Diff: https://reviews.apache.org/r/25995/diff/ Testing --- Thanks, Jiangjie Qin

Re: Review Request 25995: Patch for KAFKA-1650

src/main/scala/kafka/javaapi/consumer/ZookeeperConsumerConnector.scala 9baad34a9793e5067d11289ece2154ba87b388af core/src/main/scala/kafka/tools/MirrorMaker.scala 77d951d13b8d8ad00af40257fe51623cc2caa61a core/src/main/scala/kafka/utils/Utils.scala 738c1af9ef5de16fdf5130daab69757a14c48b5c Diff: https://reviews.apache.org/r/25995/diff/ Testing --- Thanks, Jiangjie Qin

Re: Review Request 25995: Patch for KAFKA-1650

043line705> > > > > You need to also set tail.next = null (or None) tail.next = null will be handled in the previous if...else... the old tail.prev.next will become new tail.next, which will be null. - Jiangjie --- This is

Re: Review Request 25995: Patch for KAFKA-1650

d34a9793e5067d11289ece2154ba87b388af core/src/main/scala/kafka/tools/MirrorMaker.scala 53cb16c2949e0ac36a0e943564fc9fc9b4c84caa Diff: https://reviews.apache.org/r/25995/diff/ Testing --- Thanks, Jiangjie Qin

Re: Review Request 25995: Patch for KAFKA-1650

t; f(1,2) > > 2 > > > > scala> f() > > 0 Yes, it seems to be working. - Jiangjie --- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/25995/#review65477 --

Re: Review Request 25995: Patch for KAFKA-1650

or.scala 9baad34a9793e5067d11289ece2154ba87b388af core/src/main/scala/kafka/tools/MirrorMaker.scala 53cb16c2949e0ac36a0e943564fc9fc9b4c84caa Diff: https://reviews.apache.org/r/25995/diff/ Testing --- Thanks, Jiangjie Qin

Re: Review Request 25995: Patch for KAFKA-1650

c99664c core/src/main/scala/kafka/javaapi/consumer/ZookeeperConsumerConnector.scala 9baad34a9793e5067d11289ece2154ba87b388af core/src/main/scala/kafka/tools/MirrorMaker.scala 53cb16c2949e0ac36a0e943564fc9fc9b4c84caa Diff: https://reviews.apache.org/r/25995/diff/ Testing --- Thanks, Jiangjie Qin

Re: Review Request 25995: Patch for KAFKA-1650

rConsumerConnector.scala e991d2187d03241f639eeaf6769fb59c8c99664c core/src/main/scala/kafka/javaapi/consumer/ZookeeperConsumerConnector.scala 9baad34a9793e5067d11289ece2154ba87b388af core/src/main/scala/kafka/tools/MirrorMaker.scala 53cb16c2949e0ac36a0e943564fc9fc9b4c84caa Diff: https://reviews.apache.org/r/25995/diff/ Testing --- Thanks, Jiangjie Qin

Re: Review Request 25995: Patch for KAFKA-1650

> On Dec. 17, 2014, 1:17 p.m., Joel Koshy wrote: > > core/src/main/scala/kafka/tools/MirrorMaker.scala, line 489 > > <https://reviews.apache.org/r/25995/diff/13/?file=793043#file793043line489> > > > > Why not use KafkaScheduler for the offset com

Re: Review Request 25995: Patch for KAFKA-1650

b4c84caa core/src/main/scala/kafka/utils/DoublyLinkedList.scala PRE-CREATION core/src/test/scala/unit/kafka/utils/DoublyLinkedListTest.scala PRE-CREATION Diff: https://reviews.apache.org/r/25995/diff/ Testing --- Thanks, Jiangjie Qin

Re: Review Request 25995: Patch for KAFKA-1650

If someone wants zero data loss the MM should be configured with > > required acks -1 and infinite retries. > > > > Maybe I'm misunderstanding what zero data loss really means - can you > > clarify? (Especially if someone configures the producer with acks (say) one > >

Re: Review Request 25995: Patch for KAFKA-1650

verything else go right? Agreed. > On Dec. 22, 2014, 1:34 p.m., Joel Koshy wrote: > > core/src/main/scala/kafka/tools/MirrorMaker.scala, line 720 > > <https://reviews.apache.org/r/25995/diff/18/?file=797123#file797123line720> > > > > What does "node

Re: Review Request 25995: Patch for KAFKA-1650

to access the Node class if the class is nested. - Jiangjie --- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/25995/#review65874 -

Re: Review Request 25995: Patch for KAFKA-1650

la 53cb16c2949e0ac36a0e943564fc9fc9b4c84caa core/src/main/scala/kafka/utils/DoublyLinkedList.scala PRE-CREATION core/src/test/scala/unit/kafka/utils/UtilsTest.scala 066553cad290c3d3821537a964c7d713c122d9fc Diff: https://reviews.apache.org/r/25995/diff/ Testing --- Thanks, Jiangjie Qin

Re: Review Request 25995: Patch for KAFKA-1650

t: https://reviews.apache.org/r/25995/#review65981 ------- On Dec. 23, 2014, 3:04 p.m., Jiangjie Qin wrote: > > --- > This is an automatically generated e-

Re: Review Request 25995: Patch for KAFKA-1650

it argument > > for no data loss then it should do everything needed to ensure that. I'll > > proceed with checking in this as is but we should discuss this further. > > Jiangjie Qin wrote: > Or can we maybe do this: If the user did not specify acks in there own &

Re: Review Request 25995: Patch for KAFKA-1650

c/main/scala/kafka/tools/MirrorMaker.scala 53cb16c2949e0ac36a0e943564fc9fc9b4c84caa core/src/main/scala/kafka/utils/DoublyLinkedList.scala PRE-CREATION core/src/test/scala/unit/kafka/utils/UtilsTest.scala 066553cad290c3d3821537a964c7d713c122d9fc Diff: https://reviews.apache.org/r/25995/diff/ Testing --- Thanks, Jiangjie Qin

[jira] [Created] (KAFKA-6489) Fetcher.retrieveOffsetsByTimes() should add all the topics to the metadata refresh topics set.

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

[jira] [Created] (KAFKA-6492) LogSemgent.truncateTo() should always resize the index file

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

[jira] [Resolved] (KAFKA-6489) Fetcher.retrieveOffsetsByTimes() should add all the topics to the metadata refresh topics set.

[ 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

[jira] [Created] (KAFKA-6568) LogCleanerManager.doneDeleting() should check the partition state before deleting the in progress partition

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

[jira] [Created] (KAFKA-6028) Improve the quota throttle communication.

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

[jira] [Created] (KAFKA-6029) Controller should wait for the leader migration to finish before ack a ControlledShutdownRequest

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

[jira] [Created] (KAFKA-6083) The Fetcher should add the InvalidRecordException as a cause to the KafkaException when invalid record is found.

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

[jira] [Resolved] (KAFKA-6157) Fix repeated words words in JavaDoc and comments.

[ 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

[jira] [Created] (KAFKA-6264) Log cleaner thread may die on legacy segment containing messages whose offsets are too large

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

[jira] [Created] (KAFKA-6304) The controller should allow update the partition reassignment for the partitions being reassigned

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

[jira] [Created] (KAFKA-6321) ConsumerGroupCommand should use the new consumer to query the log end offsets.

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

[jira] [Resolved] (KAFKA-6029) Controller should wait for the leader migration to finish before ack a ControlledShutdownRequest

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

[jira] [Updated] (KAFKA-5453) Controller may miss requests sent to the broker when zk session timeout happens.

[ 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

[jira] [Updated] (KAFKA-5453) Controller may miss requests sent to the broker when zk session timeout happens.

[ 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

[jira] [Created] (KAFKA-5453) Controller may miss requests sent to the broker when zk session timeout happens.

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

[jira] [Updated] (KAFKA-5453) Controller may miss requests sent to the broker when zk session timeout happens.

[ 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

[jira] [Commented] (KAFKA-5453) Controller may miss requests sent to the broker when zk session timeout happens.

[ https://issues.apache.org/jira/browse/KAFKA-5453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050070#comment-16050070 ] Jiangjie Qin commented on KAFKA-5453: - I don't think so. This is a proba

[jira] [Resolved] (KAFKA-5627) Reduce classes needed for LeaderAndIsrPartitionState and MetadataPartitionState

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

[jira] [Created] (KAFKA-5681) jarAll does not build all scala versions anymore.

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

[jira] [Resolved] (KAFKA-5681) jarAll does not build all scala versions anymore.

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

[jira] [Created] (KAFKA-5782) Avoid unnecessary PID reset when expire batches.

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

[jira] [Resolved] (KAFKA-5694) Add ChangeReplicaDirRequest and DescribeReplicaDirRequest (KIP-113)

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

[jira] [Created] (KAFKA-5834) AbstractConfig.logUnused() may log confusing warning information.

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

[jira] [Assigned] (KAFKA-3554) Generate actual data with specific compression ratio and add multi-thread support in the ProducerPerformance tool.

[ https://issues.apache.org/jira/browse/KAFKA-3554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned KAFKA-3554: --- Assignee: Jiangjie Qin (was: Dong Lin) > Generate actual data with specific compress

[jira] [Updated] (KAFKA-3554) Generate actual data with specific compression ratio and add multi-thread support in the ProducerPerformance tool.

[ https://issues.apache.org/jira/browse/KAFKA-3554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-3554: Status: Patch Available (was: Open) > Generate actual data with specific compression ratio and

[jira] [Created] (KAFKA-3721) UpdateMetadataRequest V2 should be in API version 0.10.0-IV1

Jiangjie Qin created KAFKA-3721: --- Summary: UpdateMetadataRequest V2 should be in API version 0.10.0-IV1 Key: KAFKA-3721 URL: https://issues.apache.org/jira/browse/KAFKA-3721 Project: Kafka

[jira] [Commented] (KAFKA-3721) UpdateMetadataRequest V2 should be in API version 0.10.0-IV1

[ https://issues.apache.org/jira/browse/KAFKA-3721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287999#comment-15287999 ] Jiangjie Qin commented on KAFKA-3721: - Hi Gwen, currently "0.10.0" is a

[jira] [Commented] (KAFKA-3721) UpdateMetadataRequest V2 should be in API version 0.10.0-IV1

[ https://issues.apache.org/jira/browse/KAFKA-3721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15288035#comment-15288035 ] Jiangjie Qin commented on KAFKA-3721: - I am fine either way. My understanding of

[jira] [Commented] (KAFKA-3721) UpdateMetadataRequest V2 should be in API version 0.10.0-IV1

[ https://issues.apache.org/jira/browse/KAFKA-3721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15288045#comment-15288045 ] Jiangjie Qin commented on KAFKA-3721: - [~gwenshap] [~ijuma] I just submitted PR.

[jira] [Updated] (KAFKA-3721) UpdateMetadataRequest V2 should be in API version 0.10.0-IV1

[ https://issues.apache.org/jira/browse/KAFKA-3721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-3721: Status: Patch Available (was: Open) > UpdateMetadataRequest V2 should be in API version 0.10.0-

[jira] [Commented] (KAFKA-2431) Test SSL/TLS impact on performance

[ https://issues.apache.org/jira/browse/KAFKA-2431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15378759#comment-15378759 ] Jiangjie Qin commented on KAFKA-2431: - [~benstopford] It seems I am not abl

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

Jiangjie Qin created KAFKA-3994: --- Summary: Deadlock between consumer heartbeat expiration and offset commit. Key: KAFKA-3994 URL: https://issues.apache.org/jira/browse/KAFKA-3994 Project: Kafka

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

Jiangjie Qin created KAFKA-3995: --- Summary: Add a new configuration "enable.comrpession.ratio.estimation" to the producer config Key: KAFKA-3995 URL: https://issues.apache.org/jira/browse/

[jira] [Updated] (KAFKA-3995) Add a new configuration "enable.comrpession.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: Description: We recently see a few cases where RecordTooLargeException is thrown because 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=15395000#comment-15395000 ] Jiangjie Qin commented on KAFKA-3994: - [~hachikuji] This is on the trunk. I will

[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=15395001#comment-15395001 ] Jiangjie Qin commented on KAFKA-3994: - [~ijuma] ^^ > Deadlock between c

[jira] [Created] (KAFKA-4005) Add per topic compression ratio in broker and consumer.

Jiangjie Qin created KAFKA-4005: --- Summary: Add per topic compression ratio in broker and consumer. Key: KAFKA-4005 URL: https://issues.apache.org/jira/browse/KAFKA-4005 Project: Kafka Issue

[jira] [Assigned] (KAFKA-4005) Add per topic compression ratio in broker and consumer.

[ https://issues.apache.org/jira/browse/KAFKA-4005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned KAFKA-4005: --- Assignee: Jiangjie Qin > Add per topic compression ratio in broker and consu

[jira] [Updated] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1660: Attachment: KAFKA-1660_2015-03-27_16:35:42.patch > Ability to call close() with a timeout on

[jira] [Commented] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

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

[jira] [Commented] (KAFKA-2029) Improving controlled shutdown for rolling updates

[ https://issues.apache.org/jira/browse/KAFKA-2029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14386002#comment-14386002 ] Jiangjie Qin commented on KAFKA-2029: - [~dmitrybugaychenko] I was trying to apply

[jira] [Updated] (KAFKA-1848) Checking shutdown during each iteration of ZookeeperConsumerConnector

[ https://issues.apache.org/jira/browse/KAFKA-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1848: Fix Version/s: (was: 0.9.0) 0.8.3 > Checking shutdown during each iterat

[jira] [Commented] (KAFKA-1716) hang during shutdown of ZookeeperConsumerConnector

[ https://issues.apache.org/jira/browse/KAFKA-1716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14386019#comment-14386019 ] Jiangjie Qin commented on KAFKA-1716: - [~dchu] Do you mean that the fetchers

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