[jira] [Resolved] (KAFKA-3180) issue for extracting JSON from https web page

[ https://issues.apache.org/jira/browse/KAFKA-3180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3180. -- Resolution: Not A Problem  I suggest to post these kind of queries to  [[us...@kafka.apache.org

[jira] [Resolved] (KAFKA-1977) Make logEndOffset available in the Zookeeper consumer

[ https://issues.apache.org/jira/browse/KAFKA-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1977. -- Resolution: Auto Closed Closing this as the Scala consumers have been deprecated and no further work

[jira] [Resolved] (KAFKA-6426) Kafka SASL/SCRAM authentication does not fail for incorrect username or password.

[ https://issues.apache.org/jira/browse/KAFKA-6426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6426. -- Resolution: Cannot Reproduce This looks like configuration issue. Please reopen if you think the issue

[jira] [Resolved] (KAFKA-6682) Kafka reconnection after broker restart

[ https://issues.apache.org/jira/browse/KAFKA-6682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6682. -- Resolution: Duplicate Resolving this as duplicate of KAFKA-6260.  Please reopen if the issue still

Re: [VOTE] KIP-255: OAuth Authentication via SASL/OAUTHBEARER

+1 (non-binding) Thanks for the detailed KIP. On Wed, May 16, 2018 at 5:59 PM, Mickael Maison wrote: > Thanks for the KIP, > +1 (non binding) > > On Wed, May 16, 2018 at 2:51 AM, Ron Dagostino wrote: > > Hi Jun. I think you are getting at the fact

Re: [VOTE] KIP-278: Add version option to Kafka's commands

+1 (non-binding) Thanks for the KIP. On Fri, May 11, 2018 at 12:56 PM, zhenya Sun wrote: > +1 building > > 在 2018年5月11日，上午9:51，Ted Yu 写道： > > > > +1 > > > > On Thu, May 10, 2018 at 6:42 PM, Sasaki Toru > > wrote: > > > >> Hi

[jira] [Resolved] (KAFKA-6141) Errors logs when running integration/kafka/tools/MirrorMakerIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-6141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6141. -- Resolution: Fixed Closing this as log level changed to debug in ZOOKEEPER-2795 / Zookeeper 3.4.12

[jira] [Resolved] (KAFKA-6825) DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG is private

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

Re: [VOTE] KIP-266: Add TimeoutException for KafkaConsumer#position

+1 (non-binding). Thanks. On Thu, May 10, 2018 at 2:33 PM, Mickael Maison wrote: > +1 (non binding) > Thanks > > On Thu, May 10, 2018 at 9:39 AM, Rajini Sivaram > wrote: > > Hi Richard, Thanks for the KIP. > > > > +1 (binding) > > > > Regards,

Re: [VOTE] KIP-294 - Enable TLS hostname verification by default

+1 (non-binding) Thanks. On Wed, May 9, 2018 at 10:09 PM, Mickael Maison wrote: > +1, thanks for the KIP! > > On Wed, May 9, 2018 at 4:41 PM, Ted Yu wrote: > > +1 > > > > On Wed, May 9, 2018 at 8:28 AM, Rajini Sivaram >

[jira] [Resolved] (KAFKA-3921) Periodic refresh of metadata causes spurious log messages

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

[jira] [Resolved] (KAFKA-6837) Apache kafka broker got stopped.

[ https://issues.apache.org/jira/browse/KAFKA-6837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6837. -- Resolution: Information Provided > Apache kafka broker got stop

[jira] [Resolved] (KAFKA-3417) Invalid characters in config properties not being validated?

[ https://issues.apache.org/jira/browse/KAFKA-3417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3417. -- Resolution: Fixed Assignee: Mickael Maison (was: Grant Henke) Fix Version/s: 2.0.0

Re: [DISCUSS] KIP-278: Add version option to Kafka's commands

I assume the intent of the KIP to find out the Kafka broker version. In this case, maybe we should expose version using a Kafka request. This will help the remote scripts/tools to query the Kafka version. scripts (kafka-topics.sh, kafka-configs.sh, etc..) may run from remote machines and may

Re: [VOTE] KIP-277 - Fine Grained ACL for CreateTopics API

+1 (non-binding) Thanks On Thu, Apr 26, 2018 at 9:59 PM, Colin McCabe wrote: > +1 (non-binding) > > best, > Colin > > > On Wed, Apr 25, 2018, at 02:45, Edoardo Comar wrote: > > Hi, > > > > The discuss thread on KIP-277 ( > >

Re: [VOTE] KIP-282: Add the listener name to the authentication context

+1 (non-binding) On Wed, Apr 25, 2018 at 9:05 PM, Ted Yu wrote: > +1 > > On Wed, Apr 25, 2018 at 8:33 AM, Rajini Sivaram > wrote: > > > Hi Mickael, > > > > Thanks for the KIP. > > > > +1 (binding) > > > > On Wed, Apr 25, 2018 at 9:51 AM, Mickael

Re: [VOTE] Kafka 2.0.0 in June 2018

+1 (non-binding). Thanks. On Thu, Apr 19, 2018 at 3:07 PM, Stephane Maarek < steph...@simplemachines.com.au> wrote: > +1 (non binding). Thanks Ismael! > > On Thu., 19 Apr. 2018, 2:47 pm Gwen Shapira, wrote: > > > +1 (binding) > > > > On Wed, Apr 18, 2018 at 11:35 AM, Ismael

[jira] [Resolved] (KAFKA-1716) hang during shutdown of ZookeeperConsumerConnector

[ https://issues.apache.org/jira/browse/KAFKA-1716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1716. -- Resolution: Auto Closed Closing inactive issue. The Scala consumers have been deprecated and no further

[jira] [Resolved] (KAFKA-5287) Messages getting repeated in kafka

[ https://issues.apache.org/jira/browse/KAFKA-5287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5287. -- Resolution: Cannot Reproduce Closing inactive issue. Please reopen with more details., if you think

[jira] [Resolved] (KAFKA-5262) Can't find some consumer group information

[ https://issues.apache.org/jira/browse/KAFKA-5262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5262. -- Resolution: Cannot Reproduce Closing inactive issue. Please reopen with more details., if you think

[jira] [Resolved] (KAFKA-3476) -Xloggc is not recognised by IBM java

[ https://issues.apache.org/jira/browse/KAFKA-3476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3476. -- Resolution: Won't Fix Closing this as we can export the GC values and performance opts. Please reopen

[jira] [Resolved] (KAFKA-6107) SCRAM user add appears to fail if Kafka has never been started

[ https://issues.apache.org/jira/browse/KAFKA-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6107. -- Resolution: Fixed Fix Version/s: 1.1.0 This was fixed in KafkaZkClient changes work. > SC

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

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

Re: [DISCUSS] KIP-269: Substitution Within Configuration Values

> > > >>> need to > > > > > > > >>>worry about the latter if substitutions are only by > opt-in. > > > > > > > >>>- It will be good to get more feedback on this KIP > before > > > > > updating > > > > > > &g

[jira] [Resolved] (KAFKA-2661) Add a unit test for disconnecting idle socket connections

[ https://issues.apache.org/jira/browse/KAFKA-2661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2661. -- Resolution: Fixed SelectorTest.testCloseConnectionInClosingState/testCloseOldestConnection tests

[jira] [Resolved] (KAFKA-4373) Kafka Consumer API jumping offsets

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

[jira] [Resolved] (KAFKA-2284) ConsumerRebalanceListener receives wrong type in partitionOwnership values

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

[jira] [Resolved] (KAFKA-4347) outputStreamId in Kafka spout

[ https://issues.apache.org/jira/browse/KAFKA-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4347. -- Resolution: Invalid Looks like this is related to Apache Storm Kafka connector. Request you raise

[jira] [Resolved] (KAFKA-4124) Handle disk failures gracefully

[ https://issues.apache.org/jira/browse/KAFKA-4124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4124. -- Resolution: Duplicate Some of these requirements are implemented in KIP-112/KIP-113. Pls raise new

[jira] [Resolved] (KAFKA-611) Migration tool and Mirror Maker ignore mirror.topics.whitelist in config

[ https://issues.apache.org/jira/browse/KAFKA-611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-611. - Resolution: Auto Closed mirror.topics.whitelist/blacklist were part of old consumer. also these configs

[jira] [Resolved] (KAFKA-2339) broker becomes unavailable if bad data is passed through the protocol

[ https://issues.apache.org/jira/browse/KAFKA-2339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2339. -- Resolution: Cannot Reproduce Not able to reproduce on latest server. Please reopen if you think

[jira] [Resolved] (KAFKA-2302) Currently iterated chunk is not cleared during consumer shutdown

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

[jira] [Resolved] (KAFKA-1643) message.send.max.retries not respected when no brokers are up

[ https://issues.apache.org/jira/browse/KAFKA-1643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1643. -- Resolution: Auto Closed The Scala producers have been deprecated for a while and no further work

[jira] [Resolved] (KAFKA-1405) Global JSON.globalNumberParser screws up other libraries

[ https://issues.apache.org/jira/browse/KAFKA-1405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1405. -- Resolution: Fixed Old Scala JSON usage is removed in new versions of Kafka > Glo

[jira] [Resolved] (KAFKA-4883) invalid client sasl.jaas.config triggers NullPointerException

[ https://issues.apache.org/jira/browse/KAFKA-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4883. -- Resolution: Fixed Assignee: Manikumar Fix Version/s: 1.2.0 > invalid cli

Re: [VOTE] KIP-211: Revise Expiration Semantics of Consumer Group Offsets

+1 (non-binding) Thanks for the detailed KIP. On Fri, Apr 6, 2018 at 8:54 AM, Guozhang Wang wrote: > Thanks for the KIP! > > +1 (binding) > > On Thu, Apr 5, 2018 at 3:11 PM, Matthias J. Sax > wrote: > > > +1 (binding) > > > > > > -Matthias > > > > On

Re: [DISCUSS] KIP-269: Substitution Within Configuration Values

Hi, Substitution mechanism can be useful to configure regular password configs liken ssl.keystore.password, ssl.truststore.password, etc. This is can be good alternative to previously proposed KIP-76 and will give more options to the user. https://cwiki.apache.org/confluence/display/KAFKA/KIP-

[jira] [Resolved] (KAFKA-6413) ReassignPartitionsCommand#parsePartitionReassignmentData() should give better error message when JSON is malformed

[ https://issues.apache.org/jira/browse/KAFKA-6413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6413. -- Resolution: Duplicate Resolving as duplicate of KAFKA-6084. > ReassignPartitionsComm

Re: [VOTE] KIP-249: Add Delegation Token Operations to Kafka Admin Client

Hi All, The vote has passed with 3 binding votes (Jun, Gwen, Rajini) and 2 non-binding votes (Satish, Viktor). Thanks everyone for the votes. Thanks, Manikumar On Tue, Apr 3, 2018 at 2:46 PM, Rajini Sivaram <rajinisiva...@gmail.com> wrote: > +1 (binding) > > Thanks for the

[jira] [Created] (KAFKA-6741) Transient test failure: SslTransportLayerTest.testNetworkThreadTimeRecorded

Manikumar created KAFKA-6741: Summary: Transient test failure: SslTransportLayerTest.testNetworkThreadTimeRecorded Key: KAFKA-6741 URL: https://issues.apache.org/jira/browse/KAFKA-6741 Project: Kafka

[jira] [Resolved] (KAFKA-6716) discardChannel should be released in MockSelector#completeSend

[ https://issues.apache.org/jira/browse/KAFKA-6716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6716. -- Resolution: Fixed Fix Version/s: 1.2.0 > discardChannel should be released in MockSelec

[jira] [Resolved] (KAFKA-6630) Speed up the processing of TopicDeletionStopReplicaResponseReceived events on the controller

[ https://issues.apache.org/jira/browse/KAFKA-6630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6630. -- Resolution: Fixed Fix Version/s: 1.2.0 > Speed up the process

[jira] [Resolved] (KAFKA-6702) Wrong className in LoggerFactory.getLogger method

[ https://issues.apache.org/jira/browse/KAFKA-6702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6702. -- Resolution: Fixed > Wrong className in LoggerFactory.getLogger met

[jira] [Resolved] (KAFKA-6707) The default value for config of Type.LONG should be *L

[ https://issues.apache.org/jira/browse/KAFKA-6707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6707. -- Resolution: Fixed > The default value for config of Type.LONG should be

Re: [VOTE] KIP-272: Add API version tag to broker's RequestsPerSec metric

+1 (non-binding) On Thu, Mar 29, 2018 at 6:16 PM, Thomas Crayford wrote: > +1 (non-binding) > > On Wed, Mar 28, 2018 at 9:15 PM, Ted Yu wrote: > > > +1 > > > > On Wed, Mar 28, 2018 at 12:05 PM, Mickael Maison < > mickael.mai...@gmail.com > > > > >

Re: [VOTE] KIP-249: Add Delegation Token Operations to Kafka Admin Client

gt; > > Thanks for the KIP. +1 > > > > Jun > > > > On Sun, Jan 21, 2018 at 7:44 AM, Manikumar <manikumar.re...@gmail.com> > > wrote: > > > > > Hi All, > > > > > > I would like to start a vote on KIP-249 which would add deleg

Re: [ANNOUNCE] Apache Kafka 1.1.0 Released

t; >> > >> > >> With these APIs, Kafka can be used for two broad classes of application: > >> > >> ** Building real-time streaming data pipelines that reliably get data > >> > >> between systems or applications. > >> > >> >

Re: [kafka-clients] Re: [VOTE] 1.1.0 RC4

+1 (non-binding) - Verified src, binary artifacts and basic quick start - Verified delegation token operations and docs - Verified dynamic broker configuration and docs. On Tue, Mar 27, 2018 at 6:52 PM, Rajini Sivaram wrote: > Can we get some more votes for this RC so

Re: Producer timeout and retry behavior

Hi, a) If there are no brokers available, producer send() will block up to max_block_ms (default: 6) after which it will throw a TimeoutException. No retries in this case. by-default console producer uses Callback and just logs the error after max_block_ms. b) Current behavior is, If

[jira] [Resolved] (KAFKA-6676) System tests do not handle ZK chroot properly with SCRAM

[ https://issues.apache.org/jira/browse/KAFKA-6676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6676. -- Resolution: Fixed Fix Version/s: 1.1.0 > System tests do not handle ZK chroot prope

[jira] [Resolved] (KAFKA-6680) Fix config initialization in DynamicBrokerConfig

[ https://issues.apache.org/jira/browse/KAFKA-6680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6680. -- Resolution: Fixed Fix Version/s: (was: 1.2.0) 1.1.0 > Fix con

Re: [DISCUSS] KIP-272: Add API version tag to broker's RequestsPerSec metric

Can we retain total RequestsPerSec metric and add new version tag metric? When monitoring with simple jconsole/jmx based tools, It is useful to have total metric to monitor request rate. Thanks, On Wed, Mar 21, 2018 at 11:01 AM, Gwen Shapira wrote: > I love this. Not much

[jira] [Created] (KAFKA-6680) Fix config initialization in DynamicBrokerConfig

Manikumar created KAFKA-6680: Summary: Fix config initialization in DynamicBrokerConfig Key: KAFKA-6680 URL: https://issues.apache.org/jira/browse/KAFKA-6680 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-6338) java.lang.NoClassDefFoundError: org/apache/kafka/common/network/LoginType

[ https://issues.apache.org/jira/browse/KAFKA-6338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6338. -- Resolution: Not A Problem Closing this  in-favor of RANGER-1964 > java.lang.NoClassDefFoundError:

[jira] [Resolved] (KAFKA-6596) Why we can not see any consumer offset produce rate in kafka manager

[ https://issues.apache.org/jira/browse/KAFKA-6596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6596. -- Resolution: Not A Problem I suggest you to reach out kafka-manager mailing list/github community

[jira] [Resolved] (KAFKA-5187) producer.close() times out at 30 seconds

[ https://issues.apache.org/jira/browse/KAFKA-5187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5187. -- Resolution: Not A Problem Please reopen if the issue still exists. > producer.close() times out at

[jira] [Resolved] (KAFKA-4782) change chroot for a kafka instance

[ https://issues.apache.org/jira/browse/KAFKA-4782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4782. -- Resolution: Not A Problem > change chroot for a kafka insta

[jira] [Resolved] (KAFKA-3553) Issue with getting data of next offset after restarting the consumer and producer is always running

[ https://issues.apache.org/jira/browse/KAFKA-3553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3553. -- Resolution: Auto Closed {color:#00}Closing inactive issue. Please raise issue with kafka-python

[jira] [Resolved] (KAFKA-3550) Broker does not honor MetadataRequest api version; always returns v0 MetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-3550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3550. -- Resolution: Fixed Closing as per above comment. > Broker does not honor MetadataRequest api vers

[jira] [Resolved] (KAFKA-3238) Deadlock Mirrormaker consumer not fetching any messages

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

[jira] [Resolved] (KAFKA-1106) HighwaterMarkCheckpoint failure puting broker into a bad state

[ https://issues.apache.org/jira/browse/KAFKA-1106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1106. -- Resolution: Auto Closed Relevant parts of the code is changed an similar exceptions are fixed

[jira] [Resolved] (KAFKA-4027) Leader for a cetain partition unavailable forever

[ https://issues.apache.org/jira/browse/KAFKA-4027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4027. -- Resolution: Duplicate This behavior is changed in KAFKA-5758.  Please reopen if you think the issue

[jira] [Resolved] (KAFKA-4984) Unable to produce or consume when enabling authentication SASL/Kerberos

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

[jira] [Resolved] (KAFKA-5504) Kafka controller is not getting elected

[ https://issues.apache.org/jira/browse/KAFKA-5504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5504. -- Resolution: Not A Problem Closing as per above comments. > Kafka controller is not getting elec

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

[ https://issues.apache.org/jira/browse/KAFKA-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6022. -- Resolution: Not A Problem Please reopen if you think the issue still exists > mirror maker sto

[jira] [Resolved] (KAFKA-5467) setting offset retention minutes to a lower value is not reflecting

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

[jira] [Resolved] (KAFKA-6337) Error for partition [__consumer_offsets,15] to broker

[ https://issues.apache.org/jira/browse/KAFKA-6337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6337. -- Resolution: Cannot Reproduce Please reopen if you think the issue still exists > Error for partit

Re: [VOTE] 1.0.1 RC2

+1 (non-binding) Built src and ran tests Ran core quick start On Sat, Feb 24, 2018 at 8:44 PM, Jakub Scholz wrote: > +1 (non-binding) ... I used the Scala 2.12 binaries and run my tests with > producers / consumers. > > On Thu, Feb 22, 2018 at 1:06 AM, Ewen Cheslack-Postava

[jira] [Resolved] (KAFKA-5809) when zookeeper set acl on path /. then kafka can't connect zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-5809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5809. -- Resolution: Won't Fix either we need to remove the acls on zk node acls or enable Zk SASL

[jira] [Resolved] (KAFKA-2796) add support for reassignment partition to specified logdir

[ https://issues.apache.org/jira/browse/KAFKA-2796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2796. -- Resolution: Fixed Fixed in KIP-113 (KAFKA-5163/KAFKA-5694) > add support for reassignment partit

[jira] [Resolved] (KAFKA-2553) Kafka Consumer Hangs after Network Partition

[ https://issues.apache.org/jira/browse/KAFKA-2553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2553. -- Resolution: Fixed Similar issues are in KAFKA-2169. Pl reopen if the issue still exists > Ka

[jira] [Resolved] (KAFKA-902) Randomize backoff on the clients for metadata requests

[ https://issues.apache.org/jira/browse/KAFKA-902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-902. - Resolution: Fixed Resolving this Duplicate of KAFKA-3878. Pls reopen if you think otherwise. > Random

[jira] [Resolved] (KAFKA-2167) ZkUtils updateEphemeralPath JavaDoc (spelling and correctness)

[ https://issues.apache.org/jira/browse/KAFKA-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2167. -- Resolution: Fixed > ZkUtils updateEphemeralPath JavaDoc (spelling and correctn

[jira] [Created] (KAFKA-6549) Deadlock in ZookeeperClient while processing Controller Events

Manikumar created KAFKA-6549: Summary: Deadlock in ZookeeperClient while processing Controller Events Key: KAFKA-6549 URL: https://issues.apache.org/jira/browse/KAFKA-6549 Project: Kafka Issue

Re: Kafka Log deletion Problem

looks like log segment is not rotated. You can send more data or adjust log.roll.ms/log.segment.bytes configs to rotate segments. On Fri, Feb 2, 2018 at 7:08 PM, SenthilKumar K wrote: > Hello Experts , We have a Kafka Setup running for our analytics pipeline > ...Below

Re: [DISCUSS] KIP-252: Extend ACLs to allow filtering based on ip ranges and subnets

, Feb 1, 2018 at 5:56 PM, Sönke Liebau < soenke.lie...@opencore.com.invalid> wrote: > Hi Manikumar, > > the current proposal indeed leaves out IPv6 addresses, as I was unsure > whether Kafka fully supports that yet to be honest. But it would be > fairly easy to add these to the p

Re: [DISCUSS] KIP-252: Extend ACLs to allow filtering based on ip ranges and subnets

Hi, 1. Do we support IPv6 CIDR/ranges? 2. KAFKA-5713 is mentioned in Related JIRAs section. But there is no mention of wildcard support in the KIP. Thanks, On Thu, Feb 1, 2018 at 4:05 AM, Sönke Liebau < soenke.lie...@opencore.com.invalid> wrote: > Hey everybody, > > following a brief inital

Re: [VOTE] KIP-206: Add support for UUID serialization and deserialization

+1 (non-binding) On Tue, Jan 30, 2018 at 11:50 AM, Ewen Cheslack-Postava wrote: > +1 (binding) > > On Fri, Jan 26, 2018 at 9:16 AM, Colin McCabe wrote: > > > +1 (non-binding) > > > > > > > > On Fri, Jan 26, 2018, at 08:29, Ted Yu wrote: > > > +1 > > > > >

[jira] [Resolved] (KAFKA-6091) Authorization API is called hundred's of times when there are no privileges

[ https://issues.apache.org/jira/browse/KAFKA-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6091. -- Resolution: Fixed Fixed via KAFKA-5547. Please reopen if you think the issue still exists

[jira] [Resolved] (KAFKA-4185) Abstract out password verifier in SaslServer as an injectable dependency

[ https://issues.apache.org/jira/browse/KAFKA-4185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4185. -- Resolution: Duplicate Closing this in favor of KIP-86/KAFKA-4292. Please reopen if you think otherwise

[jira] [Resolved] (KAFKA-3408) consumer rebalance fail

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

[jira] [Resolved] (KAFKA-5617) Update to the list of third-party clients

[ https://issues.apache.org/jira/browse/KAFKA-5617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5617. -- Resolution: Fixed > Update to the list of third-party clie

[jira] [Resolved] (KAFKA-5500) it is impossible to have custom Login Modules for PLAIN SASL mechanism

[ https://issues.apache.org/jira/browse/KAFKA-5500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5500. -- Resolution: Duplicate Closing in favor of KIP-88/KAFKA-4292.  Please reopen if you think otherwise

[jira] [Resolved] (KAFKA-1458) kafka hanging on shutdown

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

[jira] [Resolved] (KAFKA-1475) Kafka consumer stops LeaderFinder/FetcherThreads, but application does not know

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

[jira] [Resolved] (KAFKA-4256) Use IP for ZK broker register

[ https://issues.apache.org/jira/browse/KAFKA-4256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4256. -- Resolution: Won't Fix Closing as per above comment. Pls reopen If the issue still exists. > Use

Re: [VOTE] KIP-86: Configurable SASL callback handlers

Hi, +1 (non-binding) Thanks for the KIP. On Wed, Jan 24, 2018 at 5:00 AM, Jun Rao wrote: > Hi, Rajini, > > Thanks for the KIP. +1 from me. > > Jun > > On Thu, Jan 18, 2018 at 8:58 AM, tao xiao wrote: > > > +1 (non-binding) > > > > On Fri, 19 Jan 2018

[VOTE] KIP-249: Add Delegation Token Operations to Kafka Admin Client

Hi All, I would like to start a vote on KIP-249 which would add delegation token operations to Java Admin Client. We have merged DelegationToken API PR recently. We want to include admin client changes in the upcoming release. This will make the feature complete.

Re: [DISCUSS] KIP-249: Add Delegation Token Operations to Kafka Admin Client

Hi all, We want to include this KIP in the upcoming 1.1.0 release. Please let me know if there are any other comments. If there are no more comments, I'd like to start vote on this KIP. Thanks, On Wed, Jan 17, 2018 at 8:20 AM, Manikumar <manikumar.re...@gmail.com> wrote: > Hi, Jun, &

Re: [DISCUSS] KIP-249: Add Delegation Token Operations to Kafka Admin Client

it seems it's more consistent to pass in hmac as byte[] too. > 2. Does describeDelegationToken() return all tokens? > 3. As Ted mentioned, it would be useful to include the exceptions that can > be thrown in the new apis. > > Jun > > On Tue, Jan 16, 2018 at 10:03 AM, Manikuma

Re: [DISCUSS] KIP-249: Add Delegation Token Operations to Kafka Admin Client

> DelegationToken. > So, it seems it's more consistent to pass in hmac as byte[] too. > 2. Does describeDelegationToken() return all tokens? > 3. As Ted mentioned, it would be useful to include the exceptions that can > be thrown in the new apis. > > Jun > > On Tue

[jira] [Created] (KAFKA-6452) Add documentation for delegation token authentication mechanism

Manikumar created KAFKA-6452: Summary: Add documentation for delegation token authentication mechanism Key: KAFKA-6452 URL: https://issues.apache.org/jira/browse/KAFKA-6452 Project: Kafka Issue

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-4542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4542. -- Resolution: Fixed Fixed via [https://github.com/apache/kafka/pull/3616] > Add authentication ba

[DISCUSS] KIP-249: Add Delegation Token Operations to Kafka Admin Client

Feedback and suggestions are welcome. Thanks Manikumar

[jira] [Created] (KAFKA-6447) Add Delegation Token Operations to KafkaAdminClient

Manikumar created KAFKA-6447: Summary: Add Delegation Token Operations to KafkaAdminClient Key: KAFKA-6447 URL: https://issues.apache.org/jira/browse/KAFKA-6447 Project: Kafka Issue Type: Sub

[jira] [Resolved] (KAFKA-2331) Kafka does not spread partitions in a topic among all consumers evenly

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

[jira] [Resolved] (KAFKA-2329) Consumers balance fails when multiple consumers are started simultaneously.

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

[jira] [Resolved] (KAFKA-2025) In multi-consumer setup - explicit commit, commits on all partitions

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

[jira] [Resolved] (KAFKA-1229) Reload broker config without a restart

[ https://issues.apache.org/jira/browse/KAFKA-1229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1229. -- Resolution: Duplicate Resolving as duplicate of KIP-226/KAFKA-6240. Pls reopen of any concern

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