-mail. To reply, visit:
https://reviews.apache.org/r/23569/#review48416
---
On July 16, 2014, 9:30 p.m., Dong Lin wrote:
>
> ---
> This is an automatically generated e-mail. To rep
a2117b34c2ee3554602fe068eed0c90b075958c1
Diff: https://reviews.apache.org/r/23569/diff/
Testing
---
Thanks,
Dong Lin
core/src/main/scala/kafka/common/ErrorMapping.scala
5559d26ba2b96059f719754a351fa4598ca8a70b
core/src/test/scala/unit/kafka/api/RequestResponseSerializationTest.scala
a2117b34c2ee3554602fe068eed0c90b075958c1
Diff: https://reviews.apache.org/r/23567/diff/
Testing
---
Thanks,
Dong Lin
/TransactionManager.scala PRE-CREATION
core/src/main/scala/kafka/utils/ZkUtils.scala
dcdc1ce2b02c996294e19cf480736106aaf29511
Diff: https://reviews.apache.org/r/23568/diff/
Testing
---
Thanks,
Dong Lin
---
Thanks,
Dong Lin
1, 2014, 5:49 p.m., Joel Koshy wrote:
> > core/src/main/scala/kafka/api/TransactionRequest.scala, line 1
> > <https://reviews.apache.org/r/23567/diff/4/?file=635090#file635090line1>
> >
> > Can you add these new request/responses to the reques
> Should remove the comment on "atomic" commits - that was only for the
> > consumer offsets topic.
OK!
> On July 21, 2014, 6:56 p.m., Joel Koshy wrote:
> > core/src/main/scala/kafka/server/TransactionManager.scala, line 39
> > <https://reviews.apa
/main/scala/kafka/tools/DumpLogSegments.scala
6daf87b25a48a51aafb7dbe8d0c0371e0ea7501f
Diff: https://reviews.apache.org/r/23569/diff/
Testing
---
Thanks,
Dong Lin
/RequestResponseSerializationTest.scala
a2117b34c2ee3554602fe068eed0c90b075958c1
kafka-patch-review.py dc45549f886440f1721c60aab9aa0a4af9b4cbef
Diff: https://reviews.apache.org/r/24340/diff/
Testing
---
Thanks,
Dong Lin
dcdc1ce2b02c996294e19cf480736106aaf29511
core/src/test/scala/unit/kafka/api/RequestResponseSerializationTest.scala
a2117b34c2ee3554602fe068eed0c90b075958c1
Diff: https://reviews.apache.org/r/24340/diff/
Testing
---
Thanks,
Dong Lin
/main/scala/kafka/utils/ZkUtils.scala
dcdc1ce2b02c996294e19cf480736106aaf29511
core/src/test/scala/unit/kafka/api/RequestResponseSerializationTest.scala
a2117b34c2ee3554602fe068eed0c90b075958c1
Diff: https://reviews.apache.org/r/24340/diff/
Testing
---
Thanks,
Dong Lin
/utils/ZkUtils.scala
dcdc1ce2b02c996294e19cf480736106aaf29511
core/src/test/scala/unit/kafka/api/RequestResponseSerializationTest.scala
a2117b34c2ee3554602fe068eed0c90b075958c1
Diff: https://reviews.apache.org/r/24340/diff/
Testing
---
Thanks,
Dong Lin
/TransactionManager.scala PRE-CREATION
core/src/main/scala/kafka/utils/ZkUtils.scala
dcdc1ce2b02c996294e19cf480736106aaf29511
Diff: https://reviews.apache.org/r/23568/diff/
Testing
---
Thanks,
Dong Lin
/scala/kafka/common/ErrorMapping.scala
5559d26ba2b96059f719754a351fa4598ca8a70b
core/src/test/scala/unit/kafka/api/RequestResponseSerializationTest.scala
cd16ced5465d098be7a60498326b2a98c248f343
Diff: https://reviews.apache.org/r/23567/diff/
Testing
---
Thanks,
Dong Lin
he.org/r/23568/#review49692
---
On Aug. 6, 2014, 4:25 a.m., Dong Lin wrote:
>
> ---
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r
96
-------
On Aug. 6, 2014, 4:25 a.m., Dong Lin wrote:
>
> ---
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/23568/
>
size of them. I was thinking if I sent 999 messages and then failed over,
> > and the new broker that took over has a small batch size now, even though
> > the version has incremented the new range now overlaps then right? It might
> > already been handled but just want to throw it
size of them. I was thinking if I sent 999 messages and then failed over,
> > and the new broker that took over has a small batch size now, even though
> > the version has incremented the new range now overlaps then right? It might
> > already been handled but just want to throw it
size of them. I was thinking if I sent 999 messages and then failed over,
> > and the new broker that took over has a small batch size now, even though
> > the version has incremented the new range now overlaps then right? It might
> > already been handled but just want to throw it
,
Dong Lin
core/src/main/scala/kafka/common/ErrorMapping.scala
5559d26ba2b96059f719754a351fa4598ca8a70b
core/src/test/scala/unit/kafka/api/RequestResponseSerializationTest.scala
cd16ced5465d098be7a60498326b2a98c248f343
Diff: https://reviews.apache.org/r/23567/diff/
Testing
---
Thanks,
Dong Lin
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/23567/#review50081
---
On Aug. 9, 2014, 4:21 a.m., Dong Lin wrote:
>
> -
---
Thanks,
Dong Lin
://reviews.apache.org/r/24510/diff/
Testing
---
Thanks,
Dong Lin
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/24510/#review50127
-------
On Aug. 11, 2014, 4:23 a.m., Dong Lin wrote:
>
> ---
/main/scala/kafka/common/ErrorMapping.scala
5559d26ba2b96059f719754a351fa4598ca8a70b
core/src/test/scala/unit/kafka/api/RequestResponseSerializationTest.scala
cd16ced5465d098be7a60498326b2a98c248f343
Diff: https://reviews.apache.org/r/23567/diff/
Testing
---
Thanks,
Dong Lin
ch type's role.
Please check the updated patch. Thanks!
- Dong
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/23567/#review50663
---
Diff: https://reviews.apache.org/r/23569/diff/
Testing
---
Thanks,
Dong Lin
/diff/
Testing
---
Thanks,
Dong Lin
/diff/
Testing
---
Thanks,
Dong Lin
://reviews.apache.org/r/24874/diff/
Testing
---
Thanks,
Dong Lin
7602b8d705970a5dab49ed36d117346a960701ac
Diff: https://reviews.apache.org/r/24874/diff/
Testing
---
Thanks,
Dong Lin
/tools/SimpleConsumerPerformance.scala
7602b8d705970a5dab49ed36d117346a960701ac
Diff: https://reviews.apache.org/r/24874/diff/
Testing
---
Thanks,
Dong Lin
6edd64a92ce749421b5ab60fbea5b55e2ccbfe94
Diff: https://reviews.apache.org/r/24874/diff/
Testing
---
Thanks,
Dong Lin
323fc8566d974acc4e5c7d7c2a065794f3b5df4a
core/src/main/scala/kafka/tools/SimpleConsumerPerformance.scala
7602b8d705970a5dab49ed36d117346a960701ac
Diff: https://reviews.apache.org/r/24874/diff/
Testing
---
Thanks,
Dong Lin
/kafka_system_test_utils.py
6edd64a92ce749421b5ab60fbea5b55e2ccbfe94
Diff: https://reviews.apache.org/r/24874/diff/
Testing
---
Thanks,
Dong Lin
: https://reviews.apache.org/r/24856/diff/
Testing
---
Thanks,
Dong Lin
ically generated e-mail. To reply, visit:
https://reviews.apache.org/r/24856/#review51050
-------
On Aug. 20, 2014, 4:10 a.m., Dong Lin wrote:
>
> ---
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.o
: https://reviews.apache.org/r/24856/diff/
Testing
---
Thanks,
Dong Lin
7d90fceffd4a92460c616f8bacd78057a38a3c16
Diff: https://reviews.apache.org/r/24992/diff/
Testing
---
Thanks,
Dong Lin
/requests/MetadataResponse.java
7d90fceffd4a92460c616f8bacd78057a38a3c16
Diff: https://reviews.apache.org/r/24992/diff/
Testing
---
Thanks,
Dong Lin
/kafka/common/requests/MetadataResponse.java
7d90fceffd4a92460c616f8bacd78057a38a3c16
Diff: https://reviews.apache.org/r/24992/diff/
Testing
---
Thanks,
Dong Lin
--
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/24992/#review51317
-------
On Aug. 22, 2014, 8:04 p.m., Dong Lin wrote:
>
>
----------
On Aug. 22, 2014, 8:04 p.m., Dong Lin wrote:
>
> ---
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/24992/
> ---
/requests/MetadataResponse.java
7d90fceffd4a92460c616f8bacd78057a38a3c16
Diff: https://reviews.apache.org/r/24992/diff/
Testing
---
Thanks,
Dong Lin
-------
On Aug. 22, 2014, 11:22 p.m., Dong Lin wrote:
>
> ---
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/24992/
> ---
[
https://issues.apache.org/jira/browse/KAFKA-7464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-7464.
-
Resolution: Fixed
> Fail to shutdown ReplicaManager during broker cleaned shutd
[
https://issues.apache.org/jira/browse/KAFKA-7559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-7559.
-
Resolution: Fixed
> ConnectStandaloneFileTest system tests do not p
[
https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reopened KAFKA-7481:
-
> Consider options for safer upgrade of offset commit value sch
[
https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-7481.
-
Resolution: Fixed
> Consider options for safer upgrade of offset commit value sch
[
https://issues.apache.org/jira/browse/KAFKA-7313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-7313.
-
Resolution: Fixed
> StopReplicaRequest should attempt to remove future replica for the partition
>
Dong Lin created KAFKA-7603:
---
Summary: Producer should negotiate message format version with
broker
Key: KAFKA-7603
URL: https://issues.apache.org/jira/browse/KAFKA-7603
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-6262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-6262.
-
Resolution: Duplicate
The design in this Jira has been moved to KIP-320.
> KIP-232: Detect outda
Dong Lin created KAFKA-7645:
---
Summary: Fix flaky unit test for 2.1 branch
Key: KAFKA-7645
URL: https://issues.apache.org/jira/browse/KAFKA-7645
Project: Kafka
Issue Type: Task
Reporter
Dong Lin created KAFKA-7646:
---
Summary: Flaky test
SaslOAuthBearerSslEndToEndAuthorizationTest.testNoConsumeWithDescribeAclViaSubscribe
Key: KAFKA-7646
URL: https://issues.apache.org/jira/browse/KAFKA-7646
Dong Lin created KAFKA-7647:
---
Summary: Flaky test
LogCleanerParameterizedIntegrationTest.testCleansCombinedCompactAndDeleteTopic
Key: KAFKA-7647
URL: https://issues.apache.org/jira/browse/KAFKA-7647
Dong Lin created KAFKA-7648:
---
Summary: Flaky test
DeleteTopicsRequestTest.testValidDeleteTopicRequests
Key: KAFKA-7648
URL: https://issues.apache.org/jira/browse/KAFKA-7648
Project: Kafka
Issue
Dong Lin created KAFKA-7649:
---
Summary: Flaky test
SslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl
Key: KAFKA-7649
URL: https://issues.apache.org/jira/browse/KAFKA-7649
Project: Kafka
Dong Lin created KAFKA-7651:
---
Summary: Flaky test
SaslSslAdminClientIntegrationTest.testMinimumRequestTimeouts
Key: KAFKA-7651
URL: https://issues.apache.org/jira/browse/KAFKA-7651
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-5335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-5335.
-
Resolution: Won't Do
> Controller should batch updatePartitionReassignmentData() o
[
https://issues.apache.org/jira/browse/KAFKA-3473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-3473.
-
Resolution: Fixed
> KIP-237: More Controller Health Metr
Dong Lin created KAFKA-7019:
---
Summary: Reduction the contention between metadata update and
metadata read operation
Key: KAFKA-7019
URL: https://issues.apache.org/jira/browse/KAFKA-7019
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-6946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-6946.
-
Resolution: Fixed
> Keep the session id for incremental fetch when fetch responses are thrott
Dong Lin created KAFKA-7098:
---
Summary: Improve accuracy of the log cleaner throttle rate
Key: KAFKA-7098
URL: https://issues.apache.org/jira/browse/KAFKA-7098
Project: Kafka
Issue Type
Dong Lin created KAFKA-7126:
---
Summary: Reduce number of rebalance period for large consumer
groups after a topic is created
Key: KAFKA-7126
URL: https://issues.apache.org/jira/browse/KAFKA-7126
Project
Dong Lin created KAFKA-7147:
---
Summary: ReassignPartitionsCommand should be able to connect to
broker over SSL
Key: KAFKA-7147
URL: https://issues.apache.org/jira/browse/KAFKA-7147
Project: Kafka
Dong Lin created KAFKA-7152:
---
Summary: replica should be in-sync if its LEO equals leader's LEO
Key: KAFKA-7152
URL: https://issues.apache.org/jira/browse/KAFKA-7152
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-6636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-6636.
-
Resolution: Fixed
This is no longer an issue after KAFKA-3978; Ensure high watermark is always
positive
[
https://issues.apache.org/jira/browse/KAFKA-6618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-6618.
-
Resolution: Duplicate
Duplicate of https://issues.apache.org/jira/browse/KAFKA-6082
> Prevent
[
https://issues.apache.org/jira/browse/KAFKA-5812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-5812.
-
Resolution: Won't Do
> Represent logDir with case class where absolute path is
[
https://issues.apache.org/jira/browse/KAFKA-6617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-6617.
-
Resolution: Fixed
> Improve controller performance by batching reassignment znode write operat
[
https://issues.apache.org/jira/browse/KAFKA-3145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-3145.
-
Resolution: Cannot Reproduce
> CPU Usage Spike to 100% when network connection is to error p
[
https://issues.apache.org/jira/browse/KAFKA-4820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-4820.
-
Resolution: Fixed
> ConsumerNetworkClient.send() should not require global l
[
https://issues.apache.org/jira/browse/KAFKA-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-3089.
-
Resolution: Fixed
> VerifiableProducer should do a clean shutdown in stop_n
[
https://issues.apache.org/jira/browse/KAFKA-6488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-6488.
-
Resolution: Won't Do
> Prevent log corruption in cas
[
https://issues.apache.org/jira/browse/KAFKA-7098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-7098.
-
Resolution: Fixed
> Improve accuracy of the log cleaner throttle r
[
https://issues.apache.org/jira/browse/KAFKA-7177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-7177.
-
Resolution: Fixed
> Update 2.0 documentation to reflect changed quota behaviors by KIP-
[
https://issues.apache.org/jira/browse/KAFKA-7152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-7152.
-
Resolution: Fixed
> replica should be in-sync if its LEO equals leader&#x
Dong Lin created KAFKA-7191:
---
Summary: Add sensors for NumOfflineThread, FetchRequestRate and
FetchRequestLocalTime in the follower broker
Key: KAFKA-7191
URL: https://issues.apache.org/jira/browse/KAFKA-7191
[
https://issues.apache.org/jira/browse/KAFKA-7126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-7126.
-
Resolution: Fixed
> Reduce number of rebalance for large consumer groups after a topic is crea
[
https://issues.apache.org/jira/browse/KAFKA-7180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-7180.
-
Resolution: Fixed
> In testHWCheckpointWithFailuresSingleLogSegment, wait until server1 has
>
Dong Lin created KAFKA-7235:
---
Summary: Use brokerZkNodeVersion to prevent broker from processing
outdated controller request
Key: KAFKA-7235
URL: https://issues.apache.org/jira/browse/KAFKA-7235
Project
Dong Lin created KAFKA-6488:
---
Summary: Prevent log corruption in case of OOM
Key: KAFKA-6488
URL: https://issues.apache.org/jira/browse/KAFKA-6488
Project: Kafka
Issue Type: Bug
Dong Lin created KAFKA-6571:
---
Summary: KafkaProducer.close(0) should be non-blocking
Key: KAFKA-6571
URL: https://issues.apache.org/jira/browse/KAFKA-6571
Project: Kafka
Issue Type: Bug
Dong Lin created KAFKA-6604:
---
Summary: ReplicaManager should not remove partitions on the log
dirctory from high watermark checkpoint file
Key: KAFKA-6604
URL: https://issues.apache.org/jira/browse/KAFKA-6604
Dong Lin created KAFKA-6617:
---
Summary: Improve controller performance by batching reassignment
znode write operation
Key: KAFKA-6617
URL: https://issues.apache.org/jira/browse/KAFKA-6617
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-5626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-5626.
-
Resolution: Duplicate
Fixed in https://issues.apache.org/jira/browse/KAFKA-5960
> Producer should
Dong Lin created KAFKA-6618:
---
Summary: Prevent two controllers from updating znodes concurrently
Key: KAFKA-6618
URL: https://issues.apache.org/jira/browse/KAFKA-6618
Project: Kafka
Issue Type
Dong Lin created KAFKA-6636:
---
Summary: ReplicaFetcherThread should not die if hw < 0
Key: KAFKA-6636
URL: https://issues.apache.org/jira/browse/KAFKA-6636
Project: Kafka
Issue Type: Improvem
Dong Lin created KAFKA-6638:
---
Summary: Controller should remove replica from ISR if the replica
is removed from the replica set
Key: KAFKA-6638
URL: https://issues.apache.org/jira/browse/KAFKA-6638
Project
Dong Lin created KAFKA-6640:
---
Summary: Improve efficiency of KafkaAdminClient.describeTopics()
Key: KAFKA-6640
URL: https://issues.apache.org/jira/browse/KAFKA-6640
Project: Kafka
Issue Type
Dong Lin created KAFKA-6697:
---
Summary: JBOD configured broker should not die if log directory is
invalid
Key: KAFKA-6697
URL: https://issues.apache.org/jira/browse/KAFKA-6697
Project: Kafka
Issue
Dong Lin created KAFKA-6705:
---
Summary: producer.send() should be non-blocking
Key: KAFKA-6705
URL: https://issues.apache.org/jira/browse/KAFKA-6705
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-6705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-6705.
-
Resolution: Won't Fix
> producer.send() should not block due to metadata not a
[
https://issues.apache.org/jira/browse/KAFKA-6701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-6701.
-
Resolution: Fixed
The issue appears to have been fixed in
https://issues.apache.org/jira/browse/KAFKA
[
https://issues.apache.org/jira/browse/KAFKA-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-7147.
-
Resolution: Fixed
> Allow kafka-reassign-partitions.sh and kafka-log-dirs.sh to take admin cli
Dong Lin created KAFKA-7278:
---
Summary: replaceSegments() should not call asyncDeleteSegment()
for segments which have been removed from segments list
Key: KAFKA-7278
URL: https://issues.apache.org/jira/browse/KAFKA
Dong Lin created KAFKA-7295:
---
Summary: Fix RequestHandlerAvgIdlePercent metric calculation
Key: KAFKA-7295
URL: https://issues.apache.org/jira/browse/KAFKA-7295
Project: Kafka
Issue Type
Dong Lin created KAFKA-7297:
---
Summary: Both read/write access to Log.segments should be
protected by lock
Key: KAFKA-7297
URL: https://issues.apache.org/jira/browse/KAFKA-7297
Project: Kafka
Dong Lin created KAFKA-7313:
---
Summary: StopReplicaRequest should not remove partition from
ReplicaManager.allPartitions if partition is offline
Key: KAFKA-7313
URL: https://issues.apache.org/jira/browse/KAFKA-7313
601 - 700 of 1160 matches
Mail list logo
