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

2018-04-12 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6789: Summary: Add retry logic in AdminClient requests Key: KAFKA-6789 URL: https://issues.apache.org/jira/browse/KAFKA-6789 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-6788) Grouping consumer requests per consumer coordinator in admin client

2018-04-12 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6788: Summary: Grouping consumer requests per consumer coordinator in admin client Key: KAFKA-6788 URL: https://issues.apache.org/jira/browse/KAFKA-6788 Project: Kafka

[jira] [Comment Edited] (KAFKA-6787) enumerate SampledStat.samples got null item

2018-04-12 Thread Qiang Zhao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16436802#comment-16436802 ] Qiang Zhao edited comment on KAFKA-6787 at 4/13/18 4:52 AM: It

[jira] [Comment Edited] (KAFKA-6787) enumerate SampledStat.samples got null item

2018-04-12 Thread Qiang Zhao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16436802#comment-16436802 ] Qiang Zhao edited comment on KAFKA-6787 at 4/13/18 4:52 AM: It

[jira] [Commented] (KAFKA-6787) enumerate SampledStat.samples got null item

2018-04-12 Thread Qiang Zhao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16436802#comment-16436802 ] Qiang Zhao commented on KAFKA-6787: --- It's critical and hard to fix. Home someone else ca

[jira] [Assigned] (KAFKA-6778) DescribeConfigs does not return error for non-existent topic

2018-04-12 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-6778: Assignee: Manikumar > DescribeConfigs does not return error for non-existent topic > --

[jira] [Updated] (KAFKA-6787) enumerate SampledStat.samples got null item

2018-04-12 Thread Qiang Zhao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qiang Zhao updated KAFKA-6787: -- Description: java.lang.NullPointerException at org.apache.kafka.common.metrics.stats.SampledStat.purgeO

[jira] [Created] (KAFKA-6787) enumerate SampledStat.samples got null item

2018-04-12 Thread Qiang Zhao (JIRA)
Qiang Zhao created KAFKA-6787: - Summary: enumerate SampledStat.samples got null item Key: KAFKA-6787 URL: https://issues.apache.org/jira/browse/KAFKA-6787 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-6649) ReplicaFetcher stopped after non fatal exception is thrown

2018-04-12 Thread Srinivas Dhruvakumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16436678#comment-16436678 ] Srinivas Dhruvakumar commented on KAFKA-6649: - [~hachikuji] - We are no longer

[jira] [Updated] (KAFKA-6784) FindCoordinatorResponse cannot be cast to FetchResponse

2018-04-12 Thread Qiang Zhao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qiang Zhao updated KAFKA-6784: -- Remaining Estimate: 48h (was: 1h) Original Estimate: 48h (was: 1h) > FindCoordinatorResponse cann

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

2018-04-12 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16436669#comment-16436669 ] Ted Yu commented on KAFKA-6335: --- Haven't seen this test fail lately. > SimpleAclAuthorizerT

[jira] [Commented] (KAFKA-6784) FindCoordinatorResponse cannot be cast to FetchResponse

2018-04-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16436661#comment-16436661 ] ASF GitHub Bot commented on KAFKA-6784: --- koqizhao opened a new pull request #4865: K

[jira] [Created] (KAFKA-6786) Remove additional configs in StreamsStandbyTask

2018-04-12 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6786: Summary: Remove additional configs in StreamsStandbyTask Key: KAFKA-6786 URL: https://issues.apache.org/jira/browse/KAFKA-6786 Project: Kafka Issue Type: Imp

[jira] [Commented] (KAFKA-6777) Wrong reaction on Out Of Memory situation

2018-04-12 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16436445#comment-16436445 ] huxihx commented on KAFKA-6777: --- A possible way is to diagnose the GC logs to see why it spe

[jira] [Commented] (KAFKA-6767) OffsetCheckpoint write assumes parent directory exists

2018-04-12 Thread Steven Schlansker (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16436442#comment-16436442 ] Steven Schlansker commented on KAFKA-6767: -- If you expect it to be created as a p

[jira] [Commented] (KAFKA-6234) Transient failure in kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpoint

2018-04-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16436430#comment-16436430 ] ASF GitHub Bot commented on KAFKA-6234: --- hachikuji closed pull request #4238: KAFKA-

[jira] [Commented] (KAFKA-6767) OffsetCheckpoint write assumes parent directory exists

2018-04-12 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16436409#comment-16436409 ] Matthias J. Sax commented on KAFKA-6767: The corresponding task directory is creat

[jira] [Commented] (KAFKA-6782) GlobalStateStore never finishes restoring when consuming transactional messages

2018-04-12 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16436252#comment-16436252 ] Matthias J. Sax commented on KAFKA-6782: Thanks for reporting this issue. Make sen

[jira] [Commented] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer`

2018-04-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16436132#comment-16436132 ] ASF GitHub Bot commented on KAFKA-6592: --- guozhangwang opened a new pull request #486

[jira] [Updated] (KAFKA-6782) GlobalStateStore never finishes restoring when consuming transactional messages

2018-04-12 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6782: --- Priority: Major (was: Blocker) > GlobalStateStore never finishes restoring when consuming tra

[jira] [Commented] (KAFKA-6785) Add Trogdor documentation

2018-04-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16436035#comment-16436035 ] ASF GitHub Bot commented on KAFKA-6785: --- cmccabe opened a new pull request #4862: KA

[jira] [Created] (KAFKA-6785) Add Trogdor documentation

2018-04-12 Thread Colin P. McCabe (JIRA)
Colin P. McCabe created KAFKA-6785: -- Summary: Add Trogdor documentation Key: KAFKA-6785 URL: https://issues.apache.org/jira/browse/KAFKA-6785 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-6782) GlobalStateStore never finishes restoring when consuming transactional messages

2018-04-12 Thread Lingxiao WANG (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lingxiao WANG updated KAFKA-6782: - Description: Same problem with https://issues.apache.org/jira/browse/KAFKA-6190, but his proposit

[jira] [Updated] (KAFKA-6782) GlobalStateStore never finishes restoring when consuming transactional messages

2018-04-12 Thread Lingxiao WANG (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lingxiao WANG updated KAFKA-6782: - Description: Same problem with https://issues.apache.org/jira/browse/KAFKA-6190, but his proposit

[jira] [Commented] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer`

2018-04-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435886#comment-16435886 ] ASF GitHub Bot commented on KAFKA-6592: --- guozhangwang closed pull request #4797: KAF

[jira] [Assigned] (KAFKA-6780) log cleaner shouldn't clean messages beyond high watermark

2018-04-12 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-6780: -- Assignee: Anna Povzner > log cleaner shouldn't clean messages beyond high watermark > -

[jira] [Comment Edited] (KAFKA-5065) AbstractCoordinator.ensureCoordinatorReady() stuck in loop if absent any bootstrap servers

2018-04-12 Thread Qiang Zhao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435030#comment-16435030 ] Qiang Zhao edited comment on KAFKA-5065 at 4/12/18 3:29 PM: it

[jira] [Commented] (KAFKA-6783) consumer poll(timeout) blocked infinitely when no available bootstrap server

2018-04-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435751#comment-16435751 ] ASF GitHub Bot commented on KAFKA-6783: --- koqizhao opened a new pull request #4861: K

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

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

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

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

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

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

[jira] [Commented] (KAFKA-6783) consumer poll(timeout) blocked infinitely when no available bootstrap server

2018-04-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435724#comment-16435724 ] ASF GitHub Bot commented on KAFKA-6783: --- koqizhao opened a new pull request #4860: K

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

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

[jira] [Created] (KAFKA-6784) FindCoordinatorResponse cannot be cast to FetchResponse

2018-04-12 Thread Qiang Zhao (JIRA)
Qiang Zhao created KAFKA-6784: - Summary: FindCoordinatorResponse cannot be cast to FetchResponse Key: KAFKA-6784 URL: https://issues.apache.org/jira/browse/KAFKA-6784 Project: Kafka Issue Type: B

[jira] [Commented] (KAFKA-6762) log-cleaner thread terminates due to java.lang.IllegalStateException

2018-04-12 Thread Ricardo Bartolome (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435653#comment-16435653 ] Ricardo Bartolome commented on KAFKA-6762: -- Hello [~yuzhih...@gmail.com]. We enab

[jira] [Created] (KAFKA-6783) consumer poll(timeout) blocked infinitely when no available bootstrap server

2018-04-12 Thread Qiang Zhao (JIRA)
Qiang Zhao created KAFKA-6783: - Summary: consumer poll(timeout) blocked infinitely when no available bootstrap server Key: KAFKA-6783 URL: https://issues.apache.org/jira/browse/KAFKA-6783 Project: Kafka

[jira] [Commented] (KAFKA-1786) implement a global configuration feature for brokers

2018-04-12 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435598#comment-16435598 ] Manikumar commented on KAFKA-1786: -- looks like this requirement is covered in Dynamic Bro

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

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

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

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

[jira] [Commented] (KAFKA-6775) AbstractProcessor created in SimpleBenchmark should call super#init

2018-04-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435421#comment-16435421 ] ASF GitHub Bot commented on KAFKA-6775: --- jiminhsieh opened a new pull request #4859:

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

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

[jira] [Updated] (KAFKA-2021) Consolidate test classes for KafkaConfig

2018-04-12 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-2021: - Description: * We have kafka.server.KafkaConfigTest, KafkaConfigConfigDefTest and kafka.unit.KafkaTest (i

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

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

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

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

[jira] [Comment Edited] (KAFKA-6535) Set default retention ms for Streams repartition topics to Long.MAX_VALUE

2018-04-12 Thread Khaireddine Rezgui (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435307#comment-16435307 ] Khaireddine Rezgui edited comment on KAFKA-6535 at 4/12/18 10:27 AM: ---

[jira] [Commented] (KAFKA-6535) Set default retention ms for Streams repartition topics to Long.MAX_VALUE

2018-04-12 Thread Khaireddine Rezgui (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435307#comment-16435307 ] Khaireddine Rezgui commented on KAFKA-6535: --- Hi guys, i updated the  [https://cw

[jira] [Created] (KAFKA-6782) GlobalStateStore never finishes restoring when consuming transactional messages

2018-04-12 Thread Lingxiao WANG (JIRA)
Lingxiao WANG created KAFKA-6782: Summary: GlobalStateStore never finishes restoring when consuming transactional messages Key: KAFKA-6782 URL: https://issues.apache.org/jira/browse/KAFKA-6782 Project

[jira] [Commented] (KAFKA-5065) AbstractCoordinator.ensureCoordinatorReady() stuck in loop if absent any bootstrap servers

2018-04-12 Thread Qiang Zhao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435030#comment-16435030 ] Qiang Zhao commented on KAFKA-5065: --- it's found in 1.1.0 as well. I made another fix: [