[jira] [Assigned] (KAFKA-7216) Exception while running kafka-acls.sh from 1.0 env on target Kafka env with 1.1.1

[ https://issues.apache.org/jira/browse/KAFKA-7216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-7216: Assignee: Manikumar > Exception while running kafka-acls.sh from 1.0 env on target Kafka env with

[jira] [Resolved] (KAFKA-7425) Kafka Broker -Unable to start

[ https://issues.apache.org/jira/browse/KAFKA-7425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7425. -- Resolution: Duplicate will handle this as part of KAFKA-7216. > Kafka Broker -Unable to start > -

[jira] [Commented] (KAFKA-7425) Kafka Broker -Unable to start

[ https://issues.apache.org/jira/browse/KAFKA-7425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16622562#comment-16622562 ] Manikumar commented on KAFKA-7425: -- looks like you have used Kafka 1.1+ release kafka-ac

[jira] [Commented] (KAFKA-7422) Huge memory consumption (leak?) by Kafka Producer

[ https://issues.apache.org/jira/browse/KAFKA-7422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16620453#comment-16620453 ] Manikumar commented on KAFKA-7422: -- I don't see any object leak in the thread dump.  I c

[jira] [Resolved] (KAFKA-7388) An equal sign in a property value causes the broker to fail

[ https://issues.apache.org/jira/browse/KAFKA-7388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7388. -- Resolution: Fixed Fix Version/s: 2.1.0 > An equal sign in a property value causes the broker to

[jira] [Resolved] (KAFKA-5789) Deleted topic is recreated when consumer subscribe the deleted one

[ https://issues.apache.org/jira/browse/KAFKA-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5789. -- Resolution: Duplicate Resolving as duplicate of KAFKA-7320/KIP-361 > Deleted topic is recreated when c

[jira] [Resolved] (KAFKA-2219) reassign partition fails with offset 0 being asked for but obviously not there

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

[jira] [Resolved] (KAFKA-2139) Add a separate controller messge queue with higher priority on broker side

[ https://issues.apache.org/jira/browse/KAFKA-2139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2139. -- Resolution: Duplicate Closing this in-favor of KAFKA-4453/KIP-291. > Add a separate controller messge

[jira] [Resolved] (KAFKA-1825) leadership election state is stale and never recovers without all brokers restarting

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

[jira] [Resolved] (KAFKA-1509) Restart of destination broker after unreplicated partition move leaves partitions without leader

[ https://issues.apache.org/jira/browse/KAFKA-1509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1509. -- Resolution: Auto Closed Not able reproduce on new versions. might have fixed in newer versions. Please

[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 clarify wh

[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 on newer

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

[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] [Commented] (KAFKA-7398) Transient test failure: SaslAuthenticatorFailureDelayTest.testInvalidPasswordSaslPlain

[ https://issues.apache.org/jira/browse/KAFKA-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16610773#comment-16610773 ] Manikumar commented on KAFKA-7398: -- cc [~dhruvilshah] > Transient test failure: > Sasl

[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

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

[jira] [Commented] (KAFKA-4544) Add system tests for delegation token based authentication

[ https://issues.apache.org/jira/browse/KAFKA-4544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16606206#comment-16606206 ] Manikumar commented on KAFKA-4544: -- [~asasvari] _>> Initially, I wanted to use console_

[jira] [Commented] (KAFKA-4544) Add system tests for delegation token based authentication

[ https://issues.apache.org/jira/browse/KAFKA-4544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604711#comment-16604711 ] Manikumar commented on KAFKA-4544: -- [~asasvari] Thanks for taking this. I was planning

[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 get the

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

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

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

[jira] [Commented] (KAFKA-4544) Add system tests for delegation token based authentication

[ https://issues.apache.org/jira/browse/KAFKA-4544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16599038#comment-16599038 ] Manikumar commented on KAFKA-4544: -- [~asasvari] If you are interested, Please takeover

[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 data from

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

[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 storage usage

[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 state gets

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

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

[jira] [Assigned] (KAFKA-6789) Add retry logic in AdminClient requests

[ https://issues.apache.org/jira/browse/KAFKA-6789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-6789: Assignee: Manikumar > Add retry logic in AdminClient requests > --

[jira] [Commented] (KAFKA-4321) Make client.id available to MetricReporter and (De)Serializers in clients

[ https://issues.apache.org/jira/browse/KAFKA-4321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16594698#comment-16594698 ] Manikumar commented on KAFKA-4321: -- Passing client.id for MetricReporters is handled in

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

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

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

[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, new Descri

[jira] [Commented] (KAFKA-7314) MirrorMaker example in documentation does not work

[ https://issues.apache.org/jira/browse/KAFKA-7314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16590472#comment-16590472 ] Manikumar commented on KAFKA-7314: -- As I mentioned above, this looks like Docker network

[jira] [Commented] (KAFKA-7314) MirrorMaker example in documentation does not work

[ https://issues.apache.org/jira/browse/KAFKA-7314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16590342#comment-16590342 ] Manikumar commented on KAFKA-7314: -- We have unit/system tests to verify the basic mirror

[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 based consumer

[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 kafka off

[jira] [Commented] (KAFKA-7305) Offsets should not expire at the record-entry level

[ https://issues.apache.org/jira/browse/KAFKA-7305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589251#comment-16589251 ] Manikumar commented on KAFKA-7305: -- You can take a look at recent change related to Off

[jira] [Commented] (KAFKA-7306) Ability for producer to push to topic on remote server via ELB name

[ https://issues.apache.org/jira/browse/KAFKA-7306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589240#comment-16589240 ] Manikumar commented on KAFKA-7306: -- check this: https://stackoverflow.com/questions/386

[jira] [Commented] (KAFKA-7314) MirrorMaker example in documentation does not work

[ https://issues.apache.org/jira/browse/KAFKA-7314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589238#comment-16589238 ] Manikumar commented on KAFKA-7314: -- looks like both consumer/producer properties are poi

[jira] [Commented] (KAFKA-7244) Add note about memory map kernel limits to documentation

[ https://issues.apache.org/jira/browse/KAFKA-7244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589156#comment-16589156 ] Manikumar commented on KAFKA-7244: -- latest docs updated via KAFKA-6343/https://github.co

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

[jira] [Commented] (KAFKA-7165) Error while creating ephemeral at /brokers/ids/BROKER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16588600#comment-16588600 ] Manikumar commented on KAFKA-7165: -- [~pachilo] Please send a mail to dev mailing list fo

[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

[jira] [Commented] (KAFKA-7303) Kafka client is stuck when specifying wrong brokers

[ https://issues.apache.org/jira/browse/KAFKA-7303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16583944#comment-16583944 ] Manikumar commented on KAFKA-7303: -- I think  Kafka Streams API updated in https://issue

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

[jira] [Assigned] (KAFKA-5690) kafka-acls command should be able to list per principal

[ https://issues.apache.org/jira/browse/KAFKA-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-5690: Assignee: Manikumar > kafka-acls command should be able to list per principal > --

[jira] [Commented] (KAFKA-7303) Kafka client is stuck when specifying wrong brokers

[ https://issues.apache.org/jira/browse/KAFKA-7303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16583730#comment-16583730 ] Manikumar commented on KAFKA-7303: -- This was fixed part of KAFKA-6979 / KIP-266 . Now we

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

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

[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.   > PartitionAssignmentState is prote

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

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

[jira] [Commented] (KAFKA-7248) Kafka creating topic with no leader. Issue started showing up after unkerberizing the cluster

[ https://issues.apache.org/jira/browse/KAFKA-7248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16573666#comment-16573666 ] Manikumar commented on KAFKA-7248: -- Did you enable authorizer? If yes, you can try disab

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

[jira] [Commented] (KAFKA-7256) First started Kafka server & leader failure blocks consumers

[ https://issues.apache.org/jira/browse/KAFKA-7256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16573637#comment-16573637 ] Manikumar commented on KAFKA-7256: -- I think this is due to replication factor of "__cons

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

[ https://issues.apache.org/jira/browse/KAFKA-7257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16573612#comment-16573612 ] Manikumar commented on KAFKA-7257: -- To pass configs, we need to use  "--producer-propert

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

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

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

[jira] [Comment Edited] (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:comment-tabpanel&focusedCommentId=16565681#comment-16565681 ] Manikumar edited comment on KAFKA-7226 at 8/1/18 5:37 PM: -- looks

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16565681#comment-16565681 ] Manikumar commented on KAFKA-7226: -- looks like the issue is specific to HDP Kafka distri

[jira] [Issue Comment Deleted] (KAFKA-7229) Failed to dynamically update kafka certificate in kafka 2.0.0

[ https://issues.apache.org/jira/browse/KAFKA-7229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-7229: - Comment: was deleted (was: This may be due to the default value change for "ssl.endpoint.identification.

[jira] [Commented] (KAFKA-7229) Failed to dynamically update kafka certificate in kafka 2.0.0

[ https://issues.apache.org/jira/browse/KAFKA-7229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565625#comment-16565625 ] Manikumar commented on KAFKA-7229: -- This may be due to the default value change for "ss

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

[ https://issues.apache.org/jira/browse/KAFKA-5407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564177#comment-16564177 ] Manikumar commented on KAFKA-5407: -- [~fvegaucr] I am not sure what is happening. It is v

[jira] [Comment Edited] (KAFKA-7165) Error while creating ephemeral at /brokers/ids/BROKER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16563458#comment-16563458 ] Manikumar edited comment on KAFKA-7165 at 7/31/18 10:46 AM: [

[jira] [Commented] (KAFKA-7165) Error while creating ephemeral at /brokers/ids/BROKER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16563458#comment-16563458 ] Manikumar commented on KAFKA-7165: -- [~pachilo]   your solution may work, but we should b

[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 using DeleteTopics

[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] [Commented] (KAFKA-5962) java.io.IOException: Map failed

[ https://issues.apache.org/jira/browse/KAFKA-5962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555738#comment-16555738 ] Manikumar commented on KAFKA-5962: -- some info here: https://issues.apache.org/jira/brows

[jira] [Comment Edited] (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:comment-tabpanel&focusedCommentId=1610#comment-1610 ] Manikumar edited comment on KAFKA-2395 at 7/25/18 10:42 AM: e

[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 though th

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

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

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

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

[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 is up

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

[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: > Validate that

[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 usage of TopicAndP

[jira] [Commented] (KAFKA-6438) NSEE while concurrently creating and deleting a topic

[ https://issues.apache.org/jira/browse/KAFKA-6438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16553212#comment-16553212 ] Manikumar commented on KAFKA-6438: -- This might have been fixed in KAFKA-6630 cleanups. 

[jira] [Commented] (KAFKA-7165) Error while creating ephemeral at /brokers/ids/BROKER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16552098#comment-16552098 ] Manikumar commented on KAFKA-7165: -- [~pachilo]  I think we are waiting for  ZOOKEEPER-29

[jira] [Commented] (KAFKA-7165) Error while creating ephemeral at /brokers/ids/BROKER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16551591#comment-16551591 ] Manikumar commented on KAFKA-7165: -- Looks like related to *KAFKA-6584* > Error while cr

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

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

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

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

[jira] [Updated] (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 updated KAFKA-1420: - Fix Version/s: 2.1.0 > Replace AdminUtils.createOrUpdateTopicPartitionAssignmentPathInZK with > TestUtil

[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 > Replace AdminUtils.crea

[jira] [Commented] (KAFKA-7184) Kafka is going down with issue ERROR Failed to clean up log for __consumer_offsets-0 in dir /tmp/kafkadev2-logs due to IOException (kafka.server.LogDirFailureChannel)

[ https://issues.apache.org/jira/browse/KAFKA-7184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549186#comment-16549186 ] Manikumar commented on KAFKA-7184: -- looks like your data directory is in /tmp/ folder.  

[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 configurable fo

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

[ https://issues.apache.org/jira/browse/KAFKA-7154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16541672#comment-16541672 ] Manikumar commented on KAFKA-7154: -- looks like you are closing the terminal where server

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