[jira] [Assigned] (KAFKA-4542) Add authentication based on delegation token.

2017-02-13 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy reassigned KAFKA-4542: -- Assignee: Manikumar Reddy > Add authentication based on delegation token. >

[jira] [Resolved] (KAFKA-3531) support subnet in ACL tool

2017-02-11 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-3531. Resolution: Duplicate Assignee: (was: Parth Brahmbhatt) Resolving this as

[jira] [Resolved] (KAFKA-4076) Kafka broker shuts down due to irrecoverable IO error

2017-02-09 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-4076. Resolution: Invalid Pl reopen the issue, if still exists. > Kafka broker shuts down due

[jira] [Commented] (KAFKA-4751) kafka-clients-0.9.0.2.4.2.11-1 issue not throwing exception.

2017-02-09 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15859568#comment-15859568 ] Manikumar Reddy commented on KAFKA-4751: It is a known issue. Related JIRA is KAFKA-1894 >

[jira] [Commented] (KAFKA-4541) Add capability to create delegation token

2017-01-24 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837319#comment-15837319 ] Manikumar Reddy commented on KAFKA-4541: [~singhashish] Can you post your WIP PR? So that I can

[jira] [Commented] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens

2016-12-15 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15751936#comment-15751936 ] Manikumar Reddy commented on KAFKA-1696: Thanks for creating sub-tasks. About authentication, we

[jira] [Commented] (KAFKA-4541) Add capability to create delegation token

2016-12-15 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15751744#comment-15751744 ] Manikumar Reddy commented on KAFKA-4541: [~singhashish] Is this JIRA work includes token storage

[jira] [Assigned] (KAFKA-4543) Add capability to renew/expire delegation tokens.

2016-12-15 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy reassigned KAFKA-4543: -- Assignee: Manikumar Reddy > Add capability to renew/expire delegation tokens. >

[jira] [Commented] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens

2016-12-13 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15747403#comment-15747403 ] Manikumar Reddy commented on KAFKA-1696: [~singhashish] Yes, Pl go ahead and create sub-jiras and

[jira] [Commented] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens

2016-12-12 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15742486#comment-15742486 ] Manikumar Reddy commented on KAFKA-1696: .[~singhashish] Sorry for the late reply. I reinitiated

[jira] [Commented] (KAFKA-4074) Deleting a topic can make it unavailable even if delete.topic.enable is false

2016-09-28 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15528682#comment-15528682 ] Manikumar Reddy commented on KAFKA-4074: [~hachikuji] Yes, resolving this as duplicate >

[jira] [Resolved] (KAFKA-4074) Deleting a topic can make it unavailable even if delete.topic.enable is false

2016-09-28 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-4074. Resolution: Duplicate > Deleting a topic can make it unavailable even if

[jira] [Commented] (KAFKA-4164) Kafka produces excessive logs when publishing message to non-existent topic

2016-09-15 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15495450#comment-15495450 ] Manikumar Reddy commented on KAFKA-4164: This is a valid concern. Currently metadata

[jira] [Issue Comment Deleted] (KAFKA-4126) No relevant log when the topic is non-existent

2016-09-15 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-4126: --- Comment: was deleted (was: Yes. Another issue related to producer excessive warn logging is

[jira] [Commented] (KAFKA-4126) No relevant log when the topic is non-existent

2016-09-15 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15495420#comment-15495420 ] Manikumar Reddy commented on KAFKA-4126: Yes. Another issue related to producer excessive warn

[jira] [Commented] (KAFKA-4126) No relevant log when the topic is non-existent

2016-09-15 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15495422#comment-15495422 ] Manikumar Reddy commented on KAFKA-4126: Yes. Another issue related to producer excessive warn

[jira] [Assigned] (KAFKA-2700) delete topic should remove the corresponding ACL and configs

2016-09-15 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy reassigned KAFKA-2700: -- Assignee: Manikumar Reddy (was: Parth Brahmbhatt) > delete topic should remove the

[jira] [Assigned] (KAFKA-4072) improving memory usage in LogCleaner

2016-09-15 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy reassigned KAFKA-4072: -- Assignee: Manikumar Reddy > improving memory usage in LogCleaner >

[jira] [Commented] (KAFKA-2700) delete topic should remove the corresponding ACL and configs

2016-09-15 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15492770#comment-15492770 ] Manikumar Reddy commented on KAFKA-2700: [~parth.brahmbhatt]], are you working on this JIRA? If

[jira] [Commented] (KAFKA-4126) No relevant log when the topic is non-existent

2016-09-14 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15490118#comment-15490118 ] Manikumar Reddy commented on KAFKA-4126: [~vahid] I think, I tried by disabling auto.topic.create.

[jira] [Commented] (KAFKA-4074) Deleting a topic can make it unavailable even if delete.topic.enable is false

2016-09-06 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15469613#comment-15469613 ] Manikumar Reddy commented on KAFKA-4074: [~junrao] Yes, Both issues are same. I can merge my

[jira] [Commented] (KAFKA-4111) broker compress data of certain size instead on a produce request

2016-09-06 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15469580#comment-15469580 ] Manikumar Reddy commented on KAFKA-4111: Ok got it. Broker handles each producer request

[jira] [Commented] (KAFKA-4111) broker compress data of certain size instead on a produce request

2016-09-06 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15466584#comment-15466584 ] Manikumar Reddy commented on KAFKA-4111: "compression.type" broker config property is applicable

[jira] [Commented] (KAFKA-4109) kafka client send msg exception

2016-09-06 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15466570#comment-15466570 ] Manikumar Reddy commented on KAFKA-4109: Enable producer debug logs to get root cause of the

[jira] [Commented] (KAFKA-4126) No relevant log when the topic is non-existent

2016-09-05 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15466496#comment-15466496 ] Manikumar Reddy commented on KAFKA-4126: Currently producer logs below warn message. May be we

[jira] [Commented] (KAFKA-4065) Property missing in ProcuderConfig.java - KafkaProducer API 0.9.0.0

2016-08-25 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15436585#comment-15436585 ] Manikumar Reddy commented on KAFKA-4065: Agree, currently new producer don't support

[jira] [Assigned] (KAFKA-4074) Deleting a topic can make it unavailable even if delete.topic.enable is false

2016-08-24 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy reassigned KAFKA-4074: -- Assignee: Manikumar Reddy > Deleting a topic can make it unavailable even if

[jira] [Commented] (KAFKA-4065) Property missing in ProcuderConfig.java - KafkaProducer API 0.9.0.0

2016-08-23 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15434215#comment-15434215 ] Manikumar Reddy commented on KAFKA-4065: "compression.type" config property is used in New

[jira] [Commented] (KAFKA-3218) Kafka-0.9.0.0 does not work as OSGi module

2016-08-23 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15432667#comment-15432667 ] Manikumar Reddy commented on KAFKA-3218: [~ rajinisivaram]KAFKA-3680 fixes this issue right?

[jira] [Commented] (KAFKA-4076) Kafka broker shuts down due to irrecoverable IO error

2016-08-23 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15432252#comment-15432252 ] Manikumar Reddy commented on KAFKA-4076: You are storing kafka data logs to /tmp folder. This is

[jira] [Resolved] (KAFKA-3204) ConsumerConnector blocked on Authenticated by SASL Failed.

2016-08-19 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-3204. Resolution: Won't Fix > ConsumerConnector blocked on Authenticated by SASL Failed. >

[jira] [Resolved] (KAFKA-4063) Add support for infinite endpoints for range queries in Kafka Streams KV stores

2016-08-18 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-4063. Resolution: Duplicate > Add support for infinite endpoints for range queries in Kafka

[jira] [Resolved] (KAFKA-2199) Make signing artifacts optional, setting maven repository possible from command line

2016-08-18 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-2199. Resolution: Fixed > Make signing artifacts optional, setting maven repository possible from

[jira] [Comment Edited] (KAFKA-3980) JmxReporter uses excessive memory causing OutOfMemoryException

2016-08-17 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15424315#comment-15424315 ] Manikumar Reddy edited comment on KAFKA-3980 at 8/17/16 11:22 AM: -- as

[jira] [Commented] (KAFKA-3980) JmxReporter uses excessive memory causing OutOfMemoryException

2016-08-17 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15424315#comment-15424315 ] Manikumar Reddy commented on KAFKA-3980: as suspected, this may be related to quota leak :

[jira] [Updated] (KAFKA-4035) AclCommand should allow Describe operation on groups

2016-08-15 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-4035: --- Resolution: Fixed Fix Version/s: 0.10.1.0 Status: Resolved (was: Patch

[jira] [Commented] (KAFKA-3959) __consumer_offsets wrong number of replicas at startup

2016-08-12 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15419140#comment-15419140 ] Manikumar Reddy commented on KAFKA-3959: Yes, min.insync.replicas applicable to internal topics

[jira] [Updated] (KAFKA-4012) KerberosShortNamer should implement toString()

2016-08-12 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-4012: --- Status: Patch Available (was: Open) > KerberosShortNamer should implement toString() >

[jira] [Updated] (KAFKA-4035) AclCommand should allow Describe operation on groups

2016-08-12 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-4035: --- Affects Version/s: 0.9.0.0 0.10.0.0 0.10.0.1 >

[jira] [Updated] (KAFKA-4035) AclCommand should allow Describe operation on groups

2016-08-12 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-4035: --- Status: Patch Available (was: Open) > AclCommand should allow Describe operation on groups >

[jira] [Assigned] (KAFKA-4035) AclCommand should allow Describe operation on groups

2016-08-12 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy reassigned KAFKA-4035: -- Assignee: Manikumar Reddy > AclCommand should allow Describe operation on groups >

[jira] [Comment Edited] (KAFKA-3959) __consumer_offsets wrong number of replicas at startup

2016-08-12 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15418751#comment-15418751 ] Manikumar Reddy edited comment on KAFKA-3959 at 8/12/16 1:27 PM: - looks

[jira] [Commented] (KAFKA-3959) __consumer_offsets wrong number of replicas at startup

2016-08-12 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15418751#comment-15418751 ] Manikumar Reddy commented on KAFKA-3959: looks like this is done on purpose. While creating

[jira] [Resolved] (KAFKA-1612) Consumer offsets auto-commit before processing finishes

2016-08-10 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-1612. Resolution: Won't Fix Closing this issue in favor new consumer API. > Consumer offsets

[jira] [Updated] (KAFKA-3950) kafka mirror maker tool is not respecting whitelist option

2016-07-30 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3950: --- Affects Version/s: (was: 0.10.0.0) 0.9.0.0 > kafka mirror maker

[jira] [Updated] (KAFKA-3950) kafka mirror maker tool is not respecting whitelist option

2016-07-30 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3950: --- Reviewer: Ismael Juma Fix Version/s: 0.10.0.1 > kafka mirror maker tool is not

[jira] [Updated] (KAFKA-3950) kafka mirror maker tool is not respecting whitelist option

2016-07-30 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3950: --- Affects Version/s: 0.10.0.0 > kafka mirror maker tool is not respecting whitelist option >

[jira] [Commented] (KAFKA-3950) kafka mirror maker tool is not respecting whitelist option

2016-07-29 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15399444#comment-15399444 ] Manikumar Reddy commented on KAFKA-3950: [~ijuma] Can we include this in 0.10.0.1 release? >

[jira] [Commented] (KAFKA-3992) InstanceAlreadyExistsException Error for Consumers Starting in Parallel

2016-07-26 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15393962#comment-15393962 ] Manikumar Reddy commented on KAFKA-3992: looks like you are giving same client-Id (consumerId) to

[jira] [Comment Edited] (KAFKA-3980) JmxReporter uses excessive memory causing OutOfMemoryException

2016-07-23 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15390792#comment-15390792 ] Manikumar Reddy edited comment on KAFKA-3980 at 7/23/16 6:27 PM: -

[jira] [Commented] (KAFKA-3980) JmxReporter uses excessive memory causing OutOfMemoryException

2016-07-23 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15390792#comment-15390792 ] Manikumar Reddy commented on KAFKA-3980: [~ajorgensen] Can you enable debug log and check Produce

[jira] [Commented] (KAFKA-3980) JmxReporter uses excessive memory causing OutOfMemoryException

2016-07-20 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15387174#comment-15387174 ] Manikumar Reddy commented on KAFKA-3980: This may due to increasing in client quota metrics

[jira] [Commented] (KAFKA-3102) Kafka server unable to connect to zookeeper

2016-07-15 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15379198#comment-15379198 ] Manikumar Reddy commented on KAFKA-3102: Subscribe to user mailing list. Details are here:

[jira] [Updated] (KAFKA-2213) Log cleaner should write compacted messages using configured compression type

2016-07-15 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2213: --- Resolution: Duplicate Status: Resolved (was: Patch Available) This duplicate of

[jira] [Commented] (KAFKA-3102) Kafka server unable to connect to zookeeper

2016-07-15 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15379135#comment-15379135 ] Manikumar Reddy commented on KAFKA-3102: [~liuxinjian] There is no kafka issue. This looks like

[jira] [Resolved] (KAFKA-3102) Kafka server unable to connect to zookeeper

2016-07-15 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-3102. Resolution: Duplicate > Kafka server unable to connect to zookeeper >

[jira] [Commented] (KAFKA-3961) broker sends malformed response when switching from no compression to snappy/gzip

2016-07-13 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15375342#comment-15375342 ] Manikumar Reddy commented on KAFKA-3961: you can try DumpLogSegments tools to to verify messages

[jira] [Commented] (KAFKA-3950) kafka mirror maker tool is not respecting whitelist option

2016-07-12 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15373115#comment-15373115 ] Manikumar Reddy commented on KAFKA-3950: I was also thinking similar lines. Instead of removing

[jira] [Updated] (KAFKA-3950) kafka mirror maker tool is not respecting whitelist option

2016-07-11 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3950: --- consumer.subscribe(Pattern p , ..) method is failing when authorizer is enabled. irrespective of

[jira] [Updated] (KAFKA-3802) log mtimes reset on broker restart

2016-06-15 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3802: --- Status: Patch Available (was: Open) > log mtimes reset on broker restart >

[jira] [Updated] (KAFKA-2651) Remove deprecated config alteration from TopicCommand in 0.9.1.0

2016-06-05 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2651: --- Fix Version/s: 0.11.0.0 > Remove deprecated config alteration from TopicCommand in 0.9.1.0 >

[jira] [Resolved] (KAFKA-2547) Make DynamicConfigManager to use the ZkNodeChangeNotificationListener introduced as part of KAFKA-2211

2016-05-20 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-2547. Resolution: Fixed > Make DynamicConfigManager to use the ZkNodeChangeNotificationListener

[jira] [Updated] (KAFKA-2547) Make DynamicConfigManager to use the ZkNodeChangeNotificationListener introduced as part of KAFKA-2211

2016-05-20 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2547: --- Status: Reopened (was: Closed) > Make DynamicConfigManager to use the

[jira] [Resolved] (KAFKA-3219) Long topic names mess up broker topic state

2016-05-20 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-3219. Resolution: Fixed > Long topic names mess up broker topic state >

[jira] [Updated] (KAFKA-3219) Long topic names mess up broker topic state

2016-05-20 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3219: --- Status: Reopened (was: Closed) > Long topic names mess up broker topic state >

[jira] [Resolved] (KAFKA-2800) Update outdated dependencies

2016-05-20 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-2800. Resolution: Fixed > Update outdated dependencies > > >

[jira] [Updated] (KAFKA-2800) Update outdated dependencies

2016-05-20 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2800: --- Status: Reopened (was: Closed) > Update outdated dependencies >

[jira] [Updated] (KAFKA-2159) offsets.topic.segment.bytes and offsets.topic.retention.minutes are ignored

2016-05-17 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2159: --- Resolution: Duplicate Status: Resolved (was: Patch Available) >

[jira] [Closed] (KAFKA-665) Outgoing responses delayed on a busy Kafka broker

2016-05-14 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy closed KAFKA-665. - > Outgoing responses delayed on a busy Kafka broker >

[jira] [Resolved] (KAFKA-1201) offset in LogCleaner.awaitCleaned is not enforced

2016-05-13 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-1201. Resolution: Duplicate Assignee: (was: Jay Kreps) Fix Version/s: 0.9.0.0

[jira] [Assigned] (KAFKA-3389) ReplicaStateMachine areAllReplicasForTopicDeleted check not handling well case when there are no replicas for topic

2016-05-13 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy reassigned KAFKA-3389: -- Assignee: Manikumar Reddy (was: Neha Narkhede) > ReplicaStateMachine

[jira] [Commented] (KAFKA-3389) ReplicaStateMachine areAllReplicasForTopicDeleted check not handling well case when there are no replicas for topic

2016-05-13 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15282496#comment-15282496 ] Manikumar Reddy commented on KAFKA-3389: Scala map.forall(predicate) returns true for empty map.

[jira] [Resolved] (KAFKA-2868) retry.backoff.ms ignored by Producer

2016-05-12 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-2868. Resolution: Duplicate This was fixed in KAFKA-2138 > retry.backoff.ms ignored by Producer

[jira] [Resolved] (KAFKA-3593) kafka.network.Processor throws ArrayIndexOutOfBoundsException

2016-05-11 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-3593. Resolution: Duplicate > kafka.network.Processor throws ArrayIndexOutOfBoundsException >

[jira] [Updated] (KAFKA-3584) NullPointer Exception found when Delete Topic and Log delete concurrent

2016-05-11 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3584: --- Status: Patch Available (was: Open) > NullPointer Exception found when Delete Topic and Log

[jira] [Commented] (KAFKA-3525) max.reserved.broker.id off-by-one error

2016-05-05 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15272275#comment-15272275 ] Manikumar Reddy commented on KAFKA-3525: 1. Assume reserved.broker.max.id =1000 2. Configure

[jira] [Commented] (KAFKA-3147) Memory records is not writable in MirrorMaker

2016-05-04 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270385#comment-15270385 ] Manikumar Reddy commented on KAFKA-3147: Similar exception scenario is fixed in KAFKA-3594. Above

[jira] [Updated] (KAFKA-2651) Remove deprecated config alteration from TopicCommand in 0.9.1.0

2016-04-28 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2651: --- Assignee: Manikumar Reddy Status: Patch Available (was: Open) > Remove deprecated

[jira] [Commented] (KAFKA-3587) LogCleaner fails due to incorrect offset map computation on a replica

2016-04-28 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15261630#comment-15261630 ] Manikumar Reddy commented on KAFKA-3587: [~ecomar] your alternative approach looks good. I haven't

[jira] [Updated] (KAFKA-3629) KStreamImpl.to(...) throws NPE when the value SerDe is null

2016-04-27 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3629: --- Status: Patch Available (was: Open) > KStreamImpl.to(...) throws NPE when the value SerDe is

[jira] [Commented] (KAFKA-3609) Implement partial mirroring functionality in Kafka Mirror Maker

2016-04-22 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253761#comment-15253761 ] Manikumar Reddy commented on KAFKA-3609: Current Mirror Maker supports partial mirroring of topics

[jira] [Updated] (KAFKA-3517) Document configuration of SASL/PLAIN and multiple mechanisms

2016-04-22 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3517: --- Status: Patch Available (was: Open) > Document configuration of SASL/PLAIN and multiple

[jira] [Updated] (KAFKA-3605) Connector REST endpoint allows incorrectly overriding the connector name

2016-04-22 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3605: --- Status: Patch Available (was: Reopened) > Connector REST endpoint allows incorrectly

[jira] [Assigned] (KAFKA-3584) NullPointer Exception found when Delete Topic and Log delete concurrent

2016-04-22 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy reassigned KAFKA-3584: -- Assignee: Manikumar Reddy (was: Jay Kreps) > NullPointer Exception found when Delete

[jira] [Assigned] (KAFKA-3587) LogCleaner fails due to incorrect offset map computation on a replica

2016-04-22 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy reassigned KAFKA-3587: -- Assignee: Manikumar Reddy > LogCleaner fails due to incorrect offset map computation

[jira] [Updated] (KAFKA-3602) Rename RecordAccumulator dequeFor() and ensure proper usage

2016-04-22 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3602: --- Status: Patch Available (was: Open) > Rename RecordAccumulator dequeFor() and ensure proper

[jira] [Updated] (KAFKA-3594) Kafka new producer retries doesn't work in 0.9.0.1

2016-04-21 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3594: --- Status: Patch Available (was: Open) > Kafka new producer retries doesn't work in 0.9.0.1 >

[jira] [Comment Edited] (KAFKA-3594) Kafka new producer retries doesn't work in 0.9.0.1

2016-04-21 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15251692#comment-15251692 ] Manikumar Reddy edited comment on KAFKA-3594 at 4/21/16 10:43 AM: -- Thanks

[jira] [Updated] (KAFKA-3594) Kafka new producer retries doesn't work in 0.9.0.1

2016-04-21 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3594: --- Assignee: Manikumar Reddy (was: Jun Rao) Priority: Critical (was: Major)

[jira] [Resolved] (KAFKA-3572) Metrics of topics still exist when they have been deleted

2016-04-20 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-3572. Resolution: Duplicate This issue is fixed in KAFKA-1866 and similar issue is getting fixed

[jira] [Resolved] (KAFKA-3326) Error: A JNI error has occurred, please check your installation and try again

2016-04-20 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-3326. Resolution: Not A Problem > Error: A JNI error has occurred, please check your installation

[jira] [Resolved] (KAFKA-2524) Examples in class javadoc use unimplemented subscribe method

2016-04-19 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-2524. Resolution: Fixed Fix Version/s: 0.10.0.0 > Examples in class javadoc use

[jira] [Resolved] (KAFKA-2912) Add error code 4 (InvalidFetchSize) to Errors.java

2016-04-19 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-2912. Resolution: Fixed Assignee: Grant Henke (was: jin xing) Fix Version/s:

[jira] [Updated] (KAFKA-3580) improve error logging in ReplicaFetchThread with oversized message

2016-04-18 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3580: --- Labels: (was: label) Assignee: Manikumar Reddy Status: Patch Available (was:

[jira] [Updated] (KAFKA-2955) Add Prompt to kafka-console-producer

2016-04-18 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2955: --- Assignee: Manikumar Reddy (was: Jun Rao) Fix Version/s: 0.10.0.0 Status:

[jira] [Commented] (KAFKA-3391) Kafka to ZK timeout

2016-04-18 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245402#comment-15245402 ] Manikumar Reddy commented on KAFKA-3391: increasing ZK timeout may help. Kafka user mailing list

[jira] [Resolved] (KAFKA-2416) misleading kafka-console-consumer.sh --property option

2016-04-18 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-2416. Resolution: Fixed Assignee: (was: Sreepathi Prasanna) This got fixed in

[jira] [Resolved] (KAFKA-2157) kafka-console-consumer.sh: Mismatch in CLI "usage" docs vs. Scala Option parsing

2016-04-18 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-2157. Resolution: Fixed Assignee: Manikumar Reddy Fix Version/s: 0.10.0.0 This is

[jira] [Resolved] (KAFKA-361) Add ability to get offsets from ZK-based consumer

2016-04-18 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-361. --- Resolution: Fixed > Add ability to get offsets from ZK-based consumer >

[jira] [Resolved] (KAFKA-364) Consumer re-design

2016-04-18 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-364. --- Resolution: Fixed > Consumer re-design > -- > > Key: KAFKA-364

  1   2   3   4   5   6   >