[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-res

[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 except

Re: [kafka-clients] [VOTE] 2.0.0 RC1

looks like maven artifacts are not updated in the staging repo. They are still at old timestamp. https://repository.apache.org/content/groups/staging/org/apache/kafka/kafka_2.11/2.0.0/ On Sat, Jun 30, 2018 at 12:06 AM Rajini Sivaram wrote: > Hello Kafka users, developers and client-developers,

[VOTE] KIP-308: Support dynamic update of max.connections.per.ip/max.connections.per.ip.overrides configs

Hi All, I would like to start voting on KIP-308 which would add support for dynamic update of max.connections.per.ip/max.connections.per.ip.overrides configs https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=85474993 Thanks,

[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] [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

Re: [DISCUSS] KIP-308: Support dynamic update of max.connections.per.ip/max.connections.per.ip.overrides configs

Thanks for the responses. If there are no concerns, I will start the voting process soon. On Tue, Jun 26, 2018 at 10:14 PM Harsha wrote: > This is very useful. LGTM. > > Thanks, > Harsha > > On Mon, Jun 25th, 2018 at 10:20 AM, Dong Lin wrote: > > > > > >

Re: [VOTE] KIP-324: Add method to get metrics() in AdminClient

+1 (non-binding) Thanks. On Wed, Jun 27, 2018 at 10:15 PM Matthias J. Sax wrote: > +1 (binding) > > On 6/26/18 2:33 PM, Guozhang Wang wrote: > > +1. Thanks. > > > > On Tue, Jun 26, 2018 at 2:31 PM, Yishun Guan wrote: > > > >> Hi All, > >> > >> I am starting a vote on this KIP: > >> > >>

Re: [DISCUSS] KIP-322: Return new error code for DeleteTopics API when topic deletion disabled.

Hi, Thanks for the review. > nit: you are going to fill in an actual value below in your PR, right ? > private static final long serialVersionUID = 1L; > > We normally set the serialVersionUID = 1L in Kafka exception classes. In Motivation, please mention the IllegalStateException

[DISCUSS] KIP-322: Return new error code for DeleteTopics API when topic deletion disabled.

Hi all, I have created a minor KIP to return new error code for DeleteTopics API when topic deletion disabled. https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=87295558 Please take a look. Thanks,

[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 ena

[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. > ProducerBounceT

[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. > Conv

[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: u

[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

Re: [VOTE] 1.0.2 RC0

+1 (non-binding) Verified tests, quick start, producer/consumer perf tests. On Sat, Jun 23, 2018 at 2:25 AM Ted Yu wrote: > +1 > > Ran test suite. > > Checked signatures. > > On Fri, Jun 22, 2018 at 11:42 AM, Vahid S Hashemian < > vahidhashem...@us.ibm.com> wrote: > > > +1 (non-binding) > > > >

Re: [kafka-clients] Re: [VOTE] 1.1.1 RC1

+1 (non-binding) Ran tests, Verified quick start, producer/consumer perf tests On Sat, Jun 23, 2018 at 8:11 AM Dong Lin wrote: > Thank you for testing and voting the release! > > I noticed that the date for 1.1.1-rc1 is wrong. Please kindly test and > vote by Tuesday, June 26, 12 pm PT. > >

[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

[DISCUSS] KIP-308: Support dynamic update of max.connections.per.ip/max.connections.per.ip.overrides configs

Hi all, I have created a KIP to add support for dynamic update of max.connections.per.ip/max.connections.per.ip.overrides configs *https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=85474993 * Any feedback

Re: [VOTE] 1.1.1 RC0

+1 (non-binding) Ran test, Verified quick start, producer/consumer perf tests On Thu, Jun 21, 2018 at 11:58 AM zhenya Sun wrote: > +1 non-binding > > > 在 2018年6月21日，下午2:18，Andras Beni 写道： > > > > +1 (non-binding) > > > > Built .tar.gz, created a cluster from it and ran a basic end-to-end

[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] [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

[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. >

[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

[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

[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

[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

[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

[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

[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

[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 inst

[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

[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. > ka

[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 > Transi

[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

[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

[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

[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

[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

[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

[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 Sc

[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

[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

[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 h

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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 z

[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 wildc

[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 > ReplayLogProdu

[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 w

[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 Except

[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. > Ka

[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 throw

[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. > Consu

[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 Ka

[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 p

[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 accessi

[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 to

[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

[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 partit

[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 cal

[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] [Resolved] (KAFKA-3743) kafka-server-start.sh: Unhelpful error message

[ https://issues.apache.org/jira/browse/KAFKA-3743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3743. -- Resolution: Duplicate > kafka-server-start.sh: Unhelpful error mess

[jira] [Resolved] (KAFKA-2556) Corrupted index on log.dir updates

[ https://issues.apache.org/jira/browse/KAFKA-2556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2556. -- Resolution: Not A Problem Closing inactive issue. Kafka log.dir contains topic data and metadata

[jira] [Resolved] (KAFKA-3293) Consumers are not able to get messages.

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

[jira] [Resolved] (KAFKA-6427) Inconsistent exception type from KafkaConsumer.position

[ https://issues.apache.org/jira/browse/KAFKA-6427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6427. -- Resolution: Fixed Fix Version/s: 2.0.0 Fixed in https://github.com/apache/kafka/pull/5005

[jira] [Resolved] (KAFKA-4368) Unclean shutdown breaks Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-4368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4368. -- Resolution: Auto Closed Closing inactive issue. > Unclean shutdown breaks Kafka clus

[jira] [Resolved] (KAFKA-6769) Upgrade jetty library version

[ https://issues.apache.org/jira/browse/KAFKA-6769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6769. -- Resolution: Fixed Fix Version/s: 2.0.0 Jetty version upgraded to 9.4.10.v20180503 in trunk

[jira] [Resolved] (KAFKA-5346) Kafka Producer Failure After Idle Time

[ https://issues.apache.org/jira/browse/KAFKA-5346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5346. -- Resolution: Not A Problem Closing as per above comment. Please reopen if you think the issue still

[jira] [Resolved] (KAFKA-6929) ZkData - Consumers offsets Zookeeper path is not correct

[ https://issues.apache.org/jira/browse/KAFKA-6929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6929. -- Resolution: Fixed Fix Version/s: 2.0.0 Fixed via https://github.com/apache/kafka/pull/5060

[jira] [Resolved] (KAFKA-3649) Add capability to query broker process for configuration properties

[ https://issues.apache.org/jira/browse/KAFKA-3649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3649. -- Resolution: Fixed Requested features are added in  KIP-133: Describe and Alter Configs Admin APIs

[jira] [Resolved] (KAFKA-6921) Remove old Scala producer and all related code, tests, and tools

[ https://issues.apache.org/jira/browse/KAFKA-6921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6921. -- Resolution: Fixed > Remove old Scala producer and all related code, tests, and to

[jira] [Created] (KAFKA-6945) Add support to allow users to acquire delegation tokens for other users

Manikumar created KAFKA-6945: Summary: Add support to allow users to acquire delegation tokens for other users Key: KAFKA-6945 URL: https://issues.apache.org/jira/browse/KAFKA-6945 Project: Kafka

[jira] [Resolved] (KAFKA-6862) test toolchain

[ https://issues.apache.org/jira/browse/KAFKA-6862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6862. -- Resolution: Invalid Please reopen the Jira with more details. > test toolch

[jira] [Resolved] (KAFKA-4505) Cannot get topic lag since kafka upgrade from 0.8.1.0 to 0.10.1.0

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

[jira] [Resolved] (KAFKA-2036) Consumer and broker have different networks

[ https://issues.apache.org/jira/browse/KAFKA-2036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2036. -- Resolution: Duplicate Resolving this duplicate of KIP-235/KIP-302  > Consumer and broker h

[jira] [Resolved] (KAFKA-3793) Kafka Python Consumer library messages gets truncated

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

[jira] [Resolved] (KAFKA-6356) UnknownTopicOrPartitionException & NotLeaderForPartitionException and log deletion happening with retention bytes kept at -1.

[ https://issues.apache.org/jira/browse/KAFKA-6356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6356. -- Resolution: Not A Problem old data is discarded after log retention period or when the log reaches

[jira] [Resolved] (KAFKA-2943) Transient Failure in kafka.producer.SyncProducerTest.testReachableServer

[ https://issues.apache.org/jira/browse/KAFKA-2943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2943. -- Resolution: Auto Closed > Transient Failure in kafka.producer.SyncProducerTest.testReachableSer

[jira] [Resolved] (KAFKA-5432) producer and consumer SocketTimeoutException

[ https://issues.apache.org/jira/browse/KAFKA-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5432. -- Resolution: Auto Closed Closing inactive issue.  Exceptions observed with deprecated scala clients

[jira] [Resolved] (KAFKA-4419) Unable to GetOffset when the ACL of topic is defined

[ https://issues.apache.org/jira/browse/KAFKA-4419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4419. -- Resolution: Duplicate Resolving as duplicate of  KAFKA-3355. > Unable to GetOffset when the

[jira] [Resolved] (KAFKA-1460) NoReplicaOnlineException: No replica for partition

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

[jira] [Resolved] (KAFKA-2174) Wrong TopicMetadata deserialization

[ https://issues.apache.org/jira/browse/KAFKA-2174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2174. -- Resolution: Auto Closed Closing inactive issue. > Wrong TopicMetadata deserializat

[jira] [Resolved] (KAFKA-3345) ProducerResponse could gracefully handle no throttle time provided

[ https://issues.apache.org/jira/browse/KAFKA-3345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3345. -- Resolution: Auto Closed Closing as scala producer is removed from codebase. [|https://issues.apache.org

[jira] [Resolved] (KAFKA-5039) Logging in BlockingChannel and SyncProducer connect

[ https://issues.apache.org/jira/browse/KAFKA-5039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5039. -- Resolution: Auto Closed Closing as scala producer is removed from codebase. > Logg

[jira] [Resolved] (KAFKA-3246) Transient Failure in kafka.producer.SyncProducerTest.testProduceCorrectlyReceivesResponse

[ https://issues.apache.org/jira/browse/KAFKA-3246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3246. -- Resolution: Auto Closed > Transient Fail

[jira] [Resolved] (KAFKA-5728) Stopping consumer thread cause loosing message in the partition

[ https://issues.apache.org/jira/browse/KAFKA-5728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5728. -- Resolution: Auto Closed looks like this is related to spring kafka config issue. must be related

[jira] [Resolved] (KAFKA-4091) Unable to produce or consume on any topic

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

[jira] [Resolved] (KAFKA-3843) Endless consuming messages in Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-3843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3843. -- Resolution: Auto Closed The Scala consumers have been deprecated and no further work is planned, please

[jira] [Resolved] (KAFKA-3620) Clean up Protocol class.

[ https://issues.apache.org/jira/browse/KAFKA-3620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3620. -- Resolution: Fixed Closing this as some cleanup done in newer versions.  Please reopen if you think

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