[jira] [Commented] (KAFKA-6265) GlobalKTable missing #queryableStoreName()

2017-12-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16287230#comment-16287230 ] Guozhang Wang commented on KAFKA-6265: -- Note that {{GlobalKTableImpl}} is only constr

[jira] [Created] (KAFKA-6348) Kafka consumer can't restore from coordinator failure

2017-12-11 Thread Renjie Liu (JIRA)
Renjie Liu created KAFKA-6348: - Summary: Kafka consumer can't restore from coordinator failure Key: KAFKA-6348 URL: https://issues.apache.org/jira/browse/KAFKA-6348 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-6339) Integration test with embedded kafka not working

2017-12-11 Thread DHRUV BANSAL (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16287218#comment-16287218 ] DHRUV BANSAL commented on KAFKA-6339: - Hello Narendra, Thanks for response. The proble

[jira] [Commented] (KAFKA-3900) High CPU util on broker

2017-12-11 Thread Vikas Lalwani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16287160#comment-16287160 ] Vikas Lalwani commented on KAFKA-3900: -- We have a 4 node kafka cluster(0.10.2.0). Fac

[jira] [Updated] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Alex Dunayevsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Dunayevsky updated KAFKA-6343: --- Description: *Reproducing*: Create 5k topics *from the code* quickly, without any delays. Wai

[jira] [Resolved] (KAFKA-1530) howto update continuously

2017-12-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-1530. -- Resolution: Fixed > howto update continuously > - > > Ke

[jira] [Assigned] (KAFKA-6106) Postpone normal processing of tasks within a thread until restoration of all tasks have completed

2017-12-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-6106: Assignee: (was: Guozhang Wang) > Postpone normal processing of tasks within a thread un

[jira] [Updated] (KAFKA-1561) Data Loss for Incremented Replica Factor and Leader Election

2017-12-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1561: - Fix Version/s: 0.11.0.0 > Data Loss for Incremented Replica Factor and Leader Election > -

[jira] [Updated] (KAFKA-6334) Minor documentation typo

2017-12-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6334: - Fix Version/s: 1.0.0 > Minor documentation typo > > > Key

[jira] [Resolved] (KAFKA-6334) Minor documentation typo

2017-12-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6334. -- Resolution: Fixed > Minor documentation typo > > > Key:

[jira] [Commented] (KAFKA-6334) Minor documentation typo

2017-12-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16287012#comment-16287012 ] ASF GitHub Bot commented on KAFKA-6334: --- Github user guozhangwang commented on the i

[jira] [Commented] (KAFKA-6334) Minor documentation typo

2017-12-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16287011#comment-16287011 ] ASF GitHub Bot commented on KAFKA-6334: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-6150) Make Repartition Topics Transient

2017-12-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286934#comment-16286934 ] ASF GitHub Bot commented on KAFKA-6150: --- GitHub user guozhangwang opened a pull requ

[jira] [Reopened] (KAFKA-2319) After controlled shutdown: IllegalStateException: Kafka scheduler has not been started

2017-12-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-2319: -- > After controlled shutdown: IllegalStateException: Kafka scheduler has not > been started > --

[jira] [Commented] (KAFKA-6336) when using assign() with kafka consumer the KafkaConsumerGroup command doesnt show those consumers

2017-12-11 Thread Neerja Khattar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286904#comment-16286904 ] Neerja Khattar commented on KAFKA-6336: --- m_partitionlist.con

[jira] [Commented] (KAFKA-2319) After controlled shutdown: IllegalStateException: Kafka scheduler has not been started

2017-12-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286884#comment-16286884 ] Guozhang Wang commented on KAFKA-2319: -- I think this issue still exists, but probably

[jira] [Commented] (KAFKA-6269) KTable state restore fails after rebalance

2017-12-11 Thread Steven Schlansker (JIRATEST)
[ https://issues-test.apache.org/jira/browse/KAFKA-6269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16265581#comment-16265581 ] Steven Schlansker commented on KAFKA-6269: -- We just hit a similar issue duri

[jira] [Commented] (KAFKA-6336) when using assign() with kafka consumer the KafkaConsumerGroup command doesnt show those consumers

2017-12-11 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286851#comment-16286851 ] huxihx commented on KAFKA-6336: --- [~hachikuji] Seems `ListGroups` request returns manually-as

[jira] [Updated] (KAFKA-2319) After controlled shutdown: IllegalStateException: Kafka scheduler has not been started

2017-12-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2319: - Affects Version/s: 1.0.1 > After controlled shutdown: IllegalStateException: Kafka scheduler has n

[jira] [Commented] (KAFKA-6341) 'networkThreadTimeNanos' in KafkaChannel is not thread safe

2017-12-11 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286841#comment-16286841 ] huxihx commented on KAFKA-6341: --- [~ijuma] Thanks for reminding. I forget the fact that each

[jira] [Resolved] (KAFKA-6341) 'networkThreadTimeNanos' in KafkaChannel is not thread safe

2017-12-11 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-6341. --- Resolution: Not A Bug > 'networkThreadTimeNanos' in KafkaChannel is not thread safe >

[jira] [Created] (KAFKA-6346) Consolidate multiple background async log operations

2017-12-11 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6346: Summary: Consolidate multiple background async log operations Key: KAFKA-6346 URL: https://issues.apache.org/jira/browse/KAFKA-6346 Project: Kafka Issue Type

[jira] [Created] (KAFKA-6347) Starting offset breach based log segment deletion never considers active segment

2017-12-11 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6347: Summary: Starting offset breach based log segment deletion never considers active segment Key: KAFKA-6347 URL: https://issues.apache.org/jira/browse/KAFKA-6347 Projec

[jira] [Commented] (KAFKA-6311) Expose Kafka cluster ID in Connect REST API

2017-12-11 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286767#comment-16286767 ] Ewen Cheslack-Postava commented on KAFKA-6311: -- PR available here: https://gi

[jira] [Commented] (KAFKA-6331) Transient failure in kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpointkafka.api.AdminClientIntegrationTest.testAlterReplicaLogDirs

2017-12-11 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286765#comment-16286765 ] Ewen Cheslack-Postava commented on KAFKA-6331: -- ^ Sorry about that, typo in t

[jira] [Commented] (KAFKA-6331) Transient failure in kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpointkafka.api.AdminClientIntegrationTest.testAlterReplicaLogDirs

2017-12-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286759#comment-16286759 ] ASF GitHub Bot commented on KAFKA-6331: --- GitHub user ewencp opened a pull request:

[jira] [Commented] (KAFKA-6336) when using assign() with kafka consumer the KafkaConsumerGroup command doesnt show those consumers

2017-12-11 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286726#comment-16286726 ] Jason Gustafson commented on KAFKA-6336: This should have been fixed in KAFKA-3853

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

2017-12-11 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286612#comment-16286612 ] Ted Yu commented on KAFKA-6335: --- Same error: https://builds.apache.org/job/kafka-trunk-jdk8/

[jira] [Assigned] (KAFKA-6334) Minor documentation typo

2017-12-11 Thread Andrew Olson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Olson reassigned KAFKA-6334: --- Assignee: Andrew Olson > Minor documentation typo > > >

[jira] [Assigned] (KAFKA-2939) Make AbstractConfig.logUnused() tunable for clients

2017-12-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-2939: Assignee: (was: Guozhang Wang) > Make AbstractConfig.logUnused() tunable for clients >

[jira] [Commented] (KAFKA-6334) Minor documentation typo

2017-12-11 Thread Andrew Olson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286608#comment-16286608 ] Andrew Olson commented on KAFKA-6334: - [~guozhang] pull request: https://github.com/ap

[jira] [Assigned] (KAFKA-1056) Evenly Distribute Intervals in OffsetIndex

2017-12-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-1056: Assignee: (was: Guozhang Wang) > Evenly Distribute Intervals in OffsetIndex > -

[jira] [Commented] (KAFKA-6334) Minor documentation typo

2017-12-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286604#comment-16286604 ] ASF GitHub Bot commented on KAFKA-6334: --- GitHub user noslowerdna opened a pull reque

[jira] [Created] (KAFKA-6345) NetworkClient.inFlightRequestCount() is not thread safe, causing ConcurrentModificationExceptions when sensors are read

2017-12-11 Thread radai rosenblatt (JIRA)
radai rosenblatt created KAFKA-6345: --- Summary: NetworkClient.inFlightRequestCount() is not thread safe, causing ConcurrentModificationExceptions when sensors are read Key: KAFKA-6345 URL: https://issues.apache.o

[jira] [Assigned] (KAFKA-967) Use key range in ProducerPerformance

2017-12-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-967: --- Assignee: (was: Guozhang Wang) > Use key range in ProducerPerformance > --

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

2017-12-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-1181: Assignee: (was: Guozhang Wang) > Consolidate brokerList and topicPartitionInfo in Broke

[jira] [Resolved] (KAFKA-1561) Data Loss for Incremented Replica Factor and Leader Election

2017-12-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-1561. -- Resolution: Fixed > Data Loss for Incremented Replica Factor and Leader Election > -

[jira] [Resolved] (KAFKA-5551) StreamThread should not expose methods for testing

2017-12-11 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5551. Resolution: Fixed > StreamThread should not expose methods for testing > ---

[jira] [Updated] (KAFKA-1704) Add PartitionConfig besides LogConfig

2017-12-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1704: - Labels: newbie (was: ) > Add PartitionConfig besides LogConfig >

[jira] [Updated] (KAFKA-1704) Add PartitionConfig besides LogConfig

2017-12-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1704: - Description: Today we only have two places to store configs: server configs which is used to stor

[jira] [Assigned] (KAFKA-1704) Add PartitionConfig besides LogConfig

2017-12-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-1704: Assignee: (was: Guozhang Wang) > Add PartitionConfig besides LogConfig > --

[jira] [Assigned] (KAFKA-1043) Time-consuming FetchRequest could block other request in the response queue

2017-12-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-1043: Assignee: (was: Guozhang Wang) > Time-consuming FetchRequest could block other request

[jira] [Updated] (KAFKA-6106) Postpone normal processing of tasks within a thread until restoration of all tasks have completed

2017-12-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6106: - Labels: newbie++ (was: ) > Postpone normal processing of tasks within a thread until restoration

[jira] [Assigned] (KAFKA-5719) Create a quickstart archetype project for Kafka Streams

2017-12-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5719: Assignee: (was: Guozhang Wang) > Create a quickstart archetype project for Kafka Stream

[jira] [Commented] (KAFKA-6336) when using assign() with kafka consumer the KafkaConsumerGroup command doesnt show those consumers

2017-12-11 Thread Neerja Khattar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286384#comment-16286384 ] Neerja Khattar commented on KAFKA-6336: --- Kafka version is 0.10.2 and I don't see gro

[jira] [Assigned] (KAFKA-5037) Infinite loop if all input topics are unknown at startup

2017-12-11 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-5037: -- Assignee: (was: Matthias J. Sax) > Infinite loop if all input topics are unknown at

[jira] [Assigned] (KAFKA-5397) streams are not recovering from LockException during rebalancing

2017-12-11 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-5397: -- Assignee: (was: Matthias J. Sax) > streams are not recovering from LockException du

[jira] [Assigned] (KAFKA-6124) Revisit default config for internal client with regard to resilience

2017-12-11 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-6124: -- Assignee: (was: Matthias J. Sax) > Revisit default config for internal client with

[jira] [Assigned] (KAFKA-5660) Don't throw TopologyBuilderException during runtime

2017-12-11 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-5660: -- Assignee: (was: Matthias J. Sax) > Don't throw TopologyBuilderException during runt

[jira] [Assigned] (KAFKA-5551) StreamThread should not expose methods for testing

2017-12-11 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-5551: -- Assignee: (was: Matthias J. Sax) > StreamThread should not expose methods for testi

[jira] [Assigned] (KAFKA-4437) Incremental Batch Processing for Kafka Streams

2017-12-11 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-4437: -- Assignee: (was: Matthias J. Sax) > Incremental Batch Processing for Kafka Streams >

[jira] [Assigned] (KAFKA-5524) Streams systems tests should be with EoS

2017-12-11 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-5524: -- Assignee: (was: Matthias J. Sax) > Streams systems tests should be with EoS > -

[jira] [Commented] (KAFKA-6339) Integration test with embedded kafka not working

2017-12-11 Thread Narendra Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286332#comment-16286332 ] Narendra Kumar commented on KAFKA-6339: --- Hi Dhruv, Sorry for the delayed response. T

[jira] [Assigned] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test

2017-12-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5676: Assignee: (was: Guozhang Wang) > MockStreamsMetrics should be in o.a.k.test > -

[jira] [Assigned] (KAFKA-5784) Add a sensor for dropped records in window stores

2017-12-11 Thread siva santhalingam (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] siva santhalingam reassigned KAFKA-5784: Assignee: siva santhalingam > Add a sensor for dropped records in window stores > -

[jira] [Comment Edited] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Alex Dunayevsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285968#comment-16285968 ] Alex Dunayevsky edited comment on KAFKA-6343 at 12/11/17 4:16 PM: --

[jira] [Updated] (KAFKA-6298) Line numbers on log messages are incorrect

2017-12-11 Thread Narendra Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Narendra Kumar updated KAFKA-6298: -- Flags: (was: Patch) > Line numbers on log messages are incorrect > ---

[jira] [Updated] (KAFKA-6298) Line numbers on log messages are incorrect

2017-12-11 Thread Narendra Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Narendra Kumar updated KAFKA-6298: -- Flags: Patch > Line numbers on log messages are incorrect >

[jira] [Commented] (KAFKA-3940) Log should check the return value of dir.mkdirs()

2017-12-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286085#comment-16286085 ] ASF GitHub Bot commented on KAFKA-3940: --- Github user mimaison closed the pull reques

[jira] [Commented] (KAFKA-6298) Line numbers on log messages are incorrect

2017-12-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286059#comment-16286059 ] ASF GitHub Bot commented on KAFKA-6298: --- GitHub user mrnakumar opened a pull request

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

2017-12-11 Thread Vincent Bernat (JIRA)
Vincent Bernat created KAFKA-6344: - Summary: 0.8.2 clients will store invalid configuration in ZK for Kafka 1.0 brokers Key: KAFKA-6344 URL: https://issues.apache.org/jira/browse/KAFKA-6344 Project: K

[jira] [Commented] (KAFKA-5117) Kafka Connect REST endpoints reveal Password typed values

2017-12-11 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286021#comment-16286021 ] Randall Hauch commented on KAFKA-5117: -- BTW, the KIP doesn't have to be that complex,

[jira] [Commented] (KAFKA-5117) Kafka Connect REST endpoints reveal Password typed values

2017-12-11 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286014#comment-16286014 ] Randall Hauch commented on KAFKA-5117: -- This issue is requesting a change in a public

[jira] [Updated] (KAFKA-5117) Kafka Connect REST endpoints reveal Password typed values

2017-12-11 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-5117: - Labels: needs-kip (was: ) > Kafka Connect REST endpoints reveal Password typed values > -

[jira] [Commented] (KAFKA-6221) ReplicaFetcherThread throws UnknownTopicOrPartitionException on topic creation

2017-12-11 Thread Michael Golovanov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286004#comment-16286004 ] Michael Golovanov commented on KAFKA-6221: -- [~ijuma] Yes, you are right. I am sor

[jira] [Commented] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285985#comment-16285985 ] Ismael Juma commented on KAFKA-6343: Great! Would you be interested in submitting a PR

[jira] [Comment Edited] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Alex Dunayevsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285968#comment-16285968 ] Alex Dunayevsky edited comment on KAFKA-6343 at 12/11/17 2:31 PM: --

[jira] [Comment Edited] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Alex Dunayevsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285968#comment-16285968 ] Alex Dunayevsky edited comment on KAFKA-6343 at 12/11/17 2:28 PM: --

[jira] [Commented] (KAFKA-6121) Restore and global consumer should not use auto.offset.reset

2017-12-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285975#comment-16285975 ] ASF GitHub Bot commented on KAFKA-6121: --- Github user asfgit closed the pull request

[jira] [Comment Edited] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Alex Dunayevsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285968#comment-16285968 ] Alex Dunayevsky edited comment on KAFKA-6343 at 12/11/17 2:23 PM: --

[jira] [Comment Edited] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Alex Dunayevsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285968#comment-16285968 ] Alex Dunayevsky edited comment on KAFKA-6343 at 12/11/17 2:23 PM: --

[jira] [Comment Edited] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Alex Dunayevsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285968#comment-16285968 ] Alex Dunayevsky edited comment on KAFKA-6343 at 12/11/17 2:23 PM: --

[jira] [Comment Edited] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Alex Dunayevsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285968#comment-16285968 ] Alex Dunayevsky edited comment on KAFKA-6343 at 12/11/17 2:21 PM: --

[jira] [Assigned] (KAFKA-5965) Remove Deprecated AdminClient from Streams Resetter Tool

2017-12-11 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-5965: -- Assignee: (was: Bill Bejeck) > Remove Deprecated AdminClient from Streams Resetter Tool > -

[jira] [Assigned] (KAFKA-5784) Add a sensor for dropped records in window stores

2017-12-11 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-5784: -- Assignee: (was: Bill Bejeck) > Add a sensor for dropped records in window stores >

[jira] [Commented] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Alex Dunayevsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285968#comment-16285968 ] Alex Dunayevsky commented on KAFKA-6343: Ismael Juma, once again, thank you! This

[jira] [Commented] (KAFKA-6283) Configuration of custom SCRAM SaslServer implementations

2017-12-11 Thread Tom Bentley (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285958#comment-16285958 ] Tom Bentley commented on KAFKA-6283: See KIP-86. Closing this as it is essentially a d

[jira] [Resolved] (KAFKA-6283) Configuration of custom SCRAM SaslServer implementations

2017-12-11 Thread Tom Bentley (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tom Bentley resolved KAFKA-6283. Resolution: Duplicate > Configuration of custom SCRAM SaslServer implementations > -

[jira] [Commented] (KAFKA-6283) Configuration of custom SCRAM SaslServer implementations

2017-12-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285957#comment-16285957 ] ASF GitHub Bot commented on KAFKA-6283: --- Github user tombentley closed the pull requ

[jira] [Commented] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285865#comment-16285865 ] Ismael Juma commented on KAFKA-6343: Thanks for the additional information. The issue

[jira] [Comment Edited] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Alex Dunayevsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285862#comment-16285862 ] Alex Dunayevsky edited comment on KAFKA-6343 at 12/11/17 1:02 PM: --

[jira] [Commented] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Alex Dunayevsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285862#comment-16285862 ] Alex Dunayevsky commented on KAFKA-6343: Manikumar, sure {code:bash} $ ulimit -a

[jira] [Updated] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Alex Dunayevsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Dunayevsky updated KAFKA-6343: --- Description: *Reproducing*: Create 5k topics *from the code* quickly, without any delays. Wai

[jira] [Updated] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Alex Dunayevsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Dunayevsky updated KAFKA-6343: --- Description: *Reproducing*: Create 5k topics *from the code* quickly, without any delays. Wai

[jira] [Commented] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285841#comment-16285841 ] Manikumar commented on KAFKA-6343: -- Can you post the output of "ulimit -a" and "ps -ef

[jira] [Comment Edited] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Alex Dunayevsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285834#comment-16285834 ] Alex Dunayevsky edited comment on KAFKA-6343 at 12/11/17 12:25 PM: -

[jira] [Comment Edited] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Alex Dunayevsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285834#comment-16285834 ] Alex Dunayevsky edited comment on KAFKA-6343 at 12/11/17 12:22 PM: -

[jira] [Commented] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Alex Dunayevsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285834#comment-16285834 ] Alex Dunayevsky commented on KAFKA-6343: Ismael Juma, we have just reproduced the

[jira] [Comment Edited] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Alex Dunayevsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285834#comment-16285834 ] Alex Dunayevsky edited comment on KAFKA-6343 at 12/11/17 12:22 PM: -

[jira] [Commented] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Alex Dunayevsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285817#comment-16285817 ] Alex Dunayevsky commented on KAFKA-6343: Ismael Juma, thank you for the answer. Wh

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

2017-12-11 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285808#comment-16285808 ] Manikumar commented on KAFKA-6337: -- Yes, 30 Seconds should be fine for most of the envir

[jira] [Updated] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Alex Dunayevsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Dunayevsky updated KAFKA-6343: --- Environment: RHEL 7, RAM 755GB per host (was: RHEL 7, RAM 755GB) > OOM as the result of creat

[jira] [Commented] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285802#comment-16285802 ] Ismael Juma commented on KAFKA-6343: Looks like you are running out of file handles. S

[jira] [Updated] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Alex Dunayevsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Dunayevsky updated KAFKA-6343: --- Description: *Reproducing*: Create 5k topics *from the code* quickly, without any delays. Wai

[jira] [Updated] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Alex Dunayevsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Dunayevsky updated KAFKA-6343: --- Description: *Reproducing*: Create 5k topics *from the code* quickly, without any delays. Wai

[jira] [Updated] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Alex Dunayevsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Dunayevsky updated KAFKA-6343: --- Description: Create 5k topics *from the code* quickly, without any delays. Wait until brokers

[jira] [Updated] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Alex Dunayevsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Dunayevsky updated KAFKA-6343: --- Description: *Reproducing*: Create 5k topics *from the code* quickly, without any delays. Wai

[jira] [Updated] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Alex Dunayevsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Dunayevsky updated KAFKA-6343: --- Description: *Reproducing*: Create 5k topics *from the code* quickly, without any delays. Wai

[jira] [Created] (KAFKA-6343) OOM as the result of creation of 5k topics

2017-12-11 Thread Alex Dunayevsky (JIRA)
Alex Dunayevsky created KAFKA-6343: -- Summary: OOM as the result of creation of 5k topics Key: KAFKA-6343 URL: https://issues.apache.org/jira/browse/KAFKA-6343 Project: Kafka Issue Type: Bug

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

2017-12-11 Thread Abhi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285796#comment-16285796 ] Abhi commented on KAFKA-6337: - [~omkreddy] Please suggest > Error for partition [__consumer_

  1   2   >