[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=16287230#comment-16287230 ] Guozhang Wang commented on KAFKA-6265: -- Note that {{GlobalKTableImpl}} is only constructed in

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

[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=16287218#comment-16287218 ] DHRUV BANSAL commented on KAFKA-6339: - Hello Narendra, Thanks for response. The problem is test keep

[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=16287160#comment-16287160 ] Vikas Lalwani commented on KAFKA-3900: -- We have a 4 node kafka cluster(0.10.2.0). Facing a similar

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

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

[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

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

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

[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=16287012#comment-16287012 ] ASF GitHub Bot commented on KAFKA-6334: --- Github user guozhangwang commented on the issue:

[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=16287011#comment-16287011 ] ASF GitHub Bot commented on KAFKA-6334: --- Github user asfgit closed the pull request at:

[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=16286934#comment-16286934 ] ASF GitHub Bot commented on KAFKA-6150: --- GitHub user guozhangwang opened a pull request:

[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=16286904#comment-16286904 ] Neerja Khattar commented on KAFKA-6336: ---

[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=16286884#comment-16286884 ] Guozhang Wang commented on KAFKA-2319: -- I think this issue still exists, but probably in a slight

[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=16265581#comment-16265581 ] Steven Schlansker commented on KAFKA-6269: -- We just hit a similar issue during a rollout

[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=16286851#comment-16286851 ] huxihx commented on KAFKA-6336: --- [~hachikuji] Seems `ListGroups` request returns manually-assigned groups

[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

[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=16286841#comment-16286841 ] huxihx commented on KAFKA-6341: --- [~ijuma] Thanks for reminding. I forget the fact that each Processor thread

[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

[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

[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=16286767#comment-16286767 ] Ewen Cheslack-Postava commented on KAFKA-6311: -- PR available here:

[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=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=16286726#comment-16286726 ] Jason Gustafson commented on KAFKA-6336: This should have been fixed in KAFKA-3853 which did get

[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=16286612#comment-16286612 ] Ted Yu commented on KAFKA-6335: --- Same error:

[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=16286608#comment-16286608 ] Andrew Olson commented on KAFKA-6334: - [~guozhang] pull request:

[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=16286604#comment-16286604 ] ASF GitHub Bot commented on KAFKA-6334: --- GitHub user noslowerdna opened a pull request:

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

[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

[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

[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

[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=16286384#comment-16286384 ] Neerja Khattar commented on KAFKA-6336: --- Kafka version is 0.10.2 and I don't see groups which were

[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

[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

[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

[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

[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=16286332#comment-16286332 ] Narendra Kumar commented on KAFKA-6339: --- Hi Dhruv, Sorry for the delayed response. This does not

[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=16285968#comment-16285968 ] Alex Dunayevsky edited comment on KAFKA-6343 at 12/11/17 4:16 PM: -- Ismael

[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=16286085#comment-16286085 ] ASF GitHub Bot commented on KAFKA-3940: --- Github user mimaison closed the pull request at:

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

[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=16286021#comment-16286021 ] Randall Hauch commented on KAFKA-5117: -- BTW, the KIP doesn't have to be that complex, since this is a

[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=16286014#comment-16286014 ] Randall Hauch commented on KAFKA-5117: -- This issue is requesting a change in a public API for several

[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=16286004#comment-16286004 ] Michael Golovanov commented on KAFKA-6221: -- [~ijuma] Yes, you are right. I am sorry for mix all

[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=16285985#comment-16285985 ] Ismael Juma commented on KAFKA-6343: Great! Would you be interested in submitting a PR to add this

[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=16285968#comment-16285968 ] Alex Dunayevsky edited comment on KAFKA-6343 at 12/11/17 2:31 PM: -- Ismael

[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=16285968#comment-16285968 ] Alex Dunayevsky edited comment on KAFKA-6343 at 12/11/17 2:28 PM: -- Ismael

[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=16285975#comment-16285975 ] ASF GitHub Bot commented on KAFKA-6121: --- Github user asfgit closed the pull request at:

[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=16285968#comment-16285968 ] Alex Dunayevsky edited comment on KAFKA-6343 at 12/11/17 2:23 PM: -- Ismael

[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=16285968#comment-16285968 ] Alex Dunayevsky edited comment on KAFKA-6343 at 12/11/17 2:23 PM: -- Ismael

[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=16285968#comment-16285968 ] Alex Dunayevsky edited comment on KAFKA-6343 at 12/11/17 2:23 PM: -- Ismael

[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] [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=16285968#comment-16285968 ] Alex Dunayevsky edited comment on KAFKA-6343 at 12/11/17 2:21 PM: -- Ismael

[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=16285968#comment-16285968 ] Alex Dunayevsky commented on KAFKA-6343: Ismael Juma, once again, thank you! This time it looks

[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=16285958#comment-16285958 ] Tom Bentley commented on KAFKA-6283: See KIP-86. Closing this as it is essentially a dupe of

[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=16285957#comment-16285957 ] ASF GitHub Bot commented on KAFKA-6283: --- Github user tombentley closed the pull request at:

[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=16285865#comment-16285865 ] Ismael Juma commented on KAFKA-6343: Thanks for the additional information. The issue seems similar to

[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=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=16285862#comment-16285862 ] Alex Dunayevsky commented on KAFKA-6343: Manikumar, sure {code:bash} $ ulimit -a core file size

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

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

[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=16285841#comment-16285841 ] Manikumar commented on KAFKA-6343: -- Can you post the output of "ulimit -a" and "ps -ef | grep Kafka"

[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=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=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=16285834#comment-16285834 ] Alex Dunayevsky commented on KAFKA-6343: Ismael Juma, we have just reproduced the issue once again

[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=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=16285817#comment-16285817 ] Alex Dunayevsky commented on KAFKA-6343: Ismael Juma, thank you for the answer. What I currently

[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=16285808#comment-16285808 ] Manikumar commented on KAFKA-6337: -- Yes, 30 Seconds should be fine for most of the environments. >

[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

[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=16285802#comment-16285802 ] Ismael Juma commented on KAFKA-6343: Looks like you are running out of file handles. So increasing the

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

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

[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

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

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

[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=16285796#comment-16285796 ] Abhi commented on KAFKA-6337: - [~omkreddy] Please suggest > Error for partition [__consumer_offsets,15] to

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

2017-12-11 Thread Alex Dunayevsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Dunayevsky updated KAFKA-6221: --- Priority: Minor (was: Major) > ReplicaFetcherThread throws UnknownTopicOrPartitionException

  1   2   >