[
https://issues.apache.org/jira/browse/KAFKA-7441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7441:
Fix Version/s: 2.1.0
> Allow LogCleanerManager.resumeCleaning() to be used concurrently
>
[
https://issues.apache.org/jira/browse/KAFKA-7441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7441:
Reporter: xiongqi wu (was: Dong Lin)
> Allow LogCleanerManager.resumeCleaning() to be used concurrently
>
Dong Lin created KAFKA-7441:
---
Summary: Allow LogCleanerManager.resumeCleaning() to be used
concurrently
Key: KAFKA-7441
URL: https://issues.apache.org/jira/browse/KAFKA-7441
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-3190:
Fix Version/s: (was: 2.1.0)
2.2.0
> KafkaProducer should not invoke callback in
[
https://issues.apache.org/jira/browse/KAFKA-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16627813#comment-16627813
]
Dong Lin commented on KAFKA-3190:
-
Since there has been no activity on the PR for several months, moving
[
https://issues.apache.org/jira/browse/KAFKA-5066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-5066:
Fix Version/s: 2.1.0
> KafkaMetricsConfig properties and description notably missing from
> documentation
[
https://issues.apache.org/jira/browse/KAFKA-7332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621050#comment-16621050
]
Dong Lin commented on KAFKA-7332:
-
[~wushujames] The problem described in KAFKA-4808 says that user today
[
https://issues.apache.org/jira/browse/KAFKA-7332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned KAFKA-7332:
---
Assignee: Manikumar
> Improve error message when trying to produce message without key for
>
[
https://issues.apache.org/jira/browse/KAFKA-7332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-7332.
-
Resolution: Fixed
> Improve error message when trying to produce message without key for
> compacted
[
https://issues.apache.org/jira/browse/KAFKA-7332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7332:
Fix Version/s: 2.1.0
> Improve error message when trying to produce message without key for
> compacted
[
https://issues.apache.org/jira/browse/KAFKA-7322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7322:
Fix Version/s: 2.1.0
> Fix race condition between log cleaner thread and log retention thread when
>
[
https://issues.apache.org/jira/browse/KAFKA-7322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-7322.
-
Resolution: Fixed
> Fix race condition between log cleaner thread and log retention thread when
> topic
[
https://issues.apache.org/jira/browse/KAFKA-7322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7322:
Summary: Fix race condition between compaction thread and retention thread
when topic cleanup policy is
[
https://issues.apache.org/jira/browse/KAFKA-7322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7322:
Summary: Fix race condition between log cleaner thread and log retention
thread when topic cleanup policy
[
https://issues.apache.org/jira/browse/KAFKA-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-5690.
-
Resolution: Fixed
> kafka-acls command should be able to list per principal
>
[
https://issues.apache.org/jira/browse/KAFKA-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reopened KAFKA-5690:
-
> kafka-acls command should be able to list per principal
>
[
https://issues.apache.org/jira/browse/KAFKA-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-5690:
Fix Version/s: 2.1.0
> kafka-acls command should be able to list per principal
>
[
https://issues.apache.org/jira/browse/KAFKA-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-5690.
-
Resolution: Fixed
> kafka-acls command should be able to list per principal
>
[
https://issues.apache.org/jira/browse/KAFKA-7096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7096:
Fix Version/s: 2.1.0
> Consumer should drop the data for unassigned topic partitions
>
[
https://issues.apache.org/jira/browse/KAFKA-7383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7383:
Fix Version/s: 2.1.0
> Verify leader epoch in produce requests (KIP-359)
>
[
https://issues.apache.org/jira/browse/KAFKA-3514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-3514:
Fix Version/s: 2.1.0
> Stream timestamp computation needs some further thoughts
>
[
https://issues.apache.org/jira/browse/KAFKA-4587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-4587:
Fix Version/s: 2.1.0
> Rethink Unification of Caching with Dedupping
>
[
https://issues.apache.org/jira/browse/KAFKA-6556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-6556:
Fix Version/s: 2.1.0
> allow to attach callbacks in kafka streams, to be triggered when a window is
>
[
https://issues.apache.org/jira/browse/KAFKA-6443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-6443:
Fix Version/s: 2.1.0
> KTable involved in multiple joins could result in duplicate results
>
[
https://issues.apache.org/jira/browse/KAFKA-4690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-4690:
Fix Version/s: 2.1.0
> IllegalStateException using DeleteTopicsRequest when delete.topic.enable=false
>
[
https://issues.apache.org/jira/browse/KAFKA-6880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-6880:
Fix Version/s: 2.1.0
> Zombie replicas must be fenced
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-6774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-6774:
Fix Version/s: 2.1.0
> Improve default groupId behavior in consumer
>
[
https://issues.apache.org/jira/browse/KAFKA-4932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-4932:
Fix Version/s: 2.1.0
> Add UUID Serde
> --
>
> Key: KAFKA-4932
>
[
https://issues.apache.org/jira/browse/KAFKA-6049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-6049:
Fix Version/s: 2.1.0
> Kafka Streams: Add Cogroup in the DSL
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-7333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-7333.
-
Resolution: Fixed
> Protocol changes for KIP-320
>
>
> Key:
[
https://issues.apache.org/jira/browse/KAFKA-7333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7333:
Fix Version/s: 2.1.0
> Protocol changes for KIP-320
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-6082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-6082.
-
Resolution: Fixed
> consider fencing zookeeper updates with controller epoch zkVersion
>
[
https://issues.apache.org/jira/browse/KAFKA-7211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7211:
Fix Version/s: 2.1.0
> MM should handle timeouts in commitSync
> ---
>
[
https://issues.apache.org/jira/browse/KAFKA-7211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-7211.
-
Resolution: Fixed
> MM should handle timeouts in commitSync
> ---
>
[
https://issues.apache.org/jira/browse/KAFKA-7278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16598948#comment-16598948
]
Dong Lin commented on KAFKA-7278:
-
[~niob] The stacktrace in that Jira seems similar to the issue fixed
[
https://issues.apache.org/jira/browse/KAFKA-7295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7295:
Comment: was deleted
(was: The issue is mitigated in
https://issues.apache.org/jira/browse/KAFKA-7354)
>
[
https://issues.apache.org/jira/browse/KAFKA-7295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reopened KAFKA-7295:
-
> Fix RequestHandlerAvgIdlePercent metric calculation
> ---
[
https://issues.apache.org/jira/browse/KAFKA-7354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7354:
Fix Version/s: 2.1.0
2.0.1
1.1.2
> Fix IdlePercent and
[
https://issues.apache.org/jira/browse/KAFKA-7295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-7295.
-
Resolution: Fixed
The issue is mitigated in https://issues.apache.org/jira/browse/KAFKA-7354
> Fix
[
https://issues.apache.org/jira/browse/KAFKA-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590545#comment-16590545
]
Dong Lin commented on KAFKA-7040:
-
[~luwang] It looks like we need to fix this in Kafka to further reduce
[
https://issues.apache.org/jira/browse/KAFKA-7128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16589533#comment-16589533
]
Dong Lin commented on KAFKA-7128:
-
[~apovzner] Yes you are right. Previously I stopped at the first issue
[
https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16587596#comment-16587596
]
Dong Lin commented on KAFKA-6188:
-
[~TeilaRei] I think the discussion for the fix is in
[
https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-6188.
-
Resolution: Fixed
Likely fixed in https://issues.apache.org/jira/browse/KAFKA-7278.
> Broker fails with
[
https://issues.apache.org/jira/browse/KAFKA-7278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7278:
Fix Version/s: 2.1.0
1.1.2
> replaceSegments() should not call asyncDeleteSegment() for
[
https://issues.apache.org/jira/browse/KAFKA-7313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7313:
Description:
This patch fixes two issues:
1) Currently if a broker received StopReplicaRequest with
[
https://issues.apache.org/jira/browse/KAFKA-7313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7313:
Description:
This patch fixes two issues:
1) Currently if a broker received StopReplicaRequest with
[
https://issues.apache.org/jira/browse/KAFKA-7313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7313:
Summary: KAFKA-7313; StopReplicaRequest should attempt to remove future
replica for the partition only if
[
https://issues.apache.org/jira/browse/KAFKA-7313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7313:
Description:
Currently if a broker received StopReplicaRequest with delete=true for the same
offline
[
https://issues.apache.org/jira/browse/KAFKA-7313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7313:
Summary: StopReplicaRequest should not remove partition from
ReplicaManager.allPartitions if the replica
[
https://issues.apache.org/jira/browse/KAFKA-7313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned KAFKA-7313:
---
Assignee: Dong Lin
> StopReplicaRequest should not remove partition from
>
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
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-7295:
---
Summary: Fix RequestHandlerAvgIdlePercent metric calculation
Key: KAFKA-7295
URL: https://issues.apache.org/jira/browse/KAFKA-7295
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-7278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577707#comment-16577707
]
Dong Lin commented on KAFKA-7278:
-
Yes `segment.changeFileSuffixes("", Log.DeletedFileSuffix)` is
[
https://issues.apache.org/jira/browse/KAFKA-7278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577706#comment-16577706
]
Dong Lin commented on KAFKA-7278:
-
[~ijuma] The exception is probably thrown from
[
https://issues.apache.org/jira/browse/KAFKA-7278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577335#comment-16577335
]
Dong Lin edited comment on KAFKA-7278 at 8/11/18 9:54 PM:
--
[~ijuma] Yeah the
[
https://issues.apache.org/jira/browse/KAFKA-7278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577335#comment-16577335
]
Dong Lin commented on KAFKA-7278:
-
[~ijuma] Yeah the latest code in trunk seems to have this issue. The
[
https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned KAFKA-6188:
---
Assignee: Dong Lin
> Broker fails with FATAL Shutdown - log dirs have failed
>
[
https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577252#comment-16577252
]
Dong Lin commented on KAFKA-6188:
-
[~manme...@gmail.com] It seems rare to explicitly document what we
[
https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577251#comment-16577251
]
Dong Lin commented on KAFKA-6188:
-
[~ijuma] [~manme...@gmail.com] [~TeilaRei] I found that problem that
[
https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577251#comment-16577251
]
Dong Lin edited comment on KAFKA-6188 at 8/11/18 5:27 PM:
--
[~ijuma]
[
https://issues.apache.org/jira/browse/KAFKA-7278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7278:
Description:
Currently Log.replaceSegments() will call `asyncDeleteSegment(...)` for every
segment listed
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-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577240#comment-16577240
]
Dong Lin commented on KAFKA-6188:
-
[~xmar] The log you provided does not seem to contain any IOException
[
https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577239#comment-16577239
]
Dong Lin commented on KAFKA-6188:
-
[~manme...@gmail.com] Thanks for your detailed information. Sorry for
[
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 client
>
[
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-5928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned KAFKA-5928:
---
Assignee: Genmao Yu
> Avoid redundant requests to zookeeper when reassign topic partition
>
[
https://issues.apache.org/jira/browse/KAFKA-5928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-5928:
Fix Version/s: 2.1.0
> Avoid redundant requests to zookeeper when reassign topic partition
>
[
https://issues.apache.org/jira/browse/KAFKA-6648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-6648:
Fix Version/s: 2.0.1
> Fetcher.getTopicMetadata() should return all partitions for each requested
> topic
[
https://issues.apache.org/jira/browse/KAFKA-6648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-6648:
Summary: Fetcher.getTopicMetadata() should return all partitions for each
requested topic (was:
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:
[
https://issues.apache.org/jira/browse/KAFKA-7235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7235:
Description:
Currently a broker can process controller requests that are sent before the
broker is
[
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
> joined
[
https://issues.apache.org/jira/browse/KAFKA-7180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7180:
Fix Version/s: 2.1.0
> In testHWCheckpointWithFailuresSingleLogSegment, wait until server1 has
> joined
[
https://issues.apache.org/jira/browse/KAFKA-7180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7180:
Fix Version/s: 2.0.0
> In testHWCheckpointWithFailuresSingleLogSegment, wait until server1 has
> joined
[
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 created
>
[
https://issues.apache.org/jira/browse/KAFKA-7126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7126:
Summary: Reduce number of rebalance for large consumer groups after a topic
is created (was: Reduce
[
https://issues.apache.org/jira/browse/KAFKA-7126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7126:
Fix Version/s: 2.1.0
2.0.0
> Reduce number of rebalance period for large consumer
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16556289#comment-16556289
]
Dong Lin commented on KAFKA-7190:
-
Thanks you [~mjsax] [~guozhang] for the discussion.
> Under low
[
https://issues.apache.org/jira/browse/KAFKA-7128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16556277#comment-16556277
]
Dong Lin commented on KAFKA-7128:
-
BTW, if we want to make sure there is no message loss, it may be
[
https://issues.apache.org/jira/browse/KAFKA-7128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16556274#comment-16556274
]
Dong Lin commented on KAFKA-7128:
-
Thanks for the explanation [~hachikuji].
I slightly modified the
[
https://issues.apache.org/jira/browse/KAFKA-7128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7128:
Description:
Some model checking exposed a weakness in the ISR expansion logic. We know that
the high
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16556053#comment-16556053
]
Dong Lin edited comment on KAFKA-7190 at 7/25/18 5:53 PM:
--
[~mjsax] I guess one
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16556053#comment-16556053
]
Dong Lin commented on KAFKA-7190:
-
[~mjsax] I guess one question is, if LSO is defined for a
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16556053#comment-16556053
]
Dong Lin edited comment on KAFKA-7190 at 7/25/18 5:52 PM:
--
[~mjsax] I guess one
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16556011#comment-16556011
]
Dong Lin commented on KAFKA-7190:
-
[~guozhang] Certainly, I am happy to make the modification after we
[
https://issues.apache.org/jira/browse/KAFKA-7196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7196:
Fix Version/s: 2.1.0
> Remove heartbeat delayed operation for those removed consumers at the end of
>
[
https://issues.apache.org/jira/browse/KAFKA-7196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned KAFKA-7196:
---
Assignee: Lincong Li
> Remove heartbeat delayed operation for those removed consumers at the end of
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-7152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552112#comment-16552112
]
Dong Lin commented on KAFKA-7152:
-
I realized one more point. In the common case, if replica fetcher
[
https://issues.apache.org/jira/browse/KAFKA-7152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552105#comment-16552105
]
Dong Lin edited comment on KAFKA-7152 at 7/22/18 6:06 PM:
--
Thanks for the
[
https://issues.apache.org/jira/browse/KAFKA-7152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552110#comment-16552110
]
Dong Lin commented on KAFKA-7152:
-
Hey [~junrao], I forgot to reply to the 2nd part of the point 3
[
https://issues.apache.org/jira/browse/KAFKA-7152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552105#comment-16552105
]
Dong Lin commented on KAFKA-7152:
-
Thanks for the clarification [~ijuma]. Yeah I understand immediate
[
https://issues.apache.org/jira/browse/KAFKA-7152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551868#comment-16551868
]
Dong Lin commented on KAFKA-7152:
-
Thanks for your detailed comment Jun.
Regarding the 2nd part of 1, in
[
https://issues.apache.org/jira/browse/KAFKA-7152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551851#comment-16551851
]
Dong Lin commented on KAFKA-7152:
-
[~ijuma] Kafka at LinkedIn is not using asynchronous zookeeper client
[
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's LEO
>
[
https://issues.apache.org/jira/browse/KAFKA-7177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7177:
Priority: Minor (was: Major)
> Update 2.0 documentation to reflect changed quota behaviors by KIP-219
>
[
https://issues.apache.org/jira/browse/KAFKA-7177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7177:
Fix Version/s: 2.1.0
> Update 2.0 documentation to reflect changed quota behaviors by KIP-219
>
[
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-219
>
301 - 400 of 612 matches
Mail list logo
