[jira] [Comment Edited] (KAFKA-7154) Apache kafka getting shut down everytime it is started

[ https://issues.apache.org/jira/browse/KAFKA-7154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16541672#comment-16541672 ] Manikumar edited comment on KAFKA-7154 at 7/12/18 1:48 PM: --- loo

[jira] [Resolved] (KAFKA-3571) Traits for utilities like ConsumerGroupCommand

[ https://issues.apache.org/jira/browse/KAFKA-3571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3571. -- Resolution: Won't Fix Now AdminClient has support for most of the admin API. This can be used for test

[jira] [Resolved] (KAFKA-7123) Documentation: broken link http://confluent.io/docs/current/kafka-rest/docs/intro.html

[ https://issues.apache.org/jira/browse/KAFKA-7123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7123. -- Resolution: Fixed > Documentation: broken link > http://confluent.io/docs/current/kafka-rest/docs/intr

[jira] [Commented] (KAFKA-7124) Number of AnyLogDir should match the length of the replicas list

[ https://issues.apache.org/jira/browse/KAFKA-7124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529073#comment-16529073 ] Manikumar commented on KAFKA-7124: -- There is no issue with code. mentioned code generate

[jira] [Resolved] (KAFKA-4122) Consumer startup swallows DNS resolution exception and infinitely retries

[ https://issues.apache.org/jira/browse/KAFKA-4122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4122. -- Resolution: Duplicate Fixed under KAFKA-7111. > Consumer startup swallows DNS resolution exception and

[jira] [Created] (KAFKA-7117) Allow AclCommand to use AdminClient API

Manikumar created KAFKA-7117: Summary: Allow AclCommand to use AdminClient API Key: KAFKA-7117 URL: https://issues.apache.org/jira/browse/KAFKA-7117 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-7090) Zookeeper client setting in server-properties

[ https://issues.apache.org/jira/browse/KAFKA-7090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16526390#comment-16526390 ] Manikumar commented on KAFKA-7090: -- Kafka still uses Zookeeper 3.4 client dependency. Cu

[jira] [Commented] (KAFKA-7034) Remove the duplicated listTopics from Consumer

[ https://issues.apache.org/jira/browse/KAFKA-7034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16526215#comment-16526215 ] Manikumar commented on KAFKA-7034: -- AdminClient.listTopics() gives the topic names and C

[jira] [Resolved] (KAFKA-7099) KafkaLog4jAppender - not sending any message with level DEBUG

[ https://issues.apache.org/jira/browse/KAFKA-7099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7099. -- Resolution: Duplicate Resolving this as duplicate of  KAFKA-6415.  Please post your observation/ssolut

[jira] [Comment Edited] (KAFKA-7099) KafkaLog4jAppender - not sending any message with level DEBUG

[ https://issues.apache.org/jira/browse/KAFKA-7099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16526195#comment-16526195 ] Manikumar edited comment on KAFKA-7099 at 6/28/18 10:29 AM: R

[jira] [Updated] (KAFKA-7091) AdminClient should handle FindCoordinatorResponse errors

[ https://issues.apache.org/jira/browse/KAFKA-7091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-7091: - Fix Version/s: (was: 2.0.0) 2.0.1 > AdminClient should handle FindCoordinatorRespo

[jira] [Commented] (KAFKA-7099) KafkaLog4jAppender - not sending any message with level DEBUG

[ https://issues.apache.org/jira/browse/KAFKA-7099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16523849#comment-16523849 ] Manikumar commented on KAFKA-7099: -- Existing issue:  KAFKA-6415. This temporarily handle

[jira] [Comment Edited] (KAFKA-7099) KafkaLog4jAppender - not sending any message with level DEBUG

[ https://issues.apache.org/jira/browse/KAFKA-7099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16523849#comment-16523849 ] Manikumar edited comment on KAFKA-7099 at 6/26/18 3:10 PM: --- Exi

[jira] [Resolved] (KAFKA-7100) kafka.tools.GetOffsetShell with enable Kerberos Security on Kafka1.0

[ https://issues.apache.org/jira/browse/KAFKA-7100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7100. -- Resolution: Duplicate This is being tracked in KAFKA-5235. > kafka.tools.GetOffsetShell with enable Ke

[jira] [Commented] (KAFKA-4513) Support migration of old consumers to new consumers without downtime

[ https://issues.apache.org/jira/browse/KAFKA-4513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16523625#comment-16523625 ] Manikumar commented on KAFKA-4513: -- [~ijuma] Can we close this JIRA? > Support migratio

[jira] [Comment Edited] (KAFKA-6211) PartitionAssignmentState is protected whereas KafkaConsumerGroupService.describeGroup() returns PartitionAssignmentState Object

[ https://issues.apache.org/jira/browse/KAFKA-6211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16523616#comment-16523616 ] Manikumar edited comment on KAFKA-6211 at 6/26/18 11:56 AM: C

[jira] [Commented] (KAFKA-6211) PartitionAssignmentState is protected whereas KafkaConsumerGroupService.describeGroup() returns PartitionAssignmentState Object

[ https://issues.apache.org/jira/browse/KAFKA-6211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16523616#comment-16523616 ] Manikumar commented on KAFKA-6211: -- ConsumerGroupCommand internal classes/methods are no

[jira] [Resolved] (KAFKA-5079) ProducerBounceTest fails occasionally with a SocketTimeoutException

[ https://issues.apache.org/jira/browse/KAFKA-5079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5079. -- Resolution: Fixed ProducerBounceTest is removed as part old consumer changes. > ProducerBounceTest fai

[jira] [Resolved] (KAFKA-5080) Convert ProducerBounceTest to use the new KafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-5080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5080. -- Resolution: Fixed ProducerBounceTest is removed as part of old consumer changes. > Convert ProducerBou

[jira] [Resolved] (KAFKA-2488) System tests: updated console_consumer.py to support new consumer

[ https://issues.apache.org/jira/browse/KAFKA-2488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2488. -- Resolution: Fixed Support was added in > 0.10.1 Kafka versions. > System tests: updated console_consum

[jira] [Resolved] (KAFKA-2215) Improve Randomness for ConsoleConsumer

[ https://issues.apache.org/jira/browse/KAFKA-2215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2215. -- Resolution: Not A Problem Closing inactive issue. Also the default for console consumer's enable.auto.

[jira] [Updated] (KAFKA-7091) AdminClient should handle FindCoordinatorResponse errors

[ https://issues.apache.org/jira/browse/KAFKA-7091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-7091: - Description: Currently KafkaAdminClient.deleteConsumerGroups, listConsumerGroupOffsets method implementat

[jira] [Updated] (KAFKA-7091) AdminClient should handle FindCoordinatorResponse errors

[ https://issues.apache.org/jira/browse/KAFKA-7091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-7091: - Description: Currently KafkaAdminClient.deleteConsumerGroups, listConsumerGroupOffsets method implementat

[jira] [Updated] (KAFKA-7091) AdminClient should handle FindCoordinatorResponse errors

[ https://issues.apache.org/jira/browse/KAFKA-7091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-7091: - Description: Currently KafkaAdminClient.deleteConsumerGroups, listConsumerGroupOffsets method implementat

[jira] [Created] (KAFKA-7091) AdminClient should handle FindCoordinatorResponse errors

Manikumar created KAFKA-7091: Summary: AdminClient should handle FindCoordinatorResponse errors Key: KAFKA-7091 URL: https://issues.apache.org/jira/browse/KAFKA-7091 Project: Kafka Issue Type: Im

[jira] [Commented] (KAFKA-7083) maxTickMessages in ConsumerGroup option

[ https://issues.apache.org/jira/browse/KAFKA-7083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16518999#comment-16518999 ] Manikumar commented on KAFKA-7083: -- looks like you are using Node.js Kafka client. Can y

[jira] [Comment Edited] (KAFKA-7081) Add describe all topics API to AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-7081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16518410#comment-16518410 ] Manikumar edited comment on KAFKA-7081 at 6/20/18 6:02 PM: --- [~i

[jira] [Commented] (KAFKA-7081) Add describe all topics API to AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-7081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16518410#comment-16518410 ] Manikumar commented on KAFKA-7081: -- [~ijuma]  [~cmccabe] Would like to get your opinion

[jira] [Updated] (KAFKA-7081) Add describe all topics API to AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-7081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-7081: - Description: Currently AdminClient supports describeTopics(Collection topicNames) method for topic descr

[jira] [Created] (KAFKA-7081) Add describe all topics API to AdminClient

Manikumar created KAFKA-7081: Summary: Add describe all topics API to AdminClient Key: KAFKA-7081 URL: https://issues.apache.org/jira/browse/KAFKA-7081 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-3018) Kafka producer hangs on producer.close() call if the producer topic contains single quotes in the topic name

[ https://issues.apache.org/jira/browse/KAFKA-3018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3018. -- Resolution: Duplicate Resolving this as duplicate of KAFKA-5098.  Please reopen if you think otherwise

[jira] [Commented] (KAFKA-6344) 0.8.2 clients will store invalid configuration in ZK for Kafka 1.0 brokers

[ https://issues.apache.org/jira/browse/KAFKA-6344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517430#comment-16517430 ] Manikumar commented on KAFKA-6344: -- This accidentally got fixed in 1.1.0. > 0.8.2 clien

[jira] [Commented] (KAFKA-6314) Add a tool to delete kafka based consumer offsets for a given group

[ https://issues.apache.org/jira/browse/KAFKA-6314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517410#comment-16517410 ] Manikumar commented on KAFKA-6314: -- "–delete" works with java consumer groups also. This

[jira] [Resolved] (KAFKA-6485) 'ConsumerGroupCommand' performance optimization for old consumer describe group

[ https://issues.apache.org/jira/browse/KAFKA-6485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6485. -- Resolution: Auto Closed The Scala consumers are deprecated. The old clients and related tools are remo

[jira] [Resolved] (KAFKA-6564) Fix broken links in Dockerfile

[ https://issues.apache.org/jira/browse/KAFKA-6564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6564. -- Resolution: Fixed Fix Version/s: 1.0.2 This will get fixed in upcoming 1.0.2 release. > Fix bro

[jira] [Resolved] (KAFKA-6737) Is Kafka imapcted by critical vulnerqbilty CVE-2018-7489

[ https://issues.apache.org/jira/browse/KAFKA-6737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6737. -- Resolution: Fixed Fix Version/s: 2.0.0 This will be fixed part of upcoming 2.00, 1.1.1, 1.0.2 re

[jira] [Resolved] (KAFKA-6934) Csv reporter doesn't work for ConsoleConsumer

[ https://issues.apache.org/jira/browse/KAFKA-6934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6934. -- Resolution: Won't Fix Csv reporter works with old consumer. Old consumer related options will be remov

[jira] [Resolved] (KAFKA-5348) kafka-consumer-groups.sh refuses to remove groups without ids

[ https://issues.apache.org/jira/browse/KAFKA-5348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5348. -- Resolution: Auto Closed {color:#00}The Scala consumers have been deprecated and will be removed in

[jira] [Resolved] (KAFKA-5237) SimpleConsumerShell logs terminating message to stdout instead of stderr

[ https://issues.apache.org/jira/browse/KAFKA-5237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5237. -- Resolution: Auto Closed Old consumer related tools are deprecated and  will be removed in KAFKA-2983.

[jira] [Resolved] (KAFKA-4870) A question about broker down , the server is doing partition master election,the client producer may send msg fail . How the producer deal with the situation ??

[ https://issues.apache.org/jira/browse/KAFKA-4870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4870. -- Resolution: Information Provided If the produce request fails, the producer automatically retry based o

[jira] [Resolved] (KAFKA-3791) Broken tools -- need better way to get offsets and other info

[ https://issues.apache.org/jira/browse/KAFKA-3791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3791. -- Resolution: Fixed kafka-consumer-offset-checker.sh tool has been removed. Use kafka-consumer-groups.sh

[jira] [Resolved] (KAFKA-4061) Apache Kafka failover is not working

[ https://issues.apache.org/jira/browse/KAFKA-4061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4061. -- Resolution: Cannot Reproduce This is mostly due to the health of the consumer offset topic.  replicatio

[jira] [Updated] (KAFKA-7063) Update documentation to remove references to old producers and consumers

[ https://issues.apache.org/jira/browse/KAFKA-7063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-7063: - Fix Version/s: 2.0.0 > Update documentation to remove references to old producers and consumers > ---

[jira] [Commented] (KAFKA-7065) Quickstart tutorial fails because of missing brokers

[ https://issues.apache.org/jira/browse/KAFKA-7065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514729#comment-16514729 ] Manikumar commented on KAFKA-7065: -- looks like you have not started kafka server.  > Qu

[jira] [Resolved] (KAFKA-5590) Delete Kafka Topic Complete Failed After Enable Ranger Kafka Plugin

[ https://issues.apache.org/jira/browse/KAFKA-5590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5590. -- Resolution: Information Provided {color:#00}Closing inactive issue. Please reopen if you think the

[jira] [Resolved] (KAFKA-5691) ZKUtils.CreateRecursive should handle NOAUTH

[ https://issues.apache.org/jira/browse/KAFKA-5691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5691. -- Resolution: Auto Closed Scala consumers and related tools/tests are removed in KAFKA-2983. This change

[jira] [Resolved] (KAFKA-5408) Using the ConsumerRecord instead of BaseConsumerRecord in the ConsoleConsumer

[ https://issues.apache.org/jira/browse/KAFKA-5408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5408. -- Resolution: Fixed This is taken care in KAFKA-2983 > Using the ConsumerRecord instead of BaseConsumerR

[jira] [Resolved] (KAFKA-4723) offsets.storage=kafka - groups stuck in rebalancing with committed offsets

[ https://issues.apache.org/jira/browse/KAFKA-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4723. -- Resolution: Auto Closed Closing inactive issue. The old consumer is no longer supported. Please upgrade

[jira] [Resolved] (KAFKA-4295) kafka-console-consumer.sh does not delete the temporary group in zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-4295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4295. -- Resolution: Auto Closed Closing inactive issue. The old consumer is no longer supported. > kafka-conso

[jira] [Resolved] (KAFKA-4196) Transient test failure: DeleteConsumerGroupTest.testConsumptionOnRecreatedTopicAfterTopicWideDeleteInZK

[ https://issues.apache.org/jira/browse/KAFKA-4196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4196. -- Resolution: Auto Closed Scala consumers and related tools/tests are removed in KAFKA-2983 > Transient

[jira] [Resolved] (KAFKA-3150) kafka.tools.UpdateOffsetsInZK not work (sasl enabled)

[ https://issues.apache.org/jira/browse/KAFKA-3150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3150. -- Resolution: Auto Closed The Scala consumers and related tools are removed in KAFKA-2983 > kafka.tools.

[jira] [Resolved] (KAFKA-3057) "Checking consumer position" docs are referencing (only) deprecated ConsumerOffsetChecker

[ https://issues.apache.org/jira/browse/KAFKA-3057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3057. -- Resolution: Fixed Closing this as docs updated for kafka-consumer-groups.sh.  documentation about  kafk

[jira] [Resolved] (KAFKA-2584) SecurityProtocol enum validation should be removed or relaxed for non-config usages

[ https://issues.apache.org/jira/browse/KAFKA-2584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2584. -- Resolution: Auto Closed Closing this as scala clients are deprecated and will be removed in 2.0.0 rele

[jira] [Resolved] (KAFKA-2537) Mirrormaker defaults to localhost with no sanity checks

[ https://issues.apache.org/jira/browse/KAFKA-2537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2537. -- Resolution: Auto Closed The old consumer is no longer supported. All the usages are removed in  KAFKA-2

[jira] [Resolved] (KAFKA-1942) ConsumerGroupCommand does not show offset information in ZK for deleted topic

[ https://issues.apache.org/jira/browse/KAFKA-1942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1942. -- Resolution: Auto Closed Closing as old consumer support is removed from ConsumerGroupCommand > Consume

[jira] [Resolved] (KAFKA-857) kafka.admin.ListTopicCommand, 'by broker' display/filter

[ https://issues.apache.org/jira/browse/KAFKA-857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-857. - Resolution: Auto Closed Closing inactive issue.  This functionality can be achived by using KafkaAdminCli

[jira] [Resolved] (KAFKA-796) Kafka Scala classes should declare thrown checked exceptions to be Java friendly

[ https://issues.apache.org/jira/browse/KAFKA-796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-796. - Resolution: Auto Closed Closing inactive issue. The scala clients are no longer supported. > Kafka Scala

[jira] [Assigned] (KAFKA-7063) Update documentation to remove references to old producers and consumers

[ https://issues.apache.org/jira/browse/KAFKA-7063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-7063: Assignee: Manikumar > Update documentation to remove references to old producers and consumers > -

[jira] [Resolved] (KAFKA-3798) Kafka Consumer 0.10.0.0 killed after rebalancing exception

[ https://issues.apache.org/jira/browse/KAFKA-3798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3798. -- Resolution: Auto Closed Closing inactive issue. The old consumer is no longer supported. Please upgrade

[jira] [Resolved] (KAFKA-4967) java.io.EOFException Error while committing offsets

[ https://issues.apache.org/jira/browse/KAFKA-4967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4967. -- Resolution: Auto Closed Closing inactive issue. The old consumer is no longer supported. Please upgrade

[jira] [Resolved] (KAFKA-966) Allow high level consumer to 'nak' a message and force Kafka to close the KafkaStream without losing that message

[ https://issues.apache.org/jira/browse/KAFKA-966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-966. - Resolution: Auto Closed Closing inactive issue. The old consumer is no longer supported.  > Allow high le

[jira] [Resolved] (KAFKA-2546) CPU utilization very high when no kafka node alive

[ https://issues.apache.org/jira/browse/KAFKA-2546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2546. -- Resolution: Auto Closed Closing inactive issue. The old consumer is no longer supported. Please upgrade

[jira] [Comment Edited] (KAFKA-1013) Modify existing tools as per the changes in KAFKA-1000

[ https://issues.apache.org/jira/browse/KAFKA-1013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513988#comment-16513988 ] Manikumar edited comment on KAFKA-1013 at 6/15/18 3:42 PM: --- Con

[jira] [Commented] (KAFKA-6982) java.lang.ArithmeticException: / by zero

[ https://issues.apache.org/jira/browse/KAFKA-6982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512824#comment-16512824 ] Manikumar commented on KAFKA-6982: -- This is a minor issue. Only occurs for a brief perio

[jira] [Updated] (KAFKA-6982) java.lang.ArithmeticException: / by zero

[ https://issues.apache.org/jira/browse/KAFKA-6982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-6982: - Fix Version/s: (was: 2.0.0) 1.1.1 java.lang.ArithmeticException was fixed in 1.1.1

[jira] [Resolved] (KAFKA-4812) We are facing the same issue as SAMZA-590 for kafka

[ https://issues.apache.org/jira/browse/KAFKA-4812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4812. -- Resolution: Auto Closed Closing inactive issue. The old consumer is no longer supported. Please upgrade

[jira] [Resolved] (KAFKA-2550) [Kafka][0.8.2.1][Performance]When there are a lot of partition under a Topic, there are serious performance degradation.

[ https://issues.apache.org/jira/browse/KAFKA-2550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2550. -- Resolution: Auto Closed {color:#00}Closing inactive issue. Old clients are deprecated. Please reop

[jira] [Resolved] (KAFKA-1181) Consolidate brokerList and topicPartitionInfo in BrokerPartitionInfo

[ https://issues.apache.org/jira/browse/KAFKA-1181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1181. -- Resolution: Auto Closed Closing this as BrokerPartitionInfo class removed in  KAFKA-6921 > Consolidate

[jira] [Resolved] (KAFKA-3379) Update tools relying on old producer to use new producer.

[ https://issues.apache.org/jira/browse/KAFKA-3379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3379. -- Resolution: Fixed Fix Version/s: 2.0.0 > Update tools relying on old producer to use new produce

[jira] [Resolved] (KAFKA-2572) zk connection instability

[ https://issues.apache.org/jira/browse/KAFKA-2572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2572. -- Resolution: Auto Closed Closing inactive issue. Please reopen if the issue still exists in newer versi

[jira] [Commented] (KAFKA-6801) Restrict Consumer to fetch data from secure port only, and deny from non-secure port.

[ https://issues.apache.org/jira/browse/KAFKA-6801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16509528#comment-16509528 ] Manikumar commented on KAFKA-6801: -- For PLAINTEXT connections, the principal will be ANO

[jira] [Assigned] (KAFKA-4690) IllegalStateException using DeleteTopicsRequest when delete.topic.enable=false

[ https://issues.apache.org/jira/browse/KAFKA-4690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-4690: Assignee: Manikumar > IllegalStateException using DeleteTopicsRequest when delete.topic.enable=fal

[jira] [Resolved] (KAFKA-6351) libs directory has duplicate javassist jars

[ https://issues.apache.org/jira/browse/KAFKA-6351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6351. -- Resolution: Fixed Fix Version/s: 2.0.0 Closing this as javassist jar is resolving to single vers

[jira] [Assigned] (KAFKA-7029) ReplicaVerificationTool should not use the deprecated SimpleConsumer

[ https://issues.apache.org/jira/browse/KAFKA-7029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-7029: Assignee: Manikumar > ReplicaVerificationTool should not use the deprecated SimpleConsumer > -

[jira] [Resolved] (KAFKA-2445) Failed test: kafka.producer.ProducerTest > testSendWithDeadBroker FAILED

[ https://issues.apache.org/jira/browse/KAFKA-2445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2445. -- Resolution: Auto Closed > Failed test: kafka.producer.ProducerTest > testSendWithDeadBroker FAILED > --

[jira] [Resolved] (KAFKA-6984) Question

[ https://issues.apache.org/jira/browse/KAFKA-6984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6984. -- Resolution: Information Provided Post these kind of queries to  [us...@kafka.apache.org|mailto:us...@ka

[jira] [Resolved] (KAFKA-6982) java.lang.ArithmeticException: / by zero

[ https://issues.apache.org/jira/browse/KAFKA-6982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6982. -- Resolution: Fixed Fix Version/s: 2.0.0 > java.lang.ArithmeticException: / by zero >

[jira] [Resolved] (KAFKA-6972) Kafka ACL does not work expected with wildcard

[ https://issues.apache.org/jira/browse/KAFKA-6972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6972. -- Resolution: Information Provided > Kafka ACL does not work expected with wildcard > ---

[jira] [Resolved] (KAFKA-5523) ReplayLogProducer not using the new Kafka consumer

[ https://issues.apache.org/jira/browse/KAFKA-5523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5523. -- Resolution: Fixed Assignee: Manikumar Fix Version/s: 2.0.0 > ReplayLogProducer not usin

[jira] [Resolved] (KAFKA-5940) kafka-delete-records.sh doesn't give any feedback when the JSON offset configuration file is invalid

[ https://issues.apache.org/jira/browse/KAFKA-5940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5940. -- Resolution: Fixed Fixed in KAFKA-5919 > kafka-delete-records.sh doesn't give any feedback when the JSO

[jira] [Commented] (KAFKA-6281) Kafka JavaAPI Producer failed with NotLeaderForPartitionException

[ https://issues.apache.org/jira/browse/KAFKA-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500540#comment-16500540 ] Manikumar commented on KAFKA-6281: -- Can you upload server logs and server.properties? >

[jira] [Assigned] (KAFKA-6883) KafkaShortnamer should allow to convert Kerberos principal name to upper case user name

[ https://issues.apache.org/jira/browse/KAFKA-6883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-6883: Assignee: Manikumar > KafkaShortnamer should allow to convert Kerberos principal name to upper cas

[jira] [Commented] (KAFKA-6984) Question

[ https://issues.apache.org/jira/browse/KAFKA-6984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16498975#comment-16498975 ] Manikumar commented on KAFKA-6984: -- Take a look at quickstart docs: http://kafka.apache.

[jira] [Commented] (KAFKA-6982) java.lang.ArithmeticException: / by zero

[ https://issues.apache.org/jira/browse/KAFKA-6982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16498962#comment-16498962 ] Manikumar commented on KAFKA-6982: -- This race condition is handled in latest code by add

[jira] [Commented] (KAFKA-6984) Question

[ https://issues.apache.org/jira/browse/KAFKA-6984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16498933#comment-16498933 ] Manikumar commented on KAFKA-6984: -- You need to install gradle and need to bootstrap the

[jira] [Resolved] (KAFKA-5424) KafkaConsumer.listTopics() throws Exception when unauthorized topics exist in cluster

[ https://issues.apache.org/jira/browse/KAFKA-5424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5424. -- Resolution: Fixed This has been fixed via KAFKA-3396 > KafkaConsumer.listTopics() throws Exception whe

[jira] [Resolved] (KAFKA-5304) Kafka Producer throwing infinite NullPointerExceptions

[ https://issues.apache.org/jira/browse/KAFKA-5304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5304. -- Resolution: Auto Closed Closing inactive issue. Please reopen if the issue still exists. > Kafka Produ

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

[ https://issues.apache.org/jira/browse/KAFKA-4751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4751. -- Resolution: Fixed This is addressed by KIP-266.  > kafka-clients-0.9.0.2.4.2.11-1 issue not throwing e

[jira] [Resolved] (KAFKA-4571) Consumer fails to retrieve messages if started before producer

[ https://issues.apache.org/jira/browse/KAFKA-4571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4571. -- Resolution: Auto Closed Closing inactive issue. Please reopen if the issue still exists. > Consumer fa

[jira] [Resolved] (KAFKA-3822) Kafka Consumer close() hangs indefinitely if Kafka Broker shutdown while connected

[ https://issues.apache.org/jira/browse/KAFKA-3822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3822. -- Resolution: Fixed This is addressed by KIP-266.  > Kafka Consumer close() hangs indefinitely if Kafka

[jira] [Resolved] (KAFKA-3457) KafkaConsumer.committed(...) hangs forever if port number is wrong

[ https://issues.apache.org/jira/browse/KAFKA-3457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3457. -- Resolution: Fixed This is addressed by KIP-266.  > KafkaConsumer.committed(...) hangs forever if port

[jira] [Resolved] (KAFKA-3011) Consumer.poll(0) blocks if Kafka not accessible

[ https://issues.apache.org/jira/browse/KAFKA-3011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3011. -- Resolution: Fixed This is addressed by KIP-266.  > Consumer.poll(0) blocks if Kafka not accessible > -

[jira] [Resolved] (KAFKA-3727) Consumer.poll() stuck in loop on non-existent topic manually assigned

[ https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3727. -- Resolution: Fixed This is addressed by KIP-266. > Consumer.poll() stuck in loop on non-existent topic

[jira] [Resolved] (KAFKA-3899) Consumer.poll() stuck in loop if wrong credentials are supplied

[ https://issues.apache.org/jira/browse/KAFKA-3899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3899. -- Resolution: Fixed Assignee: (was: Edoardo Comar) Fix Version/s: 2.0.0 This is addre

[jira] [Resolved] (KAFKA-3503) Throw exception on missing/non-existent partition

[ https://issues.apache.org/jira/browse/KAFKA-3503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3503. -- Resolution: Duplicate > Throw exception on missing/non-existent partition > -

[jira] [Resolved] (KAFKA-3177) Kafka consumer can hang when position() is called on a non-existing partition.

[ https://issues.apache.org/jira/browse/KAFKA-3177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3177. -- Resolution: Fixed This is addressed by KIP-266. > Kafka consumer can hang when position() is called on

[jira] [Resolved] (KAFKA-6581) ConsumerGroupCommand hangs if even one of the partition is unavailable

[ https://issues.apache.org/jira/browse/KAFKA-6581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6581. -- Resolution: Fixed Fix Version/s: (was: 0.10.0.2) 2.0.0 This is addressed

[jira] [Commented] (KAFKA-6309) add support for getting topic defaults from AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16498033#comment-16498033 ] Manikumar commented on KAFKA-6309: -- This functionality is supported in KafkaAdminClient.

[jira] [Commented] (KAFKA-6959) Any impact we foresee if we upgrade Linux version or move to VM instead of physical Linux server

[ https://issues.apache.org/jira/browse/KAFKA-6959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16497840#comment-16497840 ] Manikumar commented on KAFKA-6959: -- Post these kind of queries to us...@kafka.apache.org

[jira] [Updated] (KAFKA-6335) SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently

[ https://issues.apache.org/jira/browse/KAFKA-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-6335: - Fix Version/s: (was: 2.0.0) > SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls f

<    1   2   3   4   5   6   7   8   9   10   >