Re: Kafka rest endpoint: early feedback

2013-12-04 Thread Jun Rao
Sasha, Thanks for sharing. The easiest thing is probably to start in a separate project. Once it's ready, we can link it from our wiki. Jun On Wed, Dec 4, 2013 at 5:46 PM, Sasha Klizhentas < sasha.klizhen...@mailgunhq.com> wrote: > Hi All, > > I've started working on Kafka rest endpoint to mak

[jira] [Commented] (KAFKA-1163) see whats going on with the 2.8.0 pom

2013-12-04 Thread Jason Rosenberg (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13839760#comment-13839760 ] Jason Rosenberg commented on KAFKA-1163: how are the pom files generated, is it us

Re: Kafka rest endpoint: early feedback

2013-12-04 Thread Steve Morin
Sasha, Currently I am building out a rest endpoint that is taking messages from nginx and writing them out to Kafka.You should take a look at it. Will look more at your API. https://github.com/DemandCube/Sparkngin -Steve On Wed, Dec 4, 2013 at 5:46 PM, Sasha Klizhentas < sasha.klizhen..

Re: Review Request 15674: new patch

2013-12-04 Thread Guozhang Wang
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/15674/#review29783 --- core/src/main/scala/kafka/log/LogCleaner.scala

Kafka rest endpoint: early feedback

2013-12-04 Thread Sasha Klizhentas
Hi All, I've started working on Kafka rest endpoint to make it easier to interface with Kafka from non JVM based languages and avoid writing high level consumer/producer client and zookeeper coordination. Here's early version: https://github.com/mailgun/kafka/compare/sasha;dev And draft API: h

Re: Review Request 16022: OfflinePartitionCount in JMX can be incorrect during controlled shutdown

2013-12-04 Thread Neha Narkhede
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/16022/#review29781 --- Ship it! Ship It! - Neha Narkhede On Dec. 4, 2013, 11:42 p.m., J

Re: Review Request 16005: Patch for KAFKA-1167

2013-12-04 Thread Guozhang Wang
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/16005/#review29779 --- core/src/main/scala/kafka/admin/TopicCommand.scala

Re: Review Request 15964: Patch for KAFKA-1156

2013-12-04 Thread Guozhang Wang
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/15964/#review29777 --- Ship it! Ship It! - Guozhang Wang On Dec. 4, 2013, 12:22 a.m., N

[jira] [Commented] (KAFKA-1168) OfflinePartitionCount in JMX can be incorrect during controlled shutdown

2013-12-04 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13839488#comment-13839488 ] Jun Rao commented on KAFKA-1168: Created reviewboard https://reviews.apache.org/r/16022/

[jira] [Updated] (KAFKA-1168) OfflinePartitionCount in JMX can be incorrect during controlled shutdown

2013-12-04 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1168: --- Attachment: KAFKA-1168.patch > OfflinePartitionCount in JMX can be incorrect during controlled shutdown > ---

Re: Review Request 16022: OfflinePartitionCount in JMX can be incorrect during controlled shutdown

2013-12-04 Thread Swapnil Ghike
--- 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., J

Review Request 16022: OfflinePartitionCount in JMX can be incorrect during controlled shutdown

2013-12-04 Thread Jun Rao
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/16022/ --- Review request for kafka. Bugs: KAFKA-1168 https://issues.apache.org/jira/b

[jira] [Created] (KAFKA-1168) OfflinePartitionCount in JMX can be incorrect during controlled shutdown

2013-12-04 Thread Jun Rao (JIRA)
Jun Rao created KAFKA-1168: -- Summary: OfflinePartitionCount in JMX can be incorrect during controlled shutdown Key: KAFKA-1168 URL: https://issues.apache.org/jira/browse/KAFKA-1168 Project: Kafka I

[jira] [Updated] (KAFKA-1167) Improve the kafka-topics tool to list the topics with overridden configs

2013-12-04 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1167: - Attachment: KAFKA-1167.patch > Improve the kafka-topics tool to list the topics with overridden c

[jira] [Commented] (KAFKA-1167) Improve the kafka-topics tool to list the topics with overridden configs

2013-12-04 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13839181#comment-13839181 ] Neha Narkhede commented on KAFKA-1167: -- Created reviewboard https://reviews.apache.or

Review Request 16005: Patch for KAFKA-1167

2013-12-04 Thread Neha Narkhede
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/16005/ --- Review request for kafka. Bugs: KAFKA-1167 https://issues.apache.org/jira/b

[jira] [Commented] (KAFKA-1074) Reassign partitions should delete the old replicas from disk

2013-12-04 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13839154#comment-13839154 ] Jun Rao commented on KAFKA-1074: Summary of the new patch: LogCleaner: *added the logic to

Re: Review Request 15674: new patch

2013-12-04 Thread Jun Rao
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/15674/ --- (Updated Dec. 4, 2013, 6:15 p.m.) Review request for kafka. Bugs: KAFKA-1074

[jira] [Updated] (KAFKA-1074) Reassign partitions should delete the old replicas from disk

2013-12-04 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1074: --- Attachment: KAFKA-1074_2013-12-04_10:14:13.patch > Reassign partitions should delete the old replicas from di

[jira] [Commented] (KAFKA-1074) Reassign partitions should delete the old replicas from disk

2013-12-04 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13839152#comment-13839152 ] Jun Rao commented on KAFKA-1074: Updated reviewboard https://reviews.apache.org/r/15674/

Re: Review Request 15674: new patch

2013-12-04 Thread Jun Rao
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/15674/ --- (Updated Dec. 4, 2013, 6:13 p.m.) Review request for kafka. Summary (updated)

[jira] [Created] (KAFKA-1167) Improve the kafka-topics tool to list the topics with overridden configs

2013-12-04 Thread Neha Narkhede (JIRA)
Neha Narkhede created KAFKA-1167: Summary: Improve the kafka-topics tool to list the topics with overridden configs Key: KAFKA-1167 URL: https://issues.apache.org/jira/browse/KAFKA-1167 Project: Kafka

[jira] [Commented] (KAFKA-1165) typo in kafka-server-stop.sh

2013-12-04 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13838969#comment-13838969 ] Jun Rao commented on KAFKA-1165: This is because delete topic is not yet supported. > typ

[jira] [Resolved] (KAFKA-1166) typo in kafka-server-stop.sh

2013-12-04 Thread tedwon (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tedwon resolved KAFKA-1166. --- Resolution: Duplicate > typo in kafka-server-stop.sh > > > Key:

[jira] [Closed] (KAFKA-1166) typo in kafka-server-stop.sh

2013-12-04 Thread tedwon (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tedwon closed KAFKA-1166. - > typo in kafka-server-stop.sh > > > Key: KAFKA-1166 > U

[jira] [Commented] (KAFKA-1165) typo in kafka-server-stop.sh

2013-12-04 Thread tedwon (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13838798#comment-13838798 ] tedwon commented on KAFKA-1165: --- Yup, thanks. Now I found it out in the release notes. And

[jira] [Commented] (KAFKA-1165) typo in kafka-server-stop.sh

2013-12-04 Thread Kostya Golikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13838769#comment-13838769 ] Kostya Golikov commented on KAFKA-1165: --- If you talking about slash -- it is not a t

[jira] [Commented] (KAFKA-1166) typo in kafka-server-stop.sh

2013-12-04 Thread Kostya Golikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13838763#comment-13838763 ] Kostya Golikov commented on KAFKA-1166: --- Duplicate of https://issues.apache.org/jira