[jira] [Commented] (KAFKA-6022) mirror maker stores offset in zookeeper

2017-10-10 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198271#comment-16198271 ] Manikumar commented on KAFKA-6022: -- looks like you are using old consumer API on mirror maker. By

[jira] [Commented] (KAFKA-6005) Reject JoinGroup request from first member with empty protocol type/protocol list

2017-10-03 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16189475#comment-16189475 ] Manikumar commented on KAFKA-6005: -- PR: https://github.com/apache/kafka/pull/3957 > Reject JoinGroup

[jira] [Created] (KAFKA-6005) Reject JoinGroup request from first member with empty protocol type/protocol list

2017-10-03 Thread Manikumar (JIRA)
Manikumar created KAFKA-6005: Summary: Reject JoinGroup request from first member with empty protocol type/protocol list Key: KAFKA-6005 URL: https://issues.apache.org/jira/browse/KAFKA-6005 Project:

[jira] [Comment Edited] (KAFKA-5734) Heap (Old generation space) gradually increase

2017-10-01 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16187287#comment-16187287 ] Manikumar edited comment on KAFKA-5734 at 10/1/17 6:02 AM: --- [~jangbora] looking

[jira] [Commented] (KAFKA-5997) acks=all does not seem to be honoured

2017-09-30 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16186974#comment-16186974 ] Manikumar commented on KAFKA-5997: -- We need to use min.insync.replicas to enforce durability guarantees.

[jira] [Commented] (KAFKA-4712) kafka-reassign-partitions causes ISR to shrink

2017-09-29 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185754#comment-16185754 ] Manikumar commented on KAFKA-4712: -- This can be related to KAFKA-5758 > kafka-reassign-partitions causes

[jira] [Resolved] (KAFKA-5369) Producer hangs on metadata fetch from broker in security authorization related failures and no meaningful exception is thrown

2017-09-27 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5369. -- Resolution: Duplicate Resolving this as duplicate of KAFKA-4764, KAFKA-5920 > Producer hangs on

[jira] [Assigned] (KAFKA-4914) Partition re-assignment tool should check types before persisting state in ZooKeeper

2017-09-27 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-4914: Assignee: (was: Manikumar) > Partition re-assignment tool should check types before persisting

[jira] [Assigned] (KAFKA-4914) Partition re-assignment tool should check types before persisting state in ZooKeeper

2017-09-27 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-4914: Assignee: Manikumar > Partition re-assignment tool should check types before persisting state in

[jira] [Updated] (KAFKA-4914) Partition re-assignment tool should check types before persisting state in ZooKeeper

2017-09-27 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-4914: - Priority: Major (was: Minor) > Partition re-assignment tool should check types before persisting state

[jira] [Commented] (KAFKA-5982) Kafka 0.9.0.1 doesn't start after delete storage dir

2017-09-27 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182969#comment-16182969 ] Manikumar commented on KAFKA-5982: -- Please check KAFKA-5917 > Kafka 0.9.0.1 doesn't start after delete

[jira] [Resolved] (KAFKA-5015) SASL/SCRAM authentication failures are hidden

2017-09-22 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5015. -- Resolution: Duplicate Resolving as duplicate of KAFKA-4764 > SASL/SCRAM authentication failures are

[jira] [Resolved] (KAFKA-5910) Kafka 0.11.0.1 Kafka consumer/producers retries in infinite loop when wrong SASL creds are passed

2017-09-22 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5910. -- Resolution: Duplicate Resolving as duplicate of KAFKA-4764 > Kafka 0.11.0.1 Kafka consumer/producers

[jira] [Resolved] (KAFKA-5917) Kafka not starting

2017-09-18 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5917. -- Resolution: Won't Fix These kinds of issues can be avoided once we completely move Kafka tools to Java

[jira] [Comment Edited] (KAFKA-5917) Kafka not starting

2017-09-18 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16169714#comment-16169714 ] Manikumar edited comment on KAFKA-5917 at 9/18/17 7:56 AM: --- This happens when

[jira] [Commented] (KAFKA-5917) Kafka not starting

2017-09-18 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16169714#comment-16169714 ] Manikumar commented on KAFKA-5917: -- This happens when you run Kafka-configs.sh script with new versions

[jira] [Commented] (KAFKA-5407) Mirrormaker dont start after upgrade

2017-09-16 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16168830#comment-16168830 ] Manikumar commented on KAFKA-5407: -- from broker logs: {code} [2017-09-14 15:16:56,688] ERROR [Group

[jira] [Commented] (KAFKA-3722) PlaintextChannelBuilder should not use ChannelBuilders.createPrincipalBuilder(configs) for creating instance of PrincipalBuilder

2017-09-15 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16167717#comment-16167717 ] Manikumar commented on KAFKA-3722: -- [~mgharat] I think KIP-189/KAFKA-5783 addresses this issue. If you

[jira] [Resolved] (KAFKA-4454) Authorizer should also include the Principal generated by the PrincipalBuilder.

2017-09-15 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4454. -- Resolution: Fixed This is covered in KIP-189/KAFKA-5783 > Authorizer should also include the Principal

[jira] [Commented] (KAFKA-5407) Mirrormaker dont start after upgrade

2017-09-14 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16167363#comment-16167363 ] Manikumar commented on KAFKA-5407: -- [~fvegaucr] Can you upload broker logs at the time of error? >

[jira] [Updated] (KAFKA-5750) Elevate log messages for denials to INFO in SimpleAclAuthorizer class

2017-09-14 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-5750: - Summary: Elevate log messages for denials to INFO in SimpleAclAuthorizer class (was: Elevate log

[jira] [Resolved] (KAFKA-3124) Update protocol wiki page to reflect latest request/response formats

2017-09-13 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3124. -- Resolution: Fixed KAFKA-3361 added support for generating protocol documentation page to Kafka docs.

[jira] [Resolved] (KAFKA-5177) Automatic creation of topic prompts warnings into console

2017-09-13 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5177. -- Resolution: Won't Fix As mentioned above, these are transient warning messages. Please reopen if you

[jira] [Resolved] (KAFKA-2887) TopicMetadataRequest creates topic if it does not exist

2017-09-12 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2887. -- Resolution: Fixed > TopicMetadataRequest creates topic if it does not exist >

[jira] [Resolved] (KAFKA-1834) No Response when handle LeaderAndIsrRequest some case

2017-09-12 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1834. -- Resolution: Fixed This was fixed in newer Kafka versions. > No Response when handle

[jira] [Resolved] (KAFKA-1630) ConsumerFetcherThread locked in Tomcat

2017-09-12 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1630. -- Resolution: Cannot Reproduce Closing inactive issue. Please reopen if you think the issue still exists

[jira] [Commented] (KAFKA-2887) TopicMetadataRequest creates topic if it does not exist

2017-09-12 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16162853#comment-16162853 ] Manikumar commented on KAFKA-2887: -- As of 0.11.0.0, We added a "allow_auto_topic_creation" flag to the

[jira] [Commented] (KAFKA-1921) Delete offsets for a group with kafka offset storage

2017-09-12 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16162803#comment-16162803 ] Manikumar commented on KAFKA-1921: -- [~onurkaraman] Now we have a command-line tool to reset Consumer

[jira] [Resolved] (KAFKA-2319) After controlled shutdown: IllegalStateException: Kafka scheduler has not been started

2017-09-08 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2319. -- Resolution: Fixed This was fixed in newer versions. Pl reopen if you think the issue still exists >

[jira] [Resolved] (KAFKA-1817) AdminUtils.createTopic vs kafka-topics.sh --create with partitions

2017-09-08 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1817. -- Resolution: Fixed Fixed in KAFKA-1737 > AdminUtils.createTopic vs kafka-topics.sh --create with

[jira] [Resolved] (KAFKA-1608) Windows: Error: Could not find or load main class org.apache.zookeeper.server.quorum.QuorumPeerMain

2017-09-08 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1608. -- Resolution: Fixed This was fixed in newer versions. Pl reopen if you think the issue still exists >

[jira] [Resolved] (KAFKA-251) The ConsumerStats MBean's PartOwnerStats attribute is a string

2017-09-08 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-251. - Resolution: Won't Fix Closing inactive issue as per above comments. > The ConsumerStats MBean's

[jira] [Commented] (KAFKA-5855) records-lag is always zero

2017-09-08 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16158559#comment-16158559 ] Manikumar commented on KAFKA-5855: -- I am able to generate some lag. By default, consumer reads from

[jira] [Resolved] (KAFKA-5592) Connection with plain client to SSL-secured broker causes OOM

2017-09-08 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5592. -- Resolution: Duplicate Marking this as duplicate of KAFKA-4493. > Connection with plain client to

[jira] [Resolved] (KAFKA-4638) Outdated and misleading link in section "End-to-end Batch Compression"

2017-09-08 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4638. -- Resolution: Duplicate Resolving as duplicate of KAFKA-5686. PR Raised for KAFKA-5686 > Outdated and

[jira] [Commented] (KAFKA-5850) Py4JJavaError: An error occurred while calling o40.loadClass. : java.lang.ClassNotFoundException: org.apache.spark.streaming.kafka.KafkaUtilsPythonHelper

2017-09-08 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16158405#comment-16158405 ] Manikumar commented on KAFKA-5850: -- [~saurabhbidwai] This issue is not related to Kafka. You may want to

[jira] [Resolved] (KAFKA-3033) Reassigning partition stuck in progress

2017-09-07 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3033. -- Resolution: Duplicate Resolving this as a duplicate of KAFKA-4914. > Reassigning partition stuck in

[jira] [Resolved] (KAFKA-4190) kafka-reassign-partitions does not report syntax problem in json

2017-09-07 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4190. -- Resolution: Duplicate Resolving this duplicated KAFKA-4914. KAFKA-4914 PR is being reviewed now. >

[jira] [Resolved] (KAFKA-4119) Get topic offset with Kafka SSL

2017-09-07 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4119. -- Resolution: Cannot Reproduce Please reopen if the issue still exists. > Get topic offset with Kafka

[jira] [Resolved] (KAFKA-4020) Kafka consumer stop taking messages from kafka server

2017-09-07 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4020. -- Resolution: Fixed Please reopen if the issue still exists. > Kafka consumer stop taking messages

[jira] [Resolved] (KAFKA-1993) Enable topic deletion as default

2017-09-07 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1993. -- Resolution: Fixed Resolving this as duplicate of KAFKA-5384 > Enable topic deletion as default >

[jira] [Resolved] (KAFKA-3113) Kafka simple consumer inconsistent result

2017-09-07 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3113. -- Resolution: Cannot Reproduce may be seed broker is different for different topics. simpleconsumer

[jira] [Resolved] (KAFKA-2022) simpleconsumer.fetch(req) throws a java.nio.channels.ClosedChannelException: null exception when the original leader fails instead of being trapped in the fetchResponse

2017-09-07 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2022. -- Resolution: Won't Fix I think we need to catch the exception and retry with a new leader. Pl reopen

[jira] [Resolved] (KAFKA-2623) Kakfa broker not deleting logs after configured retention time properly

2017-09-07 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2623. -- Resolution: Fixed Time-based log retention is enforced in KIP-33. Pl reopen if you think the issue

[jira] [Comment Edited] (KAFKA-1455) Expose ConsumerOffsetChecker as an api instead of being command line only

2017-09-07 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157395#comment-16157395 ] Manikumar edited comment on KAFKA-1455 at 9/7/17 7:22 PM: -- listGroupOffsets

[jira] [Comment Edited] (KAFKA-1455) Expose ConsumerOffsetChecker as an api instead of being command line only

2017-09-07 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157395#comment-16157395 ] Manikumar edited comment on KAFKA-1455 at 9/7/17 7:01 PM: -- This is has been added

[jira] [Resolved] (KAFKA-2166) Recreation breaks topic-list

2017-09-07 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2166. -- Resolution: Fixed Deletion related issues are fixed in newer versions. Pl reopen if you think the

[jira] [Resolved] (KAFKA-1563) High packet rate between brokers in kafka cluster.

2017-09-07 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1563. -- Resolution: Cannot Reproduce Pl reopen if you think the issue still exists > High packet rate

[jira] [Resolved] (KAFKA-47) Create topic support and new ZK data structures for intra-cluster replication

2017-09-07 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-47?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-47. Resolution: Fixed Closing this umbrella JIRA as all tasks are resolved. > Create topic support and new ZK

[jira] [Resolved] (KAFKA-641) ConsumerOffsetChecker breaks when using dns names x.b.com as opposed to raw public IP for broker.

2017-09-07 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-641. - Resolution: Fixed This is not relevant in newer versions. > ConsumerOffsetChecker breaks when using dns

[jira] [Resolved] (KAFKA-252) Generalize getOffsetsBefore API to a new more general API getLeaderMetadata

2017-09-07 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-252. - Resolution: Fixed These API were handled in newer versions. > Generalize getOffsetsBefore API to a new

[jira] [Resolved] (KAFKA-986) Topic Consumption Across multiple instances of consumer groups

2017-09-07 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-986. - Resolution: Cannot Reproduce > Topic Consumption Across multiple instances of consumer groups >

[jira] [Resolved] (KAFKA-1093) Log.getOffsetsBefore(t, …) does not return the last confirmed offset before t

2017-09-07 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1093. -- Resolution: Invalid relavent part of the code is not available now. So closing this now. >

[jira] [Resolved] (KAFKA-1197) Count of bytes or messages of a topic stored in kafka

2017-09-07 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1197. -- Resolution: Fixed Size, LogStartOffset, LogEndOffset are exposed as metrics in newer verions. > Count

[jira] [Resolved] (KAFKA-805) log.append() may fail with a compressed messageset containing no uncompressed messages

2017-09-05 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-805. - Resolution: Fixed Not able to reproduce the issue. looks like this got fixed in newer versions. >

[jira] [Resolved] (KAFKA-1946) Fix various broker metrics

2017-09-04 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1946. -- Resolution: Fixed > Fix various broker metrics > -- > > Key:

[jira] [Resolved] (KAFKA-1962) Restore delayed request metrics

2017-09-04 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1962. -- Resolution: Fixed > Restore delayed request metrics > --- > >

[jira] [Resolved] (KAFKA-1505) Broker failed to start because of corrupted replication-offset-checkpoint file

2017-09-04 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1505. -- Resolution: Fixed This was fixed in newer versions. Pl reopen if you think the issue still exists >

[jira] [Resolved] (KAFKA-3059) ConsumerGroupCommand should allow resetting offsets for consumer groups

2017-09-04 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3059. -- Resolution: Duplicate This functionality is implemented in KAFKA-4743 > ConsumerGroupCommand should

[jira] [Resolved] (KAFKA-4264) kafka-server-stop.sh fails is Kafka launched via kafka-server-start.sh

2017-09-01 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4264. -- Resolution: Duplicate This is related to KAFKA-4931. PR is available for KAFKA-4931. >

[jira] [Resolved] (KAFKA-4337) Create topic in multiple zookeepers with Kafka AdminUtils.CreateTopic JAVA API in Kafka 0.9.0.1 gives Error (Topic gets created in only one of the specified zookeeper)

2017-09-01 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4337. -- Resolution: Won't Fix > Create topic in multiple zookeepers with Kafka AdminUtils.CreateTopic JAVA >

[jira] [Commented] (KAFKA-4337) Create topic in multiple zookeepers with Kafka AdminUtils.CreateTopic JAVA API in Kafka 0.9.0.1 gives Error (Topic gets created in only one of the specified zookeeper)

2017-09-01 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16150144#comment-16150144 ] Manikumar commented on KAFKA-4337: -- As mentioned by [~ijuma], create command creates a topic using ZK

[jira] [Resolved] (KAFKA-4411) broker don't have access to kafka zookeeper nodes

2017-09-01 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4411. -- Resolution: Not A Problem It is necessary to have the same principal name across all brokers for ZK

[jira] [Resolved] (KAFKA-4188) compilation issues with org.apache.kafka.clients.consumer.internals.Fetcher.java

2017-08-31 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4188. -- Resolution: Cannot Reproduce Pl reopen if you think the issue still exists > compilation issues with

[jira] [Resolved] (KAFKA-3647) Unable to set a ssl provider

2017-08-31 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3647. -- Resolution: Fixed Closing as per above comments. > Unable to set a ssl provider >

[jira] [Resolved] (KAFKA-3079) org.apache.kafka.common.KafkaException: java.lang.SecurityException: Configuration Error:

2017-08-31 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3079. -- Resolution: Cannot Reproduce Mostly related to config error. Pl reopen if you think the issue still

[jira] [Resolved] (KAFKA-2986) Consumer group doesn't lend itself well for slow consumers with varying message size

2017-08-31 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2986. -- Resolution: Fixed Fixed in newer versions. Pl reopen if you think the issue still exists > Consumer

[jira] [Resolved] (KAFKA-2897) Class NIOServerCnxn$Factory not found due to mismatch in dependencies

2017-08-31 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2897. -- Resolution: Won't Fix Closing inactive issue. Pl reopen if you think the issue still exists > Class

[jira] [Resolved] (KAFKA-2842) BrokerEndPoint regex does't support hostname with _

2017-08-31 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2842. -- Resolution: Fixed This was fixed in KAFKA-3719 > BrokerEndPoint regex does't support hostname with _ >

[jira] [Resolved] (KAFKA-2343) Clarify KafkaConsumer.poll rebalance behavior

2017-08-31 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2343. -- Resolution: Fixed Javadocs updated in newer versions. > Clarify KafkaConsumer.poll rebalance behavior

[jira] [Resolved] (KAFKA-1138) Remote producer uses the hostname defined in broker

2017-08-31 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1138. -- Resolution: Fixed > Remote producer uses the hostname defined in broker >

[jira] [Resolved] (KAFKA-1920) Add a metric to count client side errors in BrokerTopicMetrics

2017-08-31 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1920. -- Resolution: Duplicate Similar metrics are proposed in KAFKA-5746. > Add a metric to count client side

[jira] [Resolved] (KAFKA-1402) Create unit test helper that stops and starts a cluster

2017-08-31 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1402. -- Resolution: Fixed We have KafkaServerTestHarness, EmbeddedKafkaCluster, EmbeddedZookeeper helper

[jira] [Resolved] (KAFKA-1447) Controlled shutdown deadlock when trying to send state updates

2017-08-31 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1447. -- Resolution: Fixed Pl reopen if you think the issue still exists > Controlled shutdown deadlock when

[jira] [Resolved] (KAFKA-818) Request failure metrics on the Kafka brokers is not instrumented for all requests

2017-08-31 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-818. - Resolution: Duplicate Similar metrics are proposed in KAFKA-5746. > Request failure metrics on the Kafka

[jira] [Resolved] (KAFKA-1347) Create a system test for network partitions

2017-08-31 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1347. -- Resolution: Duplicate This is being fixed in KAFKA-5476. > Create a system test for network partitions

[jira] [Resolved] (KAFKA-4520) Kafka broker fails with not so user-friendly error msg when log.dirs is not set

2017-08-30 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4520. -- Resolution: Fixed Fix Version/s: 0.11.0.0 > Kafka broker fails with not so user-friendly error

[jira] [Resolved] (KAFKA-270) sync producer / consumer test producing lot of kafka server exceptions & not getting the throughput mentioned here http://incubator.apache.org/kafka/performance.html

2017-08-30 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-270. - Resolution: Won't Fix Closing due to inactivity. Pl reopen if you think the issue still exists > sync

[jira] [Resolved] (KAFKA-1492) Getting error when sending producer request at the broker end with a single broker

2017-08-30 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1492. -- Resolution: Cannot Reproduce Pl reopen if you think the issue still exists > Getting error when

[jira] [Resolved] (KAFKA-1632) No such method error on KafkaStream.head

2017-08-30 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1632. -- Resolution: Cannot Reproduce Mostly related to Kafka version mismatch. Pl reopen if you think the

[jira] [Resolved] (KAFKA-1463) producer fails with scala.tuple error

2017-08-30 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1463. -- Resolution: Won't Fix Pl reopen if you think the issue still exists > producer fails with

[jira] [Resolved] (KAFKA-888) problems when shutting down the java consumer .

2017-08-30 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-888. - Resolution: Cannot Reproduce Pl reopen if you think the issue still exists > problems when shutting

[jira] [Resolved] (KAFKA-1980) Console consumer throws OutOfMemoryError with large max-messages

2017-08-30 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1980. -- Resolution: Won't Fix [~ndimiduk] Agree. Updated the JIRA. > Console consumer throws OutOfMemoryError

[jira] [Reopened] (KAFKA-1980) Console consumer throws OutOfMemoryError with large max-messages

2017-08-30 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reopened KAFKA-1980: -- > Console consumer throws OutOfMemoryError with large max-messages >

[jira] [Commented] (KAFKA-1980) Console consumer throws OutOfMemoryError with large max-messages

2017-08-30 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147595#comment-16147595 ] Manikumar commented on KAFKA-1980: -- [~ndimiduk] Apologies for not giving a proper explanation.

[jira] [Resolved] (KAFKA-4297) Cannot Stop Kafka with Shell Script

2017-08-30 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4297. -- Resolution: Duplicate Closing this as there is a latest PR for KAFKA-4931. > Cannot Stop Kafka with

[jira] [Resolved] (KAFKA-3570) It'd be nice to line up display output in columns in ConsumerGroupCommand

2017-08-29 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3570. -- Resolution: Fixed > It'd be nice to line up display output in columns in ConsumerGroupCommand >

[jira] [Resolved] (KAFKA-1980) Console consumer throws OutOfMemoryError with large max-messages

2017-08-29 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1980. -- Resolution: Fixed Closing as per comments. Pl reopen if you think the issue still exists > Console

[jira] [Resolved] (KAFKA-1675) bootstrapping tidy-up

2017-08-29 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1675. -- Resolution: Fixed gradlew, gradlew.bat scripts are removed from repo. Pl reopen if you think the

[jira] [Resolved] (KAFKA-2173) Kafka died after throw more error

2017-08-29 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2173. -- Resolution: Cannot Reproduce Might have fixed in latest versions. Pl reopen if you think the issue

[jira] [Resolved] (KAFKA-1636) High CPU in very active environment

2017-08-29 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1636. -- Resolution: Won't Fix ConsumerIterator waits for the data from the underlying stream. Pl reopen if you

[jira] [Updated] (KAFKA-4391) On Windows, Kafka server stops with uncaught exception after coming back from sleep

2017-08-29 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-4391: - Labels: windows (was: ) > On Windows, Kafka server stops with uncaught exception after coming back from

[jira] [Resolved] (KAFKA-4634) Issue of one kafka brokers not listed in zookeeper

2017-08-29 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4634. -- Resolution: Fixed Similar issue fixed in KAFKA-1387/Newer versions. Pl reopen if you think the issue

[jira] [Updated] (KAFKA-4695) Can't start Kafka server after Blue Screen

2017-08-29 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-4695: - Labels: windows (was: ) > Can't start Kafka server after Blue Screen >

[jira] [Commented] (KAFKA-5649) Producer is being closed generating ssl exception

2017-08-29 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16145032#comment-16145032 ] Manikumar commented on KAFKA-5649: -- Can you enable Kafka debug logs and SSL debugs logs

[jira] [Updated] (KAFKA-5764) KafkaShortnamer should allow for case-insensitive matches

2017-08-29 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-5764: - Summary: KafkaShortnamer should allow for case-insensitive matches (was: KafkaShortnamer should allow

[jira] [Assigned] (KAFKA-5764) KafkaShortnamer should allow for case-insensitive matches

2017-08-29 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-5764: Assignee: Manikumar > KafkaShortnamer should allow for case-insensitive matches >

[jira] [Resolved] (KAFKA-4869) 0.10.2.0 release notes incorrectly include KIP-115

2017-08-25 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4869. -- Resolution: Fixed Assignee: Manikumar > 0.10.2.0 release notes incorrectly include KIP-115 >

[jira] [Resolved] (KAFKA-4350) Can't mirror from Kafka 0.9 to Kafka 0.10.1

2017-08-24 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4350. -- Resolution: Won't Fix Closing as per comments. > Can't mirror from Kafka 0.9 to Kafka 0.10.1 >

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

2017-08-24 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4109. -- Resolution: Cannot Reproduce Pl reopen if you think the issue still exists > kafka client send msg

<    4   5   6   7   8   9   10   >