[
https://issues.apache.org/jira/browse/KAFKA-291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13859341#comment-13859341
]
Swapnil Ghike commented on KAFKA-291:
-
Not sure if the ConfigBuilder is going to reduce
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/16022/#review29776
---
Ship it!
Ship It!
- Swapnil Ghike
On Dec. 4, 2013, 11:42 p.m
is alive or not?
- Swapnil
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/15901/#review29588
---
On Nov. 29, 2013, 6:41 a.m., Swapnil Ghike
/kafka/server/ReplicaManager.scala
161f58134f20f9335dbd2bee6ac3f71897cbef7c
Diff: https://reviews.apache.org/r/15901/diff/
Testing
---
Builds with all scala versions; unit tests pass
Thanks,
Swapnil Ghike
[
https://issues.apache.org/jira/browse/KAFKA-1152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1152:
-
Attachment: KAFKA-1152_2013-11-28_10:19:05.patch
ReplicaManager's handling
[
https://issues.apache.org/jira/browse/KAFKA-1152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13835022#comment-13835022
]
Swapnil Ghike commented on KAFKA-1152:
--
Updated reviewboard https
/ReplicaManager.scala
161f58134f20f9335dbd2bee6ac3f71897cbef7c
Diff: https://reviews.apache.org/r/15915/diff/
Testing
---
Thanks,
Swapnil Ghike
[
https://issues.apache.org/jira/browse/KAFKA-1152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1152:
-
Attachment: KAFKA-1152.patch
ReplicaManager's handling of the leaderAndIsrRequest should
[
https://issues.apache.org/jira/browse/KAFKA-1152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13835198#comment-13835198
]
Swapnil Ghike commented on KAFKA-1152:
--
Created reviewboard https
[
https://issues.apache.org/jira/browse/KAFKA-1152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13835205#comment-13835205
]
Swapnil Ghike commented on KAFKA-1152:
--
Updated reviewboard https
[
https://issues.apache.org/jira/browse/KAFKA-1152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1152:
-
Attachment: KAFKA-1152_2013-11-28_22:40:55.patch
ReplicaManager's handling
[
https://issues.apache.org/jira/browse/KAFKA-1152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1152:
-
Attachment: (was: KAFKA-1152.patch)
ReplicaManager's handling of the leaderAndIsrRequest
Swapnil Ghike created KAFKA-1152:
Summary: ReplicaManager's handling of the leaderAndIsrRequest
should gracefully handle leader == -1
Key: KAFKA-1152
URL: https://issues.apache.org/jira/browse/KAFKA-1152
/r/15901/diff/
Testing
---
Builds
Thanks,
Swapnil Ghike
[
https://issues.apache.org/jira/browse/KAFKA-1152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1152:
-
Attachment: KAFKA-1152.patch
ReplicaManager's handling of the leaderAndIsrRequest should
[
https://issues.apache.org/jira/browse/KAFKA-1152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13834544#comment-13834544
]
Swapnil Ghike commented on KAFKA-1152:
--
Created reviewboard https
[
https://issues.apache.org/jira/browse/KAFKA-1135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13832037#comment-13832037
]
Swapnil Ghike commented on KAFKA-1135:
--
Thanks for catching this David! Jun, it seems
[
https://issues.apache.org/jira/browse/KAFKA-1135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13832040#comment-13832040
]
Swapnil Ghike commented on KAFKA-1135:
--
[~jjkoshy], does the above issue look similar
[
https://issues.apache.org/jira/browse/KAFKA-1117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13828146#comment-13828146
]
Swapnil Ghike commented on KAFKA-1117:
--
Hey Jun, after committing this patch, builds
a per cluster config instead of a per broker
config? i cant think of any downsides.
- Swapnil Ghike
On Nov. 20, 2013, 1:38 a.m., Sriram Subramanian wrote:
---
This is an automatically generated e-mail. To reply, visit:
https
/15665/#review29116
---
On Nov. 19, 2013, 3:21 a.m., Swapnil Ghike wrote:
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/15665
we only need to upgrade in once place?
Swapnil Ghike wrote:
My understanding was that the code may evolve to deal with situations
wherein we have some zookeeper paths that are on version n, and others are on
version n' and some more are on version n''. To make this explicit, I wonder
Swapnil Ghike created KAFKA-1135:
Summary: Code cleanup - use Json.encode() to write json data to zk
Key: KAFKA-1135
URL: https://issues.apache.org/jira/browse/KAFKA-1135
Project: Kafka
c9ca95f1937d0ef2e64c70e4d811a0d4f358d9db
core/src/main/scala/kafka/utils/ZkUtils.scala
856d13605b0b4bf86010571eacbacc0fb0ba7950
Diff: https://reviews.apache.org/r/15665/diff/
Testing
---
Verified
Thanks,
Swapnil Ghike
[
https://issues.apache.org/jira/browse/KAFKA-1135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13826116#comment-13826116
]
Swapnil Ghike commented on KAFKA-1135:
--
Created reviewboard https
[
https://issues.apache.org/jira/browse/KAFKA-1135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1135:
-
Attachment: KAFKA-1135.patch
Code cleanup - use Json.encode() to write json data to zk
://cwiki.apache.org/confluence/display/KAFKA/Kafka+data+structures+in+Zookeeper
Thanks,
Swapnil Ghike
[
https://issues.apache.org/jira/browse/KAFKA-1135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1135:
-
Attachment: KAFKA-1135_2013-11-18_19:17:54.patch
Code cleanup - use Json.encode() to write json
that zookeeper data looks like the structures defined in
https://cwiki.apache.org/confluence/display/KAFKA/Kafka+data+structures+in+Zookeeper
Thanks,
Swapnil Ghike
[
https://issues.apache.org/jira/browse/KAFKA-1135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13826128#comment-13826128
]
Swapnil Ghike commented on KAFKA-1135:
--
Updated reviewboard https
defined in
https://cwiki.apache.org/confluence/display/KAFKA/Kafka+data+structures+in+Zookeeper
Thanks,
Swapnil Ghike
[
https://issues.apache.org/jira/browse/KAFKA-1135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1135:
-
Attachment: KAFKA-1135_2013-11-18_19:20:58.patch
Code cleanup - use Json.encode() to write json
[
https://issues.apache.org/jira/browse/KAFKA-1135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13826133#comment-13826133
]
Swapnil Ghike commented on KAFKA-1135:
--
Updated reviewboard https
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/15201/#review28873
---
Ship it!
Ship It!
- Swapnil Ghike
On Nov. 14, 2013, 4:24 p.m
configuration change (number of partitions).
- Swapnil Ghike
On Nov. 12, 2013, 4:34 p.m., Jun Rao wrote:
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/15201
://reviews.apache.org/r/15274/#comment55256
Should we enforce that configsToBeAdded and configsToBeDeleted should not
contain the same config?
- Swapnil Ghike
On Nov. 7, 2013, 6:17 p.m., Neha Narkhede wrote:
---
This is an automatically
it as --config
config1=newVal --deleteConfig config2.
- Swapnil Ghike
On Nov. 6, 2013, 6:13 p.m., Neha Narkhede wrote:
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/15274
[
https://issues.apache.org/jira/browse/KAFKA-1121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1121:
-
Fix Version/s: 0.8.1
DumpLogSegments tool should print absolute file name to report
/browse/KAFKA-1121
Repository: kafka
Description
---
dumplogseg
Diffs
-
core/src/main/scala/kafka/tools/DumpLogSegments.scala
89b6cb1d0c3d9a1335184d0fc778246ce47738d3
Diff: https://reviews.apache.org/r/15248/diff/
Testing
---
Thanks,
Swapnil Ghike
[
https://issues.apache.org/jira/browse/KAFKA-1121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1121:
-
Attachment: KAFKA-1121.patch
DumpLogSegments tool should print absolute file name to report
://reviews.apache.org/r/15137/#comment5
probably don't need this statement.
- Swapnil Ghike
On Oct. 31, 2013, 10:28 p.m., Neha Narkhede wrote:
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/15137/#review27989
---
Ship it!
Ship It!
- Swapnil Ghike
On Oct. 31, 2013, 10:28 p.m
[
https://issues.apache.org/jira/browse/KAFKA-1100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13802635#comment-13802635
]
Swapnil Ghike commented on KAFKA-1100:
--
Hi Jason, at LinkedIn, we use wildcards
[
https://issues.apache.org/jira/browse/KAFKA-1100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13803660#comment-13803660
]
Swapnil Ghike commented on KAFKA-1100:
--
That makes sense Joel, we could also use
[
https://issues.apache.org/jira/browse/KAFKA-1093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1093:
-
Affects Version/s: 0.8
Log.getOffsetsBefore(t, …) does not return the last confirmed offset
[
https://issues.apache.org/jira/browse/KAFKA-1093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1093:
-
Description:
Let's say there are three log segments s1, s2, s3.
In Log.getoffsetsBefore(t
[
https://issues.apache.org/jira/browse/KAFKA-1093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13800013#comment-13800013
]
Swapnil Ghike commented on KAFKA-1093:
--
Created reviewboard
Log.getOffsetsBefore(t
[
https://issues.apache.org/jira/browse/KAFKA-1093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1093:
-
Attachment: KAFKA-1093.patch
Log.getOffsetsBefore(t, …) does not return the last confirmed
---
Thanks,
Swapnil Ghike
://reviews.apache.org/r/14771/diff/
Testing (updated)
---
Unit tests pass.
Thanks,
Swapnil Ghike
[
https://issues.apache.org/jira/browse/KAFKA-1093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13800018#comment-13800018
]
Swapnil Ghike commented on KAFKA-1093:
--
Created reviewboard https
/browse/KAFKA-1093
Repository: kafka
Description
---
configure reviewboard
Diffs
-
kafka-patch-review.py 2653465a30a0084cbd37fa07d00e07134ef3bd7f
Diff: https://reviews.apache.org/r/14772/diff/
Testing
---
Thanks,
Swapnil Ghike
[
https://issues.apache.org/jira/browse/KAFKA-1093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13800021#comment-13800021
]
Swapnil Ghike commented on KAFKA-1093:
--
Created reviewboard https
[
https://issues.apache.org/jira/browse/KAFKA-1093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1093:
-
Attachment: KAFKA-1093.patch
Log.getOffsetsBefore(t, …) does not return the last confirmed
[
https://issues.apache.org/jira/browse/KAFKA-1093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1093:
-
Comment: was deleted
(was: Created reviewboard https://reviews.apache.org/r/14772
[
https://issues.apache.org/jira/browse/KAFKA-1093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1093:
-
Attachment: (was: KAFKA-1093.patch)
Log.getOffsetsBefore(t, …) does not return the last
/browse/KAFKA-1094
Repository: kafka
Description
---
configure reviewboard
Diffs
-
kafka-patch-review.py 2653465a30a0084cbd37fa07d00e07134ef3bd7f
Diff: https://reviews.apache.org/r/14773/diff/
Testing
---
Thanks,
Swapnil Ghike
[
https://issues.apache.org/jira/browse/KAFKA-1094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13800023#comment-13800023
]
Swapnil Ghike commented on KAFKA-1094:
--
Created reviewboard https
[
https://issues.apache.org/jira/browse/KAFKA-1094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1094:
-
Attachment: KAFKA-1094.patch
Configure reviewboard url in kafka-patch-review tool
Swapnil Ghike created KAFKA-1094:
Summary: Configure reviewboard url in kafka-patch-review tool
Key: KAFKA-1094
URL: https://issues.apache.org/jira/browse/KAFKA-1094
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-1087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13794966#comment-13794966
]
Swapnil Ghike commented on KAFKA-1087:
--
Same patch should apply fine to trunk
[
https://issues.apache.org/jira/browse/KAFKA-1087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1087:
-
Affects Version/s: 0.8
Empty topic list causes consumer to fetch metadata of all topics
Swapnil Ghike created KAFKA-1087:
Summary: Empty topic list causes consumer to fetch metadata of all
topics
Key: KAFKA-1087
URL: https://issues.apache.org/jira/browse/KAFKA-1087
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-1087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1087:
-
Attachment: KAFKA-1087.patch
Unit tests pass.
Empty topic list causes consumer to fetch
[
https://issues.apache.org/jira/browse/KAFKA-1087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1087:
-
Description:
The ClientUtils fetches metadata for all topics if the topic set is empty
[
https://issues.apache.org/jira/browse/KAFKA-1087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1087:
-
Description:
The ClientUtils fetches metadata for all topics if the topic set is empty
https://reviews.apache.org/r/14496/#comment52036
Instead of asking the user to store the output of a dryrun into a JSON
file, should the tool compute the dryrun output and use it to perform
validation ?
- Swapnil Ghike
On Oct. 5, 2013, 6:02 p.m., Jun Rao wrote
in the ReassignPartitions tool
itself with a checkStatus mode make sense in trunk?
- Swapnil Ghike
On Oct. 4, 2013, 9:33 p.m., Jun Rao wrote:
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/14496
[
https://issues.apache.org/jira/browse/KAFKA-1030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13769884#comment-13769884
]
Swapnil Ghike commented on KAFKA-1030:
--
+1 that Guozhang, thanks for running
[
https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1003:
-
Attachment: KAFKA-1003.patch
ConsumerFetcherManager should pass clientId as metricsPrefix
[
https://issues.apache.org/jira/browse/KAFKA-1053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13768499#comment-13768499
]
Swapnil Ghike commented on KAFKA-1053:
--
After installing arg_parse and using origin
/#comment51047
Just one thing, I am not super comfortable having a password in a file in
plain text.
- Swapnil Ghike
On Sept. 16, 2013, 3:28 a.m., Neha Narkhede wrote:
---
This is an automatically generated e-mail. To reply, visit:
https
[
https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1003:
-
Attachment: (was: KAFKA-1003.patch)
ConsumerFetcherManager should pass clientId
[
https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1003:
-
Attachment: (was: KAFKA-1003.patch)
ConsumerFetcherManager should pass clientId
[
https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13768496#comment-13768496
]
Swapnil Ghike commented on KAFKA-1003:
--
Created reviewboard https
[
https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1003:
-
Attachment: (was: KAFKA-1003.patch)
ConsumerFetcherManager should pass clientId
[
https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1003:
-
Attachment: (was: KAFKA-1003.patch)
ConsumerFetcherManager should pass clientId
[
https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1003:
-
Attachment: (was: KAFKA-1003.patch)
ConsumerFetcherManager should pass clientId
[
https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1003:
-
Attachment: (was: KAFKA-1003.patch)
ConsumerFetcherManager should pass clientId
[
https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1003:
-
Attachment: KAFKA-1003.patch
ConsumerFetcherManager should pass clientId as metricsPrefix
[
https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13768495#comment-13768495
]
Swapnil Ghike commented on KAFKA-1003:
--
Created reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1003:
-
Comment: was deleted
(was: Created reviewboard https://reviews.apache.org/r/14149
[
https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1003:
-
Attachment: KAFKA-1003.patch
ConsumerFetcherManager should pass clientId as metricsPrefix
[
https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13768494#comment-13768494
]
Swapnil Ghike commented on KAFKA-1003:
--
Created reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13768756#comment-13768756
]
Swapnil Ghike commented on KAFKA-1053:
--
Saw new error on RHEL when I tried 'python
[
https://issues.apache.org/jira/browse/KAFKA-1053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13768756#comment-13768756
]
Swapnil Ghike edited comment on KAFKA-1053 at 9/16/13 9:02 PM
[
https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1003:
-
Attachment: KAFKA-1003_2013-09-16_14:13:04.patch
ConsumerFetcherManager should pass
[
https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13768768#comment-13768768
]
Swapnil Ghike commented on KAFKA-1003:
--
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-42?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-42:
---
Attachment: KAFKA-42.patch
Support rebalancing the partitions with replication
[
https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13768771#comment-13768771
]
Swapnil Ghike commented on KAFKA-1003:
--
Created reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13768770#comment-13768770
]
Swapnil Ghike commented on KAFKA-1003:
--
Created reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1003:
-
Attachment: KAFKA-1003.patch
ConsumerFetcherManager should pass clientId as metricsPrefix
[
https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1003:
-
Attachment: KAFKA-1003.patch
ConsumerFetcherManager should pass clientId as metricsPrefix
[
https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1003:
-
Attachment: (was: KAFKA-1003.patch)
ConsumerFetcherManager should pass clientId
/browse/KAFKA-1003
Repository: kafka
Description
---
test
Diffs
-
core/src/main/scala/kafka/producer/ProducerConfig.scala
7947b18aceb297f51adc0edcb1a11a447ca83e5f
Diff: https://reviews.apache.org/r/14161/diff/
Testing
---
Thanks,
Swapnil Ghike
[
https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1003:
-
Attachment: (was: KAFKA-1003.patch)
ConsumerFetcherManager should pass clientId
[
https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1003:
-
Attachment: KAFKA-1003.patch
ConsumerFetcherManager should pass clientId as metricsPrefix
[
https://issues.apache.org/jira/browse/KAFKA-42?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13768747#comment-13768747
]
Swapnil Ghike commented on KAFKA-42:
Created reviewboard
Support
[
https://issues.apache.org/jira/browse/KAFKA-42?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-42:
---
Attachment: (was: KAFKA-42.patch)
Support rebalancing the partitions with replication
[
https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1003:
-
Comment: was deleted
(was: Created reviewboard https://reviews.apache.org/r/14161
1 - 100 of 308 matches
Mail list logo
