[jira] [Resolved] (KAFKA-4030) Update older quickstart documents to clarify which version they relate to

[ https://issues.apache.org/jira/browse/KAFKA-4030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4030. -- Resolution: Not A Problem Closing as per PR comment. > Update older quickstart documents to clar

[jira] [Resolved] (KAFKA-4910) kafka consumer not receiving messages

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

[jira] [Resolved] (KAFKA-3657) NewProducer NullPointerException on ProduceRequest

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

[jira] [Resolved] (KAFKA-2194) Produce request failure after Kafka + Zookeeper restart

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

[jira] [Created] (KAFKA-7398) Transient test failure: SaslAuthenticatorFailureDelayTest.testInvalidPasswordSaslPlain

Manikumar created KAFKA-7398: Summary: Transient test failure: SaslAuthenticatorFailureDelayTest.testInvalidPasswordSaslPlain Key: KAFKA-7398 URL: https://issues.apache.org/jira/browse/KAFKA-7398 Project

[jira] [Resolved] (KAFKA-4978) kafka.metrics.reporters missing from the documentation

[ https://issues.apache.org/jira/browse/KAFKA-4978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4978. -- Resolution: Duplicate Resolving as duplicated of KAFKA-5066 which will add docs for KafkaMetricsConfig

[jira] [Resolved] (KAFKA-2244) Document Kafka metrics configuration properties

[ https://issues.apache.org/jira/browse/KAFKA-2244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2244. -- Resolution: Duplicate Resolving as duplicated of KAFKA-5066 which will add docs for KafkaMetricsConfig

Re: [VOTE] KIP-363: Allow performance tools to print final results to output file

+1 (non-binding) Thanks for the KIP. On Wed, Sep 5, 2018 at 8:24 PM Viktor Somogyi-Vass wrote: > +1 (non-binding), > > Thanks for the KIP! > > Viktor > > On Wed, Sep 5, 2018 at 10:14 AM Attila Sasvári > wrote: > > > Hi All, > > > > I'd like to start the vote on KIP-363: > > * > > >

[jira] [Resolved] (KAFKA-1833) OfflinePartitionLeaderSelector may return null leader when ISR and Assgined Broker have no common

[ https://issues.apache.org/jira/browse/KAFKA-1833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1833. -- Resolution: Auto Closed Closing as PartitionLeaderSelector class is removed/refactored

Re: [VOTE] KIP-357: Add support to list ACLs per principal

Bump! On Tue, Sep 4, 2018 at 11:58 PM Adam Bellemare wrote: > +1 (non binding) - would really like to see this one. > > On Mon, Sep 3, 2018 at 12:18 PM, Mickael Maison > wrote: > > > +1 (non binding) > > On Mon, Sep 3, 2018 at 3:14 PM Manikumar > > wrote: >

[DISCUSS] KIP-371: Add a configuration to build custom SSL principal name

Hi all, I have created a KIP that proposes couple of options for building custom SSL principal names. https://cwiki.apache.org/confluence/display/KAFKA/KIP-371%3A+Add+a+configuration+to+build+custom+SSL+principal+name Please take a look. Thanks, Manikumar

[jira] [Resolved] (KAFKA-4949) Calling kaka-consumer-group.sh to get the consumer offset throws OOM with heap space error

[ https://issues.apache.org/jira/browse/KAFKA-4949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4949. -- Resolution: Duplicate Resolving as duplicate of KAFKA-4090 > Calling kaka-consumer-group.sh to

[jira] [Resolved] (KAFKA-3971) Consumers drop from coordinator and cannot reconnect

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

[jira] [Resolved] (KAFKA-1950) Expose methods from SerializationTestUtils to all tests

[ https://issues.apache.org/jira/browse/KAFKA-1950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1950. -- Resolution: Auto Closed Closing as SerializationTestUtils class is removed from code. > Exp

[jira] [Resolved] (KAFKA-949) Integrate kafka into YARN

[ https://issues.apache.org/jira/browse/KAFKA-949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-949. - Resolution: Resolved Resolving as duplicate of KAFKA-1754 > Integrate kafka into Y

Re: [VOTE] KIP-357: Add support to list ACLs per principal

Jakub Scholz wrote: > > > +1 (non-binding) > > > > > > On Mon, Aug 27, 2018 at 6:24 PM Manikumar > > wrote: > > > > > > > Hi All, > > > > > > > > I would like to start voting on KIP-357 which allows to list ACLs per >

Re: [VOTE] KIP-359: Verify leader epoch in produce requests

+1 (non-binding) Thanks for the KIP. On Sun, Sep 2, 2018 at 10:06 PM Satish Duggana wrote: > Thanks for the KIP, > +1 (non-binding) > > On Sun, Sep 2, 2018 at 7:59 PM, Matthias J. Sax > wrote: > > > +1 (binding) > > > > On 8/30/18 11:30 PM, Dongjin Lee wrote: > > > Thanks for the KIP. I'm +1

Re: [VOTE] KIP-336: Consolidate ExtendedSerializer/Serializer and ExtendedDeserializer/Deserializer

+1 (non-binding) Thanks for the KIP. On Wed, Aug 29, 2018 at 1:41 AM Jason Gustafson wrote: > +1 Thanks for the updates. > > On Tue, Aug 28, 2018 at 1:15 AM, Viktor Somogyi-Vass < > viktorsomo...@gmail.com> wrote: > > > Sure, I've added it. I'll also do the testing today. > > > > On Mon, Aug

[jira] [Resolved] (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:all-tabpanel ] Manikumar resolved KAFKA-6801. -- Resolution: Information Provided Closing as per above comment. > Restrict Consumer to fetch d

[jira] [Resolved] (KAFKA-5962) java.io.IOException: Map failed

[ https://issues.apache.org/jira/browse/KAFKA-5962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5962. -- Resolution: Fixed Closing as docs added in KAFKA-6343 > java.io.IOException: Map fai

[jira] [Resolved] (KAFKA-1712) Excessive storage usage on newly added node

[ https://issues.apache.org/jira/browse/KAFKA-1712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1712. -- Resolution: Fixed Fixed via https://issues.apache.org/jira/browse/KAFKA-2511 > Excessive stor

[jira] [Resolved] (KAFKA-1665) controller state gets stuck in message after execute

[ https://issues.apache.org/jira/browse/KAFKA-1665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1665. -- Resolution: Auto Closed Closing inactive issue. Closing as per above comments. > controller st

[jira] [Resolved] (KAFKA-2127) Running TopicCommand --alter causes connection close/reset errors in kafka logs

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

[jira] [Resolved] (KAFKA-7291) kafka-console-consumer.sh waits on inexistent topic

[ https://issues.apache.org/jira/browse/KAFKA-7291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7291. -- Resolution: Fixed Fixed in newer versions. Yes, you need to upgrade to latest versions. > ka

[jira] [Resolved] (KAFKA-2385) zookeeper-shell does not work

[ https://issues.apache.org/jira/browse/KAFKA-2385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2385. -- Resolution: Fixed Fixed in new zookeeper (3.4.7 +) versions > zookeeper-shell does not w

[jira] [Resolved] (KAFKA-2238) KafkaMetricsConfig cannot be configured in broker (KafkaConfig)

[ https://issues.apache.org/jira/browse/KAFKA-2238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2238. -- Resolution: Duplicate Resolving as duplicated of KAFKA-5066 which will add docs for KafkaMetricsConfig

[jira] [Resolved] (KAFKA-4065) Missing Property in ProducerConfig.java - KafkaProducer API 0.9.0.0

[ https://issues.apache.org/jira/browse/KAFKA-4065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4065. -- Resolution: Auto Closed Closing inactive issue. It is highly unlikely to add this feature

[jira] [Resolved] (KAFKA-3369) Add unit-tests to the Metadata Cache

[ https://issues.apache.org/jira/browse/KAFKA-3369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3369. -- Resolution: Fixed Closing as per above comment. > Add unit-tests to the Metadata Ca

[VOTE] KIP-357: Add support to list ACLs per principal

/dc7f6005845a372a0a48a40872a32d9ece03807a4fb1bb89d3645afb@%3Cdev.kafka.apache.org%3E Thanks, Manikumar

Re: [DISCUSS] KIP-357: Add support to list ACLs per principal

sts: * > User:User1 has Allow permission for operations: Describe from hosts: * > > Thanks, > Satish. > > > On Fri, Aug 24, 2018 at 1:13 AM, Harsha wrote: > > > +1 (binding) > > > > Thanks, > > Harsha > > > > On Wed, Aug 22, 201

[jira] [Resolved] (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:all-tabpanel ] Manikumar resolved KAFKA-6309. -- Resolution: Fixed Closing as per above comment. We can use "describeConfigs(brokerResource

[jira] [Resolved] (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:all-tabpanel ] Manikumar resolved KAFKA-6314. -- Resolution: Duplicate Resolving as duplicate of KAFKA-6275 > Add a tool to delete kafka ba

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

[ https://issues.apache.org/jira/browse/KAFKA-1921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1921. -- Resolution: Duplicate Resolving as duplicate of KAFKA-6275 > Delete offsets for a group with ka

Re: [DISCUSS] KIP-357: Add support to list ACLs per principal

, Aug 22, 2018 at 5:53 PM Viktor Somogyi-Vass wrote: > Hi Manikumar, > > Implementation-wise is it just a filter over the returned ACL listing or do > you plan to add new methods to the Authorizer as well? > > Thanks, > Viktor > > On Fri, Aug 17, 2018 at 9:18 PM Priyank

[jira] [Resolved] (KAFKA-7279) partitionsFor implicitly creates topic for the existent topic

[ https://issues.apache.org/jira/browse/KAFKA-7279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7279. -- Resolution: Duplicate Resolving as duplicate of KAFKA-7320/KIP-361 > partitionsFor implicitly crea

[jira] [Created] (KAFKA-7319) Add documentation for consumer group management

Manikumar created KAFKA-7319: Summary: Add documentation for consumer group management Key: KAFKA-7319 URL: https://issues.apache.org/jira/browse/KAFKA-7319 Project: Kafka Issue Type: Task

Re: [ANNOUNCE] New Kafka PMC member: Dong Lin

Congrats, Dong Lin! On Mon, Aug 20, 2018 at 4:25 PM Ismael Juma wrote: > Hi everyone, > > Dong Lin became a committer in March 2018. Since then, he has remained > active in the community and contributed a number of patches, reviewed > several pull requests and participated in numerous KIP

[jira] [Resolved] (KAFKA-5444) Producer.send() will hang 8+ hours

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

Re: [VOTE] KIP-325: Extend Consumer Group Command to Show Beginning Offsets

+1 (non-binding) Thanks for the KIP. On Fri, Aug 17, 2018 at 9:41 AM Satish Duggana wrote: > +1 > > Thanks, > Satish. > > On Fri, Aug 17, 2018 at 1:45 AM, Bill Bejeck wrote: > > > +1 > > > > Thanks, > > Bill > > > > On Thu, Aug 16, 2018 at 3:13 PM Ted Yu wrote: > > > > > +1 > > > > > > On

[DISCUSS] KIP-357: Add support to list ACLs per principal

Hi all, I have created a minor KIP to add support to list ACLs per principal using AclCommand (kafka-acls.sh) https://cwiki.apache.org/confluence/display/KAFKA/KIP-357%3A++Add+support+to+list+ACLs+per+principal Please take a look. Thanks,

Re: Java 11 support

check this: https://issues.apache.org/jira/browse/KAFKA-7264 On Thu, Aug 16, 2018 at 2:40 PM Manoj Jain wrote: > Hi All, > > I have just subscribed to this group. I don't know what is format of > questions to be submitted yet but in hurry thought of getting more details > on kafka java

[jira] [Resolved] (KAFKA-6224) Can not build Kafka 1.0.0 with gradle 3.2.1

[ https://issues.apache.org/jira/browse/KAFKA-6224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6224. -- Resolution: Cannot Reproduce Please reopen if the issue still exists. > Can not build Kafka 1.

[jira] [Created] (KAFKA-7287) Set open ACL permissions for old consumer znode path

Manikumar created KAFKA-7287: Summary: Set open ACL permissions for old consumer znode path Key: KAFKA-7287 URL: https://issues.apache.org/jira/browse/KAFKA-7287 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-7257) --property (silently) fails when configuring SSL parameters

[ https://issues.apache.org/jira/browse/KAFKA-7257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7257. -- Resolution: Not A Problem > --property (silently) fails when configuring SSL paramet

[jira] [Resolved] (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:all-tabpanel ] Manikumar resolved KAFKA-6211. -- Resolution: Won't Fix Closing this in favour of AdminClient API.   > PartitionAssignmentSt

[jira] [Resolved] (KAFKA-6095) Error when displaying LAG information consumer partitions that use zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-6095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6095. -- Resolution: Auto Closed Closing as scala consumer related code/tools are removed from 2.0 release

[jira] [Resolved] (KAFKA-6432) Lookup indices may cause unnecessary page fault

[ https://issues.apache.org/jira/browse/KAFKA-6432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6432. -- Resolution: Fixed Fix Version/s: 2.1.0 > Lookup indices may cause unnecessary page fa

[jira] [Resolved] (KAFKA-7247) A link to Apache BookKeeper project is broken

[ https://issues.apache.org/jira/browse/KAFKA-7247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7247. -- Resolution: Fixed Fix Version/s: 2.1.0 > A link to Apache BookKeeper project is bro

[jira] [Created] (KAFKA-7259) Remove deprecated ZKUtils usage from ZkSecurityMigrator

Manikumar created KAFKA-7259: Summary: Remove deprecated ZKUtils usage from ZkSecurityMigrator Key: KAFKA-7259 URL: https://issues.apache.org/jira/browse/KAFKA-7259 Project: Kafka Issue Type

Re: [VOTE] KIP-289: Improve the default group id behavior in KafkaConsumer

+1 (non-binding). Thanks for the KIP. On Wed, Aug 8, 2018 at 7:36 PM Ted Yu wrote: > +1 > > On Wed, Aug 8, 2018 at 4:09 AM Mickael Maison > wrote: > > > +1 (non-binding) > > Thanks Vahid > > On Wed, Aug 8, 2018 at 11:26 AM Kamal Chandraprakash > > wrote: > > > > > > +1 (non-binding) > > > >

Re: [VOTE] KIP-346 - Improve LogCleaner behavior on error

+1 (non-binding) Thanks for the KIP. On Tue, Aug 7, 2018 at 10:42 PM Ray Chiang wrote: > +1 (non-binding) > > -Ray > > On 8/7/18 9:26 AM, Ted Yu wrote: > > +1 > > > > On Tue, Aug 7, 2018 at 5:25 AM Thomas Becker > wrote: > > > >> +1 (non-binding) > >> > >> We've hit issues with the log

Re: [DISCUSS] KIP-332: Update AclCommand to use AdminClient API

ot; > > StreamsResetter. I will let others comment on whether we should change to > > this when we add the option to other tools. > > > > Regards, > > > > Rajini > > > > On Fri, Aug 3, 2018 at 5:41 PM, Dong Lin wrote: > > > > > Hey Rajini, M

Re: [VOTE] KIP-332: Update AclCommand to use AdminClient API

Hi All, The vote has passed with 3 binding votes (Rajini, Jason, Dong) and 2 non-binding votes (Ted, Colin). Thanks everyone for the votes. Thanks, Manikumar On Sat, Aug 4, 2018 at 5:09 AM Dong Lin wrote: > Thanks Manikumar! > > +1 > > On Fri, Aug 3, 2018 at 4:33 PM,

Re: [DISCUSS] KIP-332: Update AclCommand to use AdminClient API

Updated the KIP. added a note to KIP-340 discussion thread. On Fri, Aug 3, 2018 at 2:52 PM Rajini Sivaram wrote: > Thanks Manikumar. Can you add a note to the KIP-340 discussion thread? > > On Fri, Aug 3, 2018 at 10:04 AM, Manikumar > wrote: > > > Hi Rajini, > >

Re: [DISCUSS] KIP-340: Allow kafka-reassign-partitions.sh and kafka-log-dirs.sh to take admin client property file

Hi Dong, In KIP-332 discussion, It was agreed to use "--command-config" option name for passing config property file. We can also use same name in here, to make it consistent across all tools. Thanks, On Thu, Jul 12, 2018 at 9:20 AM Dong Lin wrote: > wiki page is currently read-only and it

Re: [DISCUSS] KIP-332: Update AclCommand to use AdminClient API

e are no concerns, I will change the option to "--command-config". Since KIP-340 PR is not yet merged, we can also change there. Thanks, On Fri, Aug 3, 2018 at 1:57 PM Rajini Sivaram wrote: > Hi Manikumar, > > We have some tools already (ConfigCommand, ConsumerGroupCommand, > De

[jira] [Resolved] (KAFKA-7226) kafka-console-consumer.sh doesn't use security.protocol provided in config file

[ https://issues.apache.org/jira/browse/KAFKA-7226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7226. -- Resolution: Information Provided Closing the issue related to HDP Kafka distribution. > kafka-cons

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

[ https://issues.apache.org/jira/browse/KAFKA-7083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7083. -- Resolution: Information Provided Closing the issue related to node.js client. Please contact client

[VOTE] KIP-332: Update AclCommand to use AdminClient API

/msg90049.html Thanks, Manikumar

Re: [DISCUSS] KIP-332: Update AclCommand to use AdminClient API

Hi all, If there are no concerns, I will start the voting process soon. Thanks On Tue, Jul 31, 2018 at 9:08 AM Manikumar wrote: > Hi Colin, > > Yes, "--authorizer-properties" option is not required with > "--bootstrap-server" option. Updated the KIP. > &

Re: [DISCUSS] KIP-332: Update AclCommand to use AdminClient API

Hi Colin, Yes, "--authorizer-properties" option is not required with "--bootstrap-server" option. Updated the KIP. Thanks, On Tue, Jul 31, 2018 at 1:30 AM Ted Yu wrote: > Look good to me. > > On Mon, Jul 23, 2018 at 7:30 AM Manikumar > wrote: > >

Re: [DISCUSS] KIP-332: Update AclCommand to use AdminClient API

Bumping this up! On Mon, Jul 23, 2018 at 8:00 PM Manikumar wrote: > Hi all, > > I have created a KIP to use AdminClient API in AclCommand (kafka-acls.sh) > > > *https://cwiki.apache.org/confluence/display/KAFKA/KIP-332%3A+Update+AclCommand+to+use+AdminClient+API* > > &

Re: [ANNOUNCE] Apache Kafka 2.0.0 Released

y, Dong Lin, Edoardo Comar, emmanuel Harel, > > Eugene Sevastyanov, Ewen Cheslack-Postava, Fedor Bobin, fedosov-alexander, > > Filipe Agapito, Florian Hussonnois, fredfp, Gilles Degols, gitlw, Gitomain, > > Guangxian, Gunju Ko, Gunnar Morling, Guozhang Wang, hmcl, huxi, huxihx, >

[jira] [Created] (KAFKA-7210) Add system test for log compaction

Manikumar created KAFKA-7210: Summary: Add system test for log compaction Key: KAFKA-7210 URL: https://issues.apache.org/jira/browse/KAFKA-7210 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (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 resolved KAFKA-4690. -- Resolution: Duplicate Resolving as duplicate of KAFKA-5975. > IllegalStateException us

[jira] [Resolved] (KAFKA-5799) New KafkaSpoutConfig(Scheme)-ByteArrayKeyValueScheme

[ https://issues.apache.org/jira/browse/KAFKA-5799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5799. -- Resolution: Auto Closed Closing Apache Storm - Kafka Spout related query.  If this still issue, please

[jira] [Resolved] (KAFKA-2396) I have config host.name and advertised.host.name but still have a link connet to 0.0.0.0 with random port

[ https://issues.apache.org/jira/browse/KAFKA-2396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2396. -- Resolution: Not A Problem extra port is related to JMX. See  KAFKA-1869 > I have config host.n

[jira] [Resolved] (KAFKA-2395) Linked to a interfaces even though the host.name had config

[ https://issues.apache.org/jira/browse/KAFKA-2395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2395. -- Resolution: Not A Problem extra port is related to KAFKA-1869 > Linked to a interfaces even tho

[jira] [Resolved] (KAFKA-2318) replica manager repeatedly tries to fetch from partitions already moved during controlled shutdown

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

[jira] [Resolved] (KAFKA-3040) Broker didn't report new data after change in leader

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

[jira] [Resolved] (KAFKA-2890) Strange behaviour during partitions reassignment.

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

[jira] [Resolved] (KAFKA-2968) Refactor ReplicaManager to be optimal for o.a.k.c requests

[ https://issues.apache.org/jira/browse/KAFKA-2968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2968. -- Resolution: Fixed Closing this as scala request/responses classes are removed and ReplicaManager

[jira] [Resolved] (KAFKA-2969) Refactor MetadataCache to be optimal for o.a.k.c requests

[ https://issues.apache.org/jira/browse/KAFKA-2969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2969. -- Resolution: Fixed Closing this as scala request/responses classes are removed and MetadataCache

[jira] [Resolved] (KAFKA-2075) Validate that all kafka.api requests has been removed and clean up compatibility code

[ https://issues.apache.org/jira/browse/KAFKA-2075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2075. -- Resolution: Fixed Old scala request/reponse classes are removed as part of KAFKA-2983: > Valid

[jira] [Resolved] (KAFKA-2963) Replace server internal usage of TopicAndPartition with TopicPartition

[ https://issues.apache.org/jira/browse/KAFKA-2963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2963. -- Resolution: Fixed This has been fixed in various cleanups > Replace server internal us

[DISCUSS] KIP-332: Update AclCommand to use AdminClient API

Hi all, I have created a KIP to use AdminClient API in AclCommand (kafka-acls.sh) *https://cwiki.apache.org/confluence/display/KAFKA/KIP-332%3A+Update+AclCommand+to+use+AdminClient+API*

[jira] [Resolved] (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:all-tabpanel ] Manikumar resolved KAFKA-7154. -- Resolution: Information Provided > Apache kafka getting shut down everytime it is star

[jira] [Resolved] (KAFKA-2008) Update num.consumer.fetchers description in Kafka documentation

[ https://issues.apache.org/jira/browse/KAFKA-2008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2008. -- Resolution: Auto Closed Closing issue related old consumer configs. Old consumer config doc section

[jira] [Resolved] (KAFKA-1970) Several tests are not stable

[ https://issues.apache.org/jira/browse/KAFKA-1970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1970. -- Resolution: Auto Closed Closing inactive issue > Several tests are not sta

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

*Hi All,The vote has passed with 3 binding votes (Gwen, Harsha, Jason) and 8 non-binding votes (Vahid, Mickael, Ted, Daniele, Satish, Magnus, Kamal, Eno).Thanks everyone for the votes.Thanks,Manikumar* On Sat, Jul 21, 2018 at 12:26 AM Jason Gustafson wrote: > Thanks, +1 from me. > &g

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

ght abuse, but at least it suggests an incompatibility between > what the client is requesting to do and what the server supports. > UNKNOWN_SERVER_ERROR, on the other hand, suggests an unexpected condition > on the broker. > > -Jason > > On Fri, Jul 20, 2018 at 10:57 AM, Mani

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

Hi Jason, Yes, we can return UNKNOWN_SERVER_ERROR for older versions. This will give better developer experience. Updated the KIP. Thanks, On Fri, Jul 20, 2018 at 11:02 PM Jason Gustafson wrote: > Hey Manikumar, > > This looks good. Do we have to keep the current behavior when han

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

Bumping this thread. On Tue, Jul 10, 2018 at 10:33 PM Manikumar wrote: > Waiting for one more binding vote to pass this minor KIP. Appreciate your > vote. > > On Wed, Jul 4, 2018 at 7:03 PM Eno Thereska > wrote: > >> +1 (non binding) >> >> On Wed, Jul 4, 2

[jira] [Resolved] (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 resolved KAFKA-7081. -- Resolution: Won't Fix Closing this KIP in favor of adding filtering support to the Metadata API

Re: [VOTE] KIP-338 Support to exclude the internal topics in kafka-topics.sh command

+1 (non-binding) On Thu, Jul 19, 2018 at 11:47 PM Colin McCabe wrote: > +1 (non-binding) > > cheers, > Colin > > On Mon, Jul 16, 2018, at 01:10, Chia-Ping Tsai wrote: > > hi folks, > > > > The discussion[1] of KIP-338[2] did not get any objection for last 6 > > days so it is time to start the

[jira] [Resolved] (KAFKA-1420) Replace AdminUtils.createOrUpdateTopicPartitionAssignmentPathInZK with TestUtils.createTopic in unit tests

[ https://issues.apache.org/jira/browse/KAFKA-1420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1420. -- Resolution: Fixed Fixed as part of https://github.com/apache/kafka/pull/5303 > Repl

Re: KIP-327: Add describe all topics API to AdminClient

Closing this KIP in favor of adding filtering support to the Metadata API and KIP-142. Will open a new KIP when ready. Thanks for your reviews. On Mon, Jul 16, 2018 at 8:38 AM Colin McCabe wrote: > Thanks, Manikumar. I've been meaning to bring up KIP-142 again. It would > definitely be

Re: KIP-327: Add describe all topics API to AdminClient

nt > > > > > releases> > of the JDK (there were some changes in java 8, for > > > example). > > > > > Also, re2> > regular expressions are linear time, never exponential > > > time. See > > > > > https://github.com/google/re

[jira] [Resolved] (KAFKA-6746) Allow ZK Znode configurable for Kafka broker

[ https://issues.apache.org/jira/browse/KAFKA-6746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6746. -- Resolution: Fixed Fixed via https://github.com/apache/kafka/pull/5358 > Allow ZK Znode configura

KIP-327: Add describe all topics API to AdminClient

Hi all, I have created a KIP to add describe all topics API to AdminClient . https://cwiki.apache.org/confluence/display/KAFKA/KIP-327%3A+Add+describe+all+topics+API+to+AdminClient Please take a look. Thanks,

Re: [VOTE] 1.1.1 RC3

+1 (non-binding) Ran tests, Verified quick start, producer/consumer perf tests On Thu, Jul 12, 2018 at 11:06 AM Brett Rann wrote: > +1 (non binding) > rolling upgrade of shared staging multitenacy (200+ consumer groups) > cluster from 1.1.0 to 1.1.1-rc3 using the kafka_2.11-1.1.1.tgz

Re: [DISCUSS] KIP-338 Support to exclude the internal topics in kafka-topics.sh command

LGTM. Thanks for the KIP. Thanks. On Wed, Jul 11, 2018 at 3:31 PM Chia-Ping Tsai wrote: > hi Kafka, > > KIP-338 is trying to make us exclude internal topics easily when using the > kafka-topics.sh. An new option will be added to kafka-topics.sh > (TopicCommand) and user can use the option to

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

; > > > > > > > > > > +1 (non binding) > > > > > > > > Thanks for the KIP > > > > > > > > > > > > > > > > On Tue, Jul 3, 2018 at 4:59 PM, Vahid S Hashemian > > > > > > > > < vahidhashem...@us.ibm.com > wrote:

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

*Hi All,The vote has passed with 3 binding votes (Dong Lin, Rajini, Jason,) and one non-binding vote(Ted).Thanks everyone for the votes.Thanks,Manikumar* On Fri, Jun 29, 2018 at 9:34 PM Jason Gustafson wrote: > +1 > > Thanks Manikumar! > > On Fri, Jun 29, 2018 at 8:37 AM,

Re: [VOTE] 2.0.0 RC1

+1 (non-binding) Verified the release notes, src, binary artifacts, Ran the test suite, Verified quick start, Ran producer/consumer perf test, log compaction tests Thanks On Wed, Jul 4, 2018 at 8:33 AM Brett Rann wrote: > +1 tentative > rolling upgrade of tiny shared staging multitenacy

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

Manikumar Fri, Jun 29, 7:59 PM (4 days ago) to dev Hi All, I would like to start voting on KIP-322 which would return new error code for DeleteTopics API when topic deletion disabled. https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=87295558 Thanks,

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

Since this is a minor KIP, If there are no concerns I will start voting thread. On Wed, Jun 27, 2018 at 2:24 PM Ted Yu wrote: > bq. set the serialVersionUID = 1L in Kafka exception classes > > Indeed. Should have checked earlier. > > On Wed, Jun 27, 2018 at 1:38 AM, Man

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

+1 (non-binding) Verified tests, quick start, producer/consumer perf tests. On Sun, Jul 1, 2018 at 11:27 PM Ismael Juma wrote: > +1 (binding) > > Verified signature of source artifact, ran tests and verified quickstart > on source artifact with Java 7, verified quickstart on binary artifact

Re: [kafka-clients] Re: [VOTE] 0.11.0.3 RC0

+1 (non-binding) Verified quick start, ran producer/consumer perf tests, Thanks On Sun, Jul 1, 2018 at 8:29 PM Ismael Juma wrote: > +1 (binding) > > Verified signature of source artifact, ran tests and verified quickstart > on source artifact with Java 7, verified quickstart on binary

[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

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