[jira] [Assigned] (KAFKA-3940) Log should check the return value of dir.mkdirs()

[ https://issues.apache.org/jira/browse/KAFKA-3940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ishita Mandhan reassigned KAFKA-3940: - Assignee: (was: Ishita Mandhan) > Log should check the return value of dir.mkdirs()

[jira] [Assigned] (KAFKA-3522) Consider adding version information into rocksDB storage format

[ https://issues.apache.org/jira/browse/KAFKA-3522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ishita Mandhan reassigned KAFKA-3522: - Assignee: (was: Ishita Mandhan) > Consider adding version information into rocksDB

[jira] [Commented] (KAFKA-3522) Consider adding version information into rocksDB storage format

[ https://issues.apache.org/jira/browse/KAFKA-3522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15847779#comment-15847779 ] Ishita Mandhan commented on KAFKA-3522: --- [~ewencp]I don't think I'll be able to work on this

[jira] [Assigned] (KAFKA-2544) Replication tools wiki page needs to be updated

[ https://issues.apache.org/jira/browse/KAFKA-2544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ishita Mandhan reassigned KAFKA-2544: - Assignee: (was: Ishita Mandhan) > Replication tools wiki page needs to be updated >

[jira] [Assigned] (KAFKA-4320) Log compaction docs update

[ https://issues.apache.org/jira/browse/KAFKA-4320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ishita Mandhan reassigned KAFKA-4320: - Assignee: (was: Ishita Mandhan) > Log compaction docs update >

[jira] [Assigned] (KAFKA-4220) Clean up & provide better error message when incorrect argument types are provided in the command line client

[ https://issues.apache.org/jira/browse/KAFKA-4220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ishita Mandhan reassigned KAFKA-4220: - Assignee: Vahid Hashemian (was: Ishita Mandhan) > Clean up & provide better error

[jira] [Assigned] (KAFKA-2857) ConsumerGroupCommand throws GroupCoordinatorNotAvailableException when describing a non-existent group before the offset topic is created

[ https://issues.apache.org/jira/browse/KAFKA-2857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ishita Mandhan reassigned KAFKA-2857: - Assignee: Vahid Hashemian (was: Ishita Mandhan) > ConsumerGroupCommand throws

[jira] [Commented] (KAFKA-3940) Log should check the return value of dir.mkdirs()

[ https://issues.apache.org/jira/browse/KAFKA-3940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15701279#comment-15701279 ] Ishita Mandhan commented on KAFKA-3940: --- [~ijuma] I had a quick question about creating a second PR

[jira] [Commented] (KAFKA-4307) Inconsistent parameters between console producer and consumer

[ https://issues.apache.org/jira/browse/KAFKA-4307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15626723#comment-15626723 ] Ishita Mandhan commented on KAFKA-4307: --- Sure, take your time! Was just checking to see if it was up

[jira] [Assigned] (KAFKA-2544) Replication tools wiki page needs to be updated

[ https://issues.apache.org/jira/browse/KAFKA-2544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ishita Mandhan reassigned KAFKA-2544: - Assignee: Ishita Mandhan > Replication tools wiki page needs to be updated >

[jira] [Commented] (KAFKA-4307) Inconsistent parameters between console producer and consumer

[ https://issues.apache.org/jira/browse/KAFKA-4307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15626328#comment-15626328 ] Ishita Mandhan commented on KAFKA-4307: --- Are you working on this, [~manasvigupta]? > Inconsistent

[jira] [Assigned] (KAFKA-4320) Log compaction docs update

[ https://issues.apache.org/jira/browse/KAFKA-4320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ishita Mandhan reassigned KAFKA-4320: - Assignee: Ishita Mandhan > Log compaction docs update > -- > >

[jira] [Work started] (KAFKA-4220) Clean up & provide better error message when incorrect argument types are provided in the command line client

[ https://issues.apache.org/jira/browse/KAFKA-4220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4220 started by Ishita Mandhan. - > Clean up & provide better error message when incorrect argument types are >

[jira] [Updated] (KAFKA-4220) Clean up & provide better error message when incorrect argument types are provided in the command line client

[ https://issues.apache.org/jira/browse/KAFKA-4220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ishita Mandhan updated KAFKA-4220: -- Description: When the argument provided to a command line statement is not of the right type,

[jira] [Created] (KAFKA-4220) Clean up & provide better error message when incorrect argument types are provided in the command line client

Ishita Mandhan created KAFKA-4220: - Summary: Clean up & provide better error message when incorrect argument types are provided in the command line client Key: KAFKA-4220 URL:

[jira] [Work started] (KAFKA-3940) Log should check the return value of dir.mkdirs()

[ https://issues.apache.org/jira/browse/KAFKA-3940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3940 started by Ishita Mandhan. - > Log should check the return value of dir.mkdirs() >

[jira] [Commented] (KAFKA-3522) Consider adding version information into rocksDB storage format

[ https://issues.apache.org/jira/browse/KAFKA-3522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15431288#comment-15431288 ] Ishita Mandhan commented on KAFKA-3522: --- Just wanted to check in to see if now is a good time to

[jira] [Commented] (KAFKA-3929) Add prefix for underlying clients configs in StreamConfig

[ https://issues.apache.org/jira/browse/KAFKA-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15388216#comment-15388216 ] Ishita Mandhan commented on KAFKA-3929: --- I've started but haven't made too much progress into it so

[jira] [Commented] (KAFKA-3940) Log should check the return value of dir.mkdirs()

[ https://issues.apache.org/jira/browse/KAFKA-3940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384663#comment-15384663 ] Ishita Mandhan commented on KAFKA-3940: --- I think we should convert the dir.mkdirs() to

[jira] [Commented] (KAFKA-3940) Log should check the return value of dir.mkdirs()

[ https://issues.apache.org/jira/browse/KAFKA-3940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15375692#comment-15375692 ] Ishita Mandhan commented on KAFKA-3940: --- Hi Jim, I got a notification of your PR because I had this

[jira] [Commented] (KAFKA-3940) Log should check the return value of dir.mkdirs()

[ https://issues.apache.org/jira/browse/KAFKA-3940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15372078#comment-15372078 ] Ishita Mandhan commented on KAFKA-3940: --- If dir is changed from File to Files here

[jira] [Assigned] (KAFKA-3940) Log should check the return value of dir.mkdirs()

[ https://issues.apache.org/jira/browse/KAFKA-3940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ishita Mandhan reassigned KAFKA-3940: - Assignee: Ishita Mandhan > Log should check the return value of dir.mkdirs() >

[jira] [Commented] (KAFKA-3929) Add prefix for underlying clients configs in StreamConfig

[ https://issues.apache.org/jira/browse/KAFKA-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15364802#comment-15364802 ] Ishita Mandhan commented on KAFKA-3929: --- So have a function say appConfigsWithPrefix that is called

[jira] [Commented] (KAFKA-3929) Add prefix for underlying clients configs in StreamConfig

[ https://issues.apache.org/jira/browse/KAFKA-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15363051#comment-15363051 ] Ishita Mandhan commented on KAFKA-3929: --- Are you thinking a similar implementation to KAFAK-3740 for

[jira] [Assigned] (KAFKA-3929) Add prefix for underlying clients configs in StreamConfig

[ https://issues.apache.org/jira/browse/KAFKA-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ishita Mandhan reassigned KAFKA-3929: - Assignee: Ishita Mandhan > Add prefix for underlying clients configs in StreamConfig >

[jira] [Comment Edited] (KAFKA-3876) Transient test failure: kafka.api.PlaintextConsumerTest.testExpandingTopicSubscriptions

[ https://issues.apache.org/jira/browse/KAFKA-3876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15362993#comment-15362993 ] Ishita Mandhan edited comment on KAFKA-3876 at 7/5/16 6:48 PM: --- I saw the

[jira] [Commented] (KAFKA-3876) Transient test failure: kafka.api.PlaintextConsumerTest.testExpandingTopicSubscriptions

[ https://issues.apache.org/jira/browse/KAFKA-3876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15362993#comment-15362993 ] Ishita Mandhan commented on KAFKA-3876: --- I saw a similar one too -

[jira] [Commented] (KAFKA-3522) Consider adding version information into rocksDB storage format

[ https://issues.apache.org/jira/browse/KAFKA-3522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352172#comment-15352172 ] Ishita Mandhan commented on KAFKA-3522: --- I'd like to work on this once a consensus has been reached

[jira] [Assigned] (KAFKA-3522) Consider adding version information into rocksDB storage format

[ https://issues.apache.org/jira/browse/KAFKA-3522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ishita Mandhan reassigned KAFKA-3522: - Assignee: Ishita Mandhan > Consider adding version information into rocksDB storage

[jira] [Commented] (KAFKA-2857) ConsumerGroupCommand throws GroupCoordinatorNotAvailableException when describing a non-existent group before the offset topic is created

[ https://issues.apache.org/jira/browse/KAFKA-2857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15347448#comment-15347448 ] Ishita Mandhan commented on KAFKA-2857: --- Thanks [~hachikuji]! I just created a PR for this jira. >

[jira] [Assigned] (KAFKA-3897) Improve Unit Tests for New Consumer's Regex Subscription

[ https://issues.apache.org/jira/browse/KAFKA-3897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ishita Mandhan reassigned KAFKA-3897: - Assignee: Ishita Mandhan > Improve Unit Tests for New Consumer's Regex Subscription >

[jira] [Commented] (KAFKA-2857) ConsumerGroupCommand throws GroupCoordinatorNotAvailableException when describing a non-existent group before the offset topic is created

[ https://issues.apache.org/jira/browse/KAFKA-2857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15347175#comment-15347175 ] Ishita Mandhan commented on KAFKA-2857: --- So it seems like we need to check if the offsets topic

[jira] [Commented] (KAFKA-3185) Allow users to cleanup internal data

[ https://issues.apache.org/jira/browse/KAFKA-3185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15334945#comment-15334945 ] Ishita Mandhan commented on KAFKA-3185: --- Ah okay, sounds good- I'll look for something else. thank

[jira] [Commented] (KAFKA-3185) Allow users to cleanup internal data

[ https://issues.apache.org/jira/browse/KAFKA-3185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15334860#comment-15334860 ] Ishita Mandhan commented on KAFKA-3185: --- [~guozhang] Do you think this is a bug a newbie(aka me)

[jira] [Assigned] (KAFKA-2857) ConsumerGroupCommand throws GroupCoordinatorNotAvailableException when describing a non-existent group before the offset topic is created

[ https://issues.apache.org/jira/browse/KAFKA-2857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ishita Mandhan reassigned KAFKA-2857: - Assignee: Ishita Mandhan > ConsumerGroupCommand throws

[jira] [Commented] (KAFKA-2857) ConsumerGroupCommand throws GroupCoordinatorNotAvailableException when describing a non-existent group before the offset topic is created

[ https://issues.apache.org/jira/browse/KAFKA-2857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15325152#comment-15325152 ] Ishita Mandhan commented on KAFKA-2857: --- Working on this with [~vahid] and we aren't sure about what

[jira] [Commented] (KAFKA-3762) Log.loadSegments() should log the message in exception

[ https://issues.apache.org/jira/browse/KAFKA-3762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15319487#comment-15319487 ] Ishita Mandhan commented on KAFKA-3762: --- [~junrao] Is this what you had in mind? ^ >

[jira] [Commented] (KAFKA-3755) tightening the offset check in ReplicaFetcherThread

[ https://issues.apache.org/jira/browse/KAFKA-3755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15311436#comment-15311436 ] Ishita Mandhan commented on KAFKA-3755: --- [~junrao]What would be easiest way to produce an error to

[jira] [Assigned] (KAFKA-3762) Log.loadSegments() should log the message in exception

[ https://issues.apache.org/jira/browse/KAFKA-3762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ishita Mandhan reassigned KAFKA-3762: - Assignee: Ishita Mandhan > Log.loadSegments() should log the message in exception >

[jira] [Assigned] (KAFKA-3755) tightening the offset check in ReplicaFetcherThread

[ https://issues.apache.org/jira/browse/KAFKA-3755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ishita Mandhan reassigned KAFKA-3755: - Assignee: Ishita Mandhan > tightening the offset check in ReplicaFetcherThread >

[jira] [Commented] (KAFKA-3158) ConsumerGroupCommand should tell whether group is actually dead

[ https://issues.apache.org/jira/browse/KAFKA-3158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15300716#comment-15300716 ] Ishita Mandhan commented on KAFKA-3158: --- Thanks [~hachikuji]! I just submitted a PR for it >

[jira] [Commented] (KAFKA-3158) ConsumerGroupCommand should tell whether group is actually dead

[ https://issues.apache.org/jira/browse/KAFKA-3158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296877#comment-15296877 ] Ishita Mandhan commented on KAFKA-3158: --- [~jasong35] How can I reproduce the error? I'm having

[jira] [Commented] (KAFKA-3511) Provide built-in aggregators sum() and avg() in Kafka Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15286487#comment-15286487 ] Ishita Mandhan commented on KAFKA-3511: --- Sure, [~enothereska] I could definitely use some help. I'm

[jira] [Commented] (KAFKA-3158) ConsumerGroupCommand should tell whether group is actually dead

[ https://issues.apache.org/jira/browse/KAFKA-3158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15248867#comment-15248867 ] Ishita Mandhan commented on KAFKA-3158: --- Yes, I'd like to give it a shot. Assigning it to myself.

[jira] [Assigned] (KAFKA-3158) ConsumerGroupCommand should tell whether group is actually dead

[ https://issues.apache.org/jira/browse/KAFKA-3158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ishita Mandhan reassigned KAFKA-3158: - Assignee: Ishita Mandhan > ConsumerGroupCommand should tell whether group is actually

[jira] [Comment Edited] (KAFKA-3158) ConsumerGroupCommand should tell whether group is actually dead

[ https://issues.apache.org/jira/browse/KAFKA-3158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15248852#comment-15248852 ] Ishita Mandhan edited comment on KAFKA-3158 at 4/19/16 10:57 PM: - Neha,

[jira] [Commented] (KAFKA-3158) ConsumerGroupCommand should tell whether group is actually dead

[ https://issues.apache.org/jira/browse/KAFKA-3158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15248852#comment-15248852 ] Ishita Mandhan commented on KAFKA-3158: --- Neha, are you working on this bug? > ConsumerGroupCommand

[jira] [Assigned] (KAFKA-3511) Provide built-in aggregators sum() and avg() in Kafka Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ishita Mandhan reassigned KAFKA-3511: - Assignee: Ishita Mandhan > Provide built-in aggregators sum() and avg() in Kafka Streams