[
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
[
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 of the
[
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://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://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://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 of the
[
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
[
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://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
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
[
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://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
[
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
[
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://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://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
[
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
[
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
[
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 the
[
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
[
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:comment-tabpanelfocusedCommentId=13800018#comment-13800018
]
Swapnil Ghike commented on KAFKA-1093:
--
Created reviewboard
[
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://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
[
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://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.
If the
[
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.
If the
[
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 the
[
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
[
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 as
[
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 as
[
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://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 as
[
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 as
[
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 as
[
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 as
[
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 as
[
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 as
[
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/
)
[
https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13767962#comment-13767962
]
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:comment-tabpanelfocusedCommentId=13767963#comment-13767963
]
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=13767967#comment-13767967
]
Swapnil Ghike edited comment on KAFKA-1053 at 9/16/13 12:38 AM:
[
https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13767976#comment-13767976
]
Swapnil Ghike commented on KAFKA-1003:
--
Created reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1030:
-
Assignee: Guozhang Wang (was: Swapnil Ghike)
Addition of partitions requires bouncing all
[
https://issues.apache.org/jira/browse/KAFKA-1006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1006:
-
Description:
Consumer currently uses auto.offset.reset = largest by default. If a new topic
is
[
https://issues.apache.org/jira/browse/KAFKA-1006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1006:
-
Summary: Consumer loses messages of a new topic with auto.offset.reset =
largest (was: Mirror
[
https://issues.apache.org/jira/browse/KAFKA-1030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1030:
-
Description: Consumer may not notice new partitions because the propagation
of the metadata to
[
https://issues.apache.org/jira/browse/KAFKA-1030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1030:
-
Description:
Consumer may not notice new partitions because the propagation of the metadata
to
[
https://issues.apache.org/jira/browse/KAFKA-1030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13752679#comment-13752679
]
Swapnil Ghike commented on KAFKA-1030:
--
Hmm, this will mean that the consumer client
[
https://issues.apache.org/jira/browse/KAFKA-1026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13751519#comment-13751519
]
Swapnil Ghike commented on KAFKA-1026:
--
As David Demaagd had mentioned earlier, it
Swapnil Ghike created KAFKA-1017:
Summary: High number of open file handles in 0.8 producer
Key: KAFKA-1017
URL: https://issues.apache.org/jira/browse/KAFKA-1017
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-1017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1017:
-
Attachment: kafka-1017.patch
This patch fixes two issues:
1. Reduce the number of open file
[
https://issues.apache.org/jira/browse/KAFKA-990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13737162#comment-13737162
]
Swapnil Ghike commented on KAFKA-990:
-
The rebased patch also failed for me on 0.8 HEAD
[
https://issues.apache.org/jira/browse/KAFKA-990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13737162#comment-13737162
]
Swapnil Ghike edited comment on KAFKA-990 at 8/12/13 6:23 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13737199#comment-13737199
]
Swapnil Ghike commented on KAFKA-990:
-
v1 works with git apply.
Fix
Swapnil Ghike created KAFKA-1006:
Summary: Mirror maker loses messages of a new topic
Key: KAFKA-1006
URL: https://issues.apache.org/jira/browse/KAFKA-1006
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13730439#comment-13730439
]
Swapnil Ghike commented on KAFKA-999:
-
Since we need leader broker's host:port to
[
https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13731174#comment-13731174
]
Swapnil Ghike commented on KAFKA-999:
-
Actually that's not needed, will get a patch out
[
https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-999:
Comment: was deleted
(was: Actually that's not needed, will get a patch out in a couple hours.)
[
https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-999:
Attachment: kafka-999-v1.patch
Controlled shutdown never succeeds until the broker is killed
[
https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-999:
Attachment: kafka-999-v2.patch
Thanks for pointing that out. Actually in ControllerChannelManager,
[
https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-999:
Attachment: kafka-999-v3.patch
Controlled shutdown never succeeds until the broker is killed
[
https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-999:
Attachment: (was: LIKAFKA-269-v3.patch)
Controlled shutdown never succeeds until the
Swapnil Ghike created KAFKA-1003:
Summary: ConsumerFetcherManager should pass clientId as
metricsPrefix to AbstractFetcherManager
Key: KAFKA-1003
URL: https://issues.apache.org/jira/browse/KAFKA-1003
1 - 100 of 279 matches
Mail list logo
