[
https://issues.apache.org/jira/browse/KAFKA-871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13639359#comment-13639359
]
Swapnil Ghike commented on KAFKA-871:
-
How about using metadata.broker.list or metadata
Swapnil Ghike created KAFKA-874:
---
Summary: Migration tool's system tests should use separate
server.properties files for 0.7 and 0.8 brokers
Key: KAFKA-874
URL: https://issues.apache.org/jira/browse/KAFKA-874
Swapnil Ghike created KAFKA-875:
---
Summary: System test cleanup
Key: KAFKA-875
URL: https://issues.apache.org/jira/browse/KAFKA-875
Project: Kafka
Issue Type: Bug
Affects Versions: 0.8
[
https://issues.apache.org/jira/browse/KAFKA-871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-871:
Attachment: kafka-871-v2.patch
Renamed broker.list to metadata.broker.list.
Discussed the system t
[
https://issues.apache.org/jira/browse/KAFKA-835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike reassigned KAFKA-835:
---
Assignee: Swapnil Ghike
> Update 0.8 configs on the website
>
[
https://issues.apache.org/jira/browse/KAFKA-835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-835:
Attachment: config-changes.patch
I have not included the "recommended mbeans to monitor" information
[
https://issues.apache.org/jira/browse/KAFKA-875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13640134#comment-13640134
]
Swapnil Ghike commented on KAFKA-875:
-
And we should also do something about this tripp
[
https://issues.apache.org/jira/browse/KAFKA-871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13640151#comment-13640151
]
Swapnil Ghike commented on KAFKA-871:
-
We should hold off checking this patch in until
[
https://issues.apache.org/jira/browse/KAFKA-871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13640665#comment-13640665
]
Swapnil Ghike commented on KAFKA-871:
-
According to [~jfung], anything under system_tes
[
https://issues.apache.org/jira/browse/KAFKA-871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13640667#comment-13640667
]
Swapnil Ghike commented on KAFKA-871:
-
I will exclude them from v3 to reduce the noise
[
https://issues.apache.org/jira/browse/KAFKA-835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-835:
Attachment: config-changes-v2.patch
My bad. This patch includes three files - configuration07, confi
[
https://issues.apache.org/jira/browse/KAFKA-835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-835:
Attachment: config-changes-v3.patch
> Update 0.8 configs on the website
> --
[
https://issues.apache.org/jira/browse/KAFKA-871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13641323#comment-13641323
]
Swapnil Ghike commented on KAFKA-871:
-
1. Removed the aforementioned noise from patch v
[
https://issues.apache.org/jira/browse/KAFKA-871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-871:
Attachment: kafka-871-v3.patch
> Rename ZkConfig properties
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13642347#comment-13642347
]
Swapnil Ghike commented on KAFKA-871:
-
Attached patch v4.
I think v4 fixes the system
[
https://issues.apache.org/jira/browse/KAFKA-871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-871:
Attachment: kafka-871-v4.patch
> Rename ZkConfig properties
> --
>
>
Swapnil Ghike created KAFKA-878:
---
Summary: System test should if # messages produced and consumed in
migration tool test is 0
Key: KAFKA-878
URL: https://issues.apache.org/jira/browse/KAFKA-878
Project:
[
https://issues.apache.org/jira/browse/KAFKA-878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-878:
Summary: System test should fail if # messages produced and consumed in
migration tool test is 0 (w
[
https://issues.apache.org/jira/browse/KAFKA-878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-878:
Description: System test should fail if # messages produced and consumed in
migration tool test is 0
Swapnil Ghike created KAFKA-879:
---
Summary: In system test, read the new leader from zookeeper
instead of broker log on completion of become-leader state transition
Key: KAFKA-879
URL: https://issues.apache.org/jira/
[
https://issues.apache.org/jira/browse/KAFKA-876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13642633#comment-13642633
]
Swapnil Ghike commented on KAFKA-876:
-
Starting from 10:08:55,750, the zookeeper log sh
[
https://issues.apache.org/jira/browse/KAFKA-835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-835:
Attachment: config-changes-v4.patch
Attached patch v4. Include log.roll.hours in configuration07.htm
[
https://issues.apache.org/jira/browse/KAFKA-887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13644723#comment-13644723
]
Swapnil Ghike commented on KAFKA-887:
-
Thanks for the cleanup. +1
> St
[
https://issues.apache.org/jira/browse/KAFKA-901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13658959#comment-13658959
]
Swapnil Ghike commented on KAFKA-901:
-
Just to be sure, the two attached patches are in
Swapnil Ghike created KAFKA-917:
---
Summary: Expose zk.session.timeout.ms in console consumer
Key: KAFKA-917
URL: https://issues.apache.org/jira/browse/KAFKA-917
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-917:
Attachment: kafka-917.patch
Attached a pathc.
> Expose zk.session.timeout.ms in con
[
https://issues.apache.org/jira/browse/KAFKA-917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13668781#comment-13668781
]
Swapnil Ghike commented on KAFKA-917:
-
Hi, could someone review this? Thanks!
[
https://issues.apache.org/jira/browse/KAFKA-917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13668885#comment-13668885
]
Swapnil Ghike commented on KAFKA-917:
-
Makes sense, opened KAFKA-924.
Swapnil Ghike created KAFKA-924:
---
Summary: Specify console consumer properties via a single
--property command line parameter
Key: KAFKA-924
URL: https://issues.apache.org/jira/browse/KAFKA-924
Project:
[
https://issues.apache.org/jira/browse/KAFKA-923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13670132#comment-13670132
]
Swapnil Ghike commented on KAFKA-923:
-
Looks good, +1.
> Improve contr
[
https://issues.apache.org/jira/browse/KAFKA-928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13672312#comment-13672312
]
Swapnil Ghike commented on KAFKA-928:
-
+1, thanks for fixing this.
> n
[
https://issues.apache.org/jira/browse/KAFKA-928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13673571#comment-13673571
]
Swapnil Ghike commented on KAFKA-928:
-
Was just about to comment, perhaps it would be g
[
https://issues.apache.org/jira/browse/KAFKA-917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-917:
Attachment: kafka-917-0.8-rebased.patch
Does the rebased patch work?
> Expose zk.se
[
https://issues.apache.org/jira/browse/KAFKA-951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13691633#comment-13691633
]
Swapnil Ghike commented on KAFKA-951:
-
+1, thanks.
> Leader election r
[
https://issues.apache.org/jira/browse/KAFKA-835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13698668#comment-13698668
]
Swapnil Ghike commented on KAFKA-835:
-
This was committed http://kafka.apache.org/08/co
[
https://issues.apache.org/jira/browse/KAFKA-835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike resolved KAFKA-835.
-
Resolution: Fixed
> Update 0.8 configs on the website
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13699819#comment-13699819
]
Swapnil Ghike commented on KAFKA-559:
-
Some feedback:
1. Passing a groupId for cleanup
Swapnil Ghike created KAFKA-964:
---
Summary: Default hadoop-producer configs to ProducerConfig defaults
Key: KAFKA-964
URL: https://issues.apache.org/jira/browse/KAFKA-964
Project: Kafka
Issue Ty
[
https://issues.apache.org/jira/browse/KAFKA-964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-964:
Attachment: kafka-964.patch
> Default hadoop-producer configs to ProducerConfig defaults
> -
[
https://issues.apache.org/jira/browse/KAFKA-964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-964:
Labels: bugs (was: )
Status: Patch Available (was: Open)
> Default hadoop-producer configs
[
https://issues.apache.org/jira/browse/KAFKA-964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-964:
Summary: Default hadoop-producer configs to request.required.acks = 1
(was: Default hadoop-producer
[
https://issues.apache.org/jira/browse/KAFKA-964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-964:
Attachment: (was: kafka-964.patch)
> Default hadoop-producer configs to request.required.ack
[
https://issues.apache.org/jira/browse/KAFKA-964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-964:
Attachment: kafka-964-v1.patch
Set request.required.acks = 1 in hadoop-producer.
Maintained the ove
[
https://issues.apache.org/jira/browse/KAFKA-969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13705517#comment-13705517
]
Swapnil Ghike commented on KAFKA-969:
-
I agree with Joel. Registering a consumers' subs
[
https://issues.apache.org/jira/browse/KAFKA-656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13707836#comment-13707836
]
Swapnil Ghike commented on KAFKA-656:
-
Hey Prashanth/Jonathan, have you had the time to
[
https://issues.apache.org/jira/browse/KAFKA-266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13707837#comment-13707837
]
Swapnil Ghike commented on KAFKA-266:
-
Hey Andrea, Guy, did you make any head way on th
[
https://issues.apache.org/jira/browse/KAFKA-979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13712002#comment-13712002
]
Swapnil Ghike commented on KAFKA-979:
-
Hey Sriram, can you explain what we are trying t
[
https://issues.apache.org/jira/browse/KAFKA-983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-983:
Status: Patch Available (was: Open)
> Expose cleanshutdown method in MirrorMaker at the object
[
https://issues.apache.org/jira/browse/KAFKA-983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-983:
Attachment: KAFKA-983.patch
> Expose cleanshutdown method in MirrorMaker at the object level
> -
Swapnil Ghike created KAFKA-983:
---
Summary: Expose cleanshutdown method in MirrorMaker at the object
level
Key: KAFKA-983
URL: https://issues.apache.org/jira/browse/KAFKA-983
Project: Kafka
Iss
Swapnil Ghike created KAFKA-987:
---
Summary: Avoid checkpointing offsets in Kafka consumer that have
not changed since the last commit
Key: KAFKA-987
URL: https://issues.apache.org/jira/browse/KAFKA-987
P
[
https://issues.apache.org/jira/browse/KAFKA-987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-987:
Attachment: kafka-987.patch
The only case wherein the code does not have a bug and yet the consumer
[
https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13715949#comment-13715949
]
Swapnil Ghike commented on KAFKA-982:
-
+1 for 296.
> Logo for Kafka
>
[
https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13716594#comment-13716594
]
Swapnil Ghike commented on KAFKA-982:
-
Now that we have 301 back in the race, I change
[
https://issues.apache.org/jira/browse/KAFKA-987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-987:
Attachment: kafka-987-v2.patch
Yes, thank you. Attached v2.
> Avoid checkpointing o
[
https://issues.apache.org/jira/browse/KAFKA-984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13717894#comment-13717894
]
Swapnil Ghike commented on KAFKA-984:
-
Hey Guozhang, this looks like a reasonable appro
[
https://issues.apache.org/jira/browse/KAFKA-987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13718044#comment-13718044
]
Swapnil Ghike commented on KAFKA-987:
-
I think that any call to createMessageStreams wi
[
https://issues.apache.org/jira/browse/KAFKA-983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-983:
Attachment: KAFKA-983-rebased.patch
rebased.
> Expose cleanshutdown method in Mirro
[
https://issues.apache.org/jira/browse/KAFKA-987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13721221#comment-13721221
]
Swapnil Ghike commented on KAFKA-987:
-
I discussed this yesterday with Jun. If there is
Swapnil Ghike created KAFKA-991:
---
Summary: Reduce the queue size in hadoop producer
Key: KAFKA-991
URL: https://issues.apache.org/jira/browse/KAFKA-991
Project: Kafka
Issue Type: Bug
Affect
[
https://issues.apache.org/jira/browse/KAFKA-991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-991:
Description:
Currently the queue.size in hadoop producer is 10MB. This means that the
KafkaRecordWr
[
https://issues.apache.org/jira/browse/KAFKA-991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-991:
Attachment: kafka-991-v1.patch
> Reduce the queue size in hadoop producer
>
[
https://issues.apache.org/jira/browse/KAFKA-991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-991:
Status: Patch Available (was: Open)
> Reduce the queue size in hadoop producer
> --
[
https://issues.apache.org/jira/browse/KAFKA-991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-991:
Description:
Currently the queue.size in hadoop producer is 10MB. This means that the
KafkaRecordWr
[
https://issues.apache.org/jira/browse/KAFKA-991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13726955#comment-13726955
]
Swapnil Ghike commented on KAFKA-991:
-
Also reviewed by Jun, Neha. The reason why we us
[
https://issues.apache.org/jira/browse/KAFKA-991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-991:
Attachment: kafka-991-followup.patch
> Reduce the queue size in hadoop producer
> --
[
https://issues.apache.org/jira/browse/KAFKA-991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13726995#comment-13726995
]
Swapnil Ghike commented on KAFKA-991:
-
Thanks Joel. Would you mind committing the follo
[
https://issues.apache.org/jira/browse/KAFKA-991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-991:
Attachment: kafka-991-followup-v2.patch
Fixed README.
> Reduce the queue size in ha
[
https://issues.apache.org/jira/browse/KAFKA-991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-991:
Attachment: kafka-991-followup-3.patch
Thanks, attached a new patch to address that.
[
https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13727438#comment-13727438
]
Swapnil Ghike commented on KAFKA-992:
-
- I think I am not completely clear why timestam
[
https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13727438#comment-13727438
]
Swapnil Ghike edited comment on KAFKA-992 at 8/2/13 7:11 AM:
-
-
[
https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13728354#comment-13728354
]
Swapnil Ghike commented on KAFKA-992:
-
Makes sense. Just one comment, you can use the s
[
https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13728358#comment-13728358
]
Swapnil Ghike commented on KAFKA-992:
-
Also the while loop should be fixed, the first s
[
https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13728358#comment-13728358
]
Swapnil Ghike edited comment on KAFKA-992 at 8/3/13 1:39 AM:
-
A
[
https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13729607#comment-13729607
]
Swapnil Ghike commented on KAFKA-992:
-
+1
> Double Check on Broker Reg
[
https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13730243#comment-13730243
]
Swapnil Ghike commented on KAFKA-999:
-
I think the right fix would be to undo any chang
[
https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13730331#comment-13730331
]
Swapnil Ghike commented on KAFKA-999:
-
I see your points. After thinking a bit about th
Swapnil Ghike created KAFKA-1002:
Summary: Delete aliveLeaders field from LeaderAndIsrRequest
Key: KAFKA-1002
URL: https://issues.apache.org/jira/browse/KAFKA-1002
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13730348#comment-13730348
]
Swapnil Ghike commented on KAFKA-999:
-
Perhaps the word live misled me. Thanks for the
[
https://issues.apache.org/jira/browse/KAFKA-1002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-1002:
-
Description: After KAFKA-999 is committed, we don't need aliveLeaders in
LeaderAndIsrRequest. (w
[
https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13730439#comment-13730439
]
Swapnil Ghike commented on KAFKA-999:
-
Since we need leader broker's host:port to creat
[
https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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:
Assignee: Swapnil Ghike (was: Neha Narkhede)
> Controlled shutdown never succeeds until the bro
[
https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-999:
Status: Patch Available (was: Open)
> Controlled shutdown never succeeds until the broker is ki
[
https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-999:
Attachment: kafka-991-v1.patch
Small-scale fix for 0.8.
> Controlled shutdown neve
[
https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-999:
Attachment: (was: kafka-991-v1.patch)
> Controlled shutdown never succeeds until the broker
[
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, w
[
https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-999:
Attachment: LIKAFKA-269-v3.patch
Renamed to leaders at one another place.
> Control
[
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 broke
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
[
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 t
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-990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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-tabpanel&focusedCommentId=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-tabpanel&focusedCommentId=13737199#comment-13737199
]
Swapnil Ghike commented on KAFKA-990:
-
v1 works with git apply.
> Fix
[
https://issues.apache.org/jira/browse/KAFKA-990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13737419#comment-13737419
]
Swapnil Ghike commented on KAFKA-990:
-
Comments on v1:
I think a much clearer name for
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: Bu
101 - 200 of 433 matches
Mail list logo
