[jira] [Commented] (KAFKA-7160) Add check for group ID length

2018-07-19 Thread Sayan Biswas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16548889#comment-16548889 ] Sayan Biswas commented on KAFKA-7160: - Hi, I've assigned this issue to myself. Even I

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

2018-07-19 Thread Dhruvil Shah (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16548907#comment-16548907 ] Dhruvil Shah commented on KAFKA-7184: - What kind of storage are you using? Could you

[jira] [Updated] (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)

2018-07-19 Thread Sandeep Muddamsetty (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sandeep Muddamsetty updated KAFKA-7184: --- Attachment: server.log.2018-07-18-15 > Kafka is going down with issue ERROR Failed to

[jira] [Updated] (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)

2018-07-19 Thread Sandeep Muddamsetty (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sandeep Muddamsetty updated KAFKA-7184: --- Attachment: log-cleaner.log > Kafka is going down with issue ERROR Failed to clean up

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

2018-07-19 Thread Sandeep Muddamsetty (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16548927#comment-16548927 ] Sandeep Muddamsetty commented on KAFKA-7184: [~dhruvilshah] Please find the

[jira] [Commented] (KAFKA-6884) ConsumerGroupCommand should use new AdminClient

2018-07-19 Thread Attila Sasvari (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549082#comment-16549082 ] Attila Sasvari commented on KAFKA-6884: --- pull request was merged, thanks for the re

[jira] [Updated] (KAFKA-7172) Prometheus /metrics http endpoint for monitoring integration

2018-07-19 Thread Hari Sekhon (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hari Sekhon updated KAFKA-7172: --- Description: Feature Request to add Prometheus /metrics http endpoint for monitoring integration: [

[jira] [Commented] (KAFKA-3352) Avoid DNS reverse lookups

2018-07-19 Thread Marco Brade (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549153#comment-16549153 ] Marco Brade commented on KAFKA-3352: I'm currently facing a super slow Kafka client s

[jira] [Commented] (KAFKA-7160) Add check for group ID length

2018-07-19 Thread lambdaliu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549162#comment-16549162 ] lambdaliu commented on KAFKA-7160: -- Hi, [~Bitswazsky] [~a.bircakovic] Sorry for the late

[jira] [Commented] (KAFKA-7172) Prometheus /metrics http endpoint for monitoring integration

2018-07-19 Thread Stevo Slavic (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549169#comment-16549169 ] Stevo Slavic commented on KAFKA-7172: - [~harisekhon] have you considered [https://git

[jira] [Comment Edited] (KAFKA-7160) Add check for group ID length

2018-07-19 Thread lambdaliu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549162#comment-16549162 ] lambdaliu edited comment on KAFKA-7160 at 7/19/18 12:02 PM: H

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

2018-07-19 Thread Manikumar (JIRA)
[ 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] [Updated] (KAFKA-7182) SASL/OAUTHBEARER client response is missing %x01 separators

2018-07-19 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-7182: -- Priority: Blocker (was: Minor) > SASL/OAUTHBEARER client response is missing %x01 separators >

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

2018-07-19 Thread Sandeep Muddamsetty (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549286#comment-16549286 ] Sandeep Muddamsetty commented on KAFKA-7184: [~omkreddy] Yes . My log locati

[jira] [Resolved] (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)

2018-07-19 Thread Dhruvil Shah (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dhruvil Shah resolved KAFKA-7184. - Resolution: Not A Problem > Kafka is going down with issue ERROR Failed to clean up log for > __

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

2018-07-19 Thread Dhruvil Shah (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549336#comment-16549336 ] Dhruvil Shah commented on KAFKA-7184: - [~smuddamsetty] after reaching the retention p

[jira] [Assigned] (KAFKA-6960) Remove the methods from the internal Scala AdminClient that are provided by the new AdminClient

2018-07-19 Thread Attila Sasvari (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari reassigned KAFKA-6960: - Assignee: Attila Sasvari > Remove the methods from the internal Scala AdminClient that a

[jira] [Commented] (KAFKA-3514) Stream timestamp computation needs some further thoughts

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549398#comment-16549398 ] ASF GitHub Bot commented on KAFKA-3514: --- guozhangwang closed pull request #5382: KA

[jira] [Assigned] (KAFKA-3514) Stream timestamp computation needs some further thoughts

2018-07-19 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-3514: -- Assignee: Guozhang Wang (was: Matthias J. Sax) > Stream timestamp computation needs s

[jira] [Commented] (KAFKA-6960) Remove the methods from the internal Scala AdminClient that are provided by the new AdminClient

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549527#comment-16549527 ] ASF GitHub Bot commented on KAFKA-6960: --- asasvari opened a new pull request #5395:

[jira] [Commented] (KAFKA-7182) SASL/OAUTHBEARER client response is missing %x01 separators

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549542#comment-16549542 ] ASF GitHub Bot commented on KAFKA-7182: --- rajinisivaram closed pull request #5391: K

[jira] [Resolved] (KAFKA-7182) SASL/OAUTHBEARER client response is missing %x01 separators

2018-07-19 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-7182. --- Resolution: Fixed Reviewer: Rajini Sivaram Fix Version/s: 2.0.0 > SASL/OAUTHB

[jira] [Resolved] (KAFKA-1420) Replace AdminUtils.createOrUpdateTopicPartitionAssignmentPathInZK with TestUtils.createTopic in unit tests

2018-07-19 Thread Manikumar (JIRA)
[ 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] [Updated] (KAFKA-1420) Replace AdminUtils.createOrUpdateTopicPartitionAssignmentPathInZK with TestUtils.createTopic in unit tests

2018-07-19 Thread Manikumar (JIRA)
[ 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] [Updated] (KAFKA-7138) Kafka Connect - Make errors.deadletterqueue.topic.replication.factor default consistent

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-7138: -- Component/s: KafkaConnect config > Kafka Connect - Make errors.deadletterqueue.topic.r

[jira] [Updated] (KAFKA-7113) AdminClient.create has an infinite retry loop bug

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-7113: -- Component/s: admin > AdminClient.create has an infinite retry loop bug > --

[jira] [Updated] (KAFKA-6781) Transient failure in KafkaAdminClientTest.testDescribeConsumerGroupOffsets

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6781: -- Component/s: unit tests admin > Transient failure in KafkaAdminClientTest.testDescribe

[jira] [Updated] (KAFKA-6369) General wildcard support for ACL's in kafka

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6369: -- Component/s: security > General wildcard support for ACL's in kafka > -

[jira] [Updated] (KAFKA-5889) MetricsTest is flaky

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5889: -- Component/s: unit tests > MetricsTest is flaky > > > Key: KAFKA-58

[jira] [Updated] (KAFKA-5297) Broker can take a long time to shut down if there are many active log segments

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5297: -- Component/s: log > Broker can take a long time to shut down if there are many active log segments > ---

[jira] [Updated] (KAFKA-5444) Producer.send() will hang 8+ hours

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5444: -- Component/s: producer > Producer.send() will hang 8+ hours > -- > >

[jira] [Updated] (KAFKA-5261) Performance improvement of SimpleAclAuthorizer

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5261: -- Component/s: security > Performance improvement of SimpleAclAuthorizer > --

[jira] [Updated] (KAFKA-5165) Kafka Logs Cleanup Not happening, Huge File Growth - Windows

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5165: -- Component/s: log > Kafka Logs Cleanup Not happening, Huge File Growth - Windows > -

[jira] [Updated] (KAFKA-4715) Consumer/Producer config does not work with related enums

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4715: -- Component/s: config clients > Consumer/Producer config does not work with related enum

[jira] [Updated] (KAFKA-3704) Improve mechanism for compression stream block size selection in KafkaProducer

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3704: -- Component/s: producer compression > Improve mechanism for compression stream block si

[jira] [Updated] (KAFKA-3539) KafkaProducer.send() may block even though it returns the Future

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3539: -- Component/s: producer > KafkaProducer.send() may block even though it returns the Future > ---

[jira] [Updated] (KAFKA-2387) Improve KafkaConsumer API

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-2387: -- Component/s: consumer > Improve KafkaConsumer API > - > > Key:

[jira] [Updated] (KAFKA-2559) Add ducktape task to gradle

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-2559: -- Component/s: build > Add ducktape task to gradle > --- > > Key:

[jira] [Updated] (KAFKA-2424) Consider introducing lint-like tool for Scala

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-2424: -- Component/s: build > Consider introducing lint-like tool for Scala > --

[jira] [Updated] (KAFKA-2359) New consumer - partitions auto assigned only on poll

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-2359: -- Component/s: consumer > New consumer - partitions auto assigned only on poll >

[jira] [Commented] (KAFKA-7044) kafka-consumer-groups.sh NullPointerException describing round robin or sticky assignors

2018-07-19 Thread ErikPearson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549675#comment-16549675 ] ErikPearson commented on KAFKA-7044: We are running Confluent Platform 4.1.1 and are

[jira] [Updated] (KAFKA-6969) AdminClient should provide a way to get the version of a node

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6969: -- Component/s: admin > AdminClient should provide a way to get the version of a node > --

[jira] [Updated] (KAFKA-6533) Kafka log cleaner stopped due to "cannot allocate memory" error

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6533: -- Component/s: log > Kafka log cleaner stopped due to "cannot allocate memory" error > --

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

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-2319: -- Component/s: core > After controlled shutdown: IllegalStateException: Kafka scheduler has not > been s

[jira] [Updated] (KAFKA-7059) Offer new constructor on ProducerRecord

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-7059: -- Component/s: producer > Offer new constructor on ProducerRecord > ---

[jira] [Updated] (KAFKA-7171) KafkaPerformanceProducer crashes with same transaction id.

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-7171: -- Component/s: producer > KafkaPerformanceProducer crashes with same transaction id. > -

[jira] [Updated] (KAFKA-7078) Kafka 1.0.1 Broker version crashes when deleting log

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-7078: -- Component/s: log > Kafka 1.0.1 Broker version crashes when deleting log > -

[jira] [Updated] (KAFKA-2260) Allow specifying expected offset on produce

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-2260: -- Component/s: producer > Allow specifying expected offset on produce >

[jira] [Updated] (KAFKA-2510) Prevent broker from re-replicating / losing data due to disk misconfiguration

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-2510: -- Component/s: replication > Prevent broker from re-replicating / losing data due to disk misconfiguratio

[jira] [Updated] (KAFKA-2318) replica manager repeatedly tries to fetch from partitions already moved during controlled shutdown

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-2318: -- Component/s: replication > replica manager repeatedly tries to fetch from partitions already moved > d

[jira] [Updated] (KAFKA-4545) tombstone needs to be removed after delete.retention.ms has passed after it has been cleaned

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4545: -- Component/s: log > tombstone needs to be removed after delete.retention.ms has passed after it > has b

[jira] [Updated] (KAFKA-3062) Read from kafka replication to get data likely Version based

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3062: -- Component/s: replication > Read from kafka replication to get data likely Version based > -

[jira] [Updated] (KAFKA-5586) Handle client disconnects during JoinGroup

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5586: -- Component/s: consumer > Handle client disconnects during JoinGroup > --

[jira] [Updated] (KAFKA-6449) KafkaConsumer happen 40s timeOut when poll data after pollThread sleep more than request.timeout.ms

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6449: -- Component/s: consumer > KafkaConsumer happen 40s timeOut when poll data after pollThread sleep more >

[jira] [Updated] (KAFKA-6471) seekToEnd and seek give unclear results for Consumer with read_committed isolation level

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6471: -- Component/s: consumer > seekToEnd and seek give unclear results for Consumer with read_committed > iso

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

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6281: -- Component/s: producer > Kafka JavaAPI Producer failed with NotLeaderForPartitionException > --

[jira] [Updated] (KAFKA-6572) kafka-consumer-groups does not reset offsets to specified datetime correctly

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6572: -- Component/s: consumer > kafka-consumer-groups does not reset offsets to specified datetime correctly >

[jira] [Updated] (KAFKA-6671) Consumer group coordinator releases group before new coordinator is ready.

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6671: -- Component/s: consumer > Consumer group coordinator releases group before new coordinator is ready. > --

[jira] [Updated] (KAFKA-6626) Performance bottleneck in Kafka Connect sendRecords

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6626: -- Component/s: KafkaConnect > Performance bottleneck in Kafka Connect sendRecords > -

[jira] [Updated] (KAFKA-6632) Very slow hashCode methods in Kafka Connect types

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6632: -- Component/s: KafkaConnect > Very slow hashCode methods in Kafka Connect types > ---

[jira] [Updated] (KAFKA-6994) KafkaConsumer.poll throwing AuthorizationException timeout-dependent

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6994: -- Component/s: consumer > KafkaConsumer.poll throwing AuthorizationException timeout-dependent >

[jira] [Updated] (KAFKA-7083) maxTickMessages in ConsumerGroup option

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-7083: -- Component/s: consumer > maxTickMessages in ConsumerGroup option > -

[jira] [Updated] (KAFKA-6939) Change the default of log.message.timestamp.difference.max.ms to 500 years

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6939: -- Component/s: log > Change the default of log.message.timestamp.difference.max.ms to 500 years > ---

[jira] [Updated] (KAFKA-6904) DynamicBrokerReconfigurationTest#testAdvertisedListenerUpdate is flaky

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6904: -- Component/s: unit tests > DynamicBrokerReconfigurationTest#testAdvertisedListenerUpdate is flaky >

[jira] [Updated] (KAFKA-6013) Controller getting stuck

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6013: -- Component/s: controller > Controller getting stuck > > > Key:

[jira] [Updated] (KAFKA-6078) Investigate failure of ReassignPartitionsClusterTest.shouldExpandCluster

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6078: -- Component/s: unit tests > Investigate failure of ReassignPartitionsClusterTest.shouldExpandCluster > --

[jira] [Updated] (KAFKA-5189) trunk unstable - DescribeConsumerGroupTest.testDescribeGroupWithNewConsumerWithShortInitializationTimeout fails 90% of times

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5189: -- Component/s: unit tests > trunk unstable - > DescribeConsumerGroupTest.testDescribeGroupWithNewConsume

[jira] [Updated] (KAFKA-5955) Transient failure: AuthorizerIntegrationTest.testTransactionalProducerTopicAuthorizationExceptionInCommit

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5955: -- Component/s: unit tests > Transient failure: > AuthorizerIntegrationTest.testTransactionalProducerTopi

[jira] [Updated] (KAFKA-5880) Transactional producer and read committed consumer causes consumer to stuck

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5880: -- Component/s: clients > Transactional producer and read committed consumer causes consumer to stuck > --

[jira] [Updated] (KAFKA-4577) NPE in ControllerChannelManager.scala::addUpdateMetadataRequestForBrokers

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4577: -- Component/s: controller > NPE in ControllerChannelManager.scala::addUpdateMetadataRequestForBrokers >

[jira] [Updated] (KAFKA-4771) NPEs in KerberosLogin due to autoboxing

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4771: -- Component/s: security > NPEs in KerberosLogin due to autoboxing > -

[jira] [Updated] (KAFKA-4546) a consumer could miss tombstone when leader changes during the reads

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4546: -- Component/s: consumer > a consumer could miss tombstone when leader changes during the reads >

[jira] [Updated] (KAFKA-6097) Kafka ssl.endpoint.identification.algorithm=HTTPS not working

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6097: -- Component/s: security > Kafka ssl.endpoint.identification.algorithm=HTTPS not working > ---

[jira] [Updated] (KAFKA-7040) The replica fetcher thread may truncate accepted messages during multiple fast leadership transitions

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-7040: -- Component/s: replication > The replica fetcher thread may truncate accepted messages during multiple >

[jira] [Updated] (KAFKA-5805) The console consumer crushes broker on Windows

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5805: -- Component/s: consumer > The console consumer crushes broker on Windows > --

[jira] [Updated] (KAFKA-5492) LogRecoveryTest.testHWCheckpointWithFailuresSingleLogSegment transient failure

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5492: -- Component/s: unit tests > LogRecoveryTest.testHWCheckpointWithFailuresSingleLogSegment transient failur

[jira] [Updated] (KAFKA-5209) Transient failure: kafka.server.MetadataRequestTest.testControllerId

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5209: -- Component/s: unit tests > Transient failure: kafka.server.MetadataRequestTest.testControllerId > --

[jira] [Updated] (KAFKA-5195) Endless NotLeaderForPartitionException for ReplicaFetcherThread

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5195: -- Component/s: replication > Endless NotLeaderForPartitionException for ReplicaFetcherThread > --

[jira] [Updated] (KAFKA-5276) Support derived and prefixed configs in DescribeConfigs (KIP-133)

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5276: -- Component/s: config > Support derived and prefixed configs in DescribeConfigs (KIP-133) > -

[jira] [Updated] (KAFKA-4142) Log files in /data dir date modified keeps being updated?

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4142: -- Component/s: log > Log files in /data dir date modified keeps being updated? >

[jira] [Updated] (KAFKA-5272) Improve validation for Alter Configs (KIP-133)

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5272: -- Component/s: config > Improve validation for Alter Configs (KIP-133) >

[jira] [Updated] (KAFKA-3686) Kafka producer is not fault tolerant

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3686: -- Component/s: producer > Kafka producer is not fault tolerant > >

[jira] [Updated] (KAFKA-3696) Describe producer and consumer interceptors in website documentation

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3696: -- Component/s: documentation > Describe producer and consumer interceptors in website documentation > ---

[jira] [Updated] (KAFKA-4065) Missing Property in ProducerConfig.java - KafkaProducer API 0.9.0.0

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4065: -- Component/s: producer > Missing Property in ProducerConfig.java - KafkaProducer API 0.9.0.0 >

[jira] [Updated] (KAFKA-3369) Add unit-tests to the Metadata Cache

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3369: -- Component/s: unit tests > Add unit-tests to the Metadata Cache > >

[jira] [Updated] (KAFKA-6278) Allow multiple concurrent transactions on a single producer

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6278: -- Component/s: producer > Allow multiple concurrent transactions on a single producer >

[jira] [Updated] (KAFKA-6278) Allow multiple concurrent transactions on a single producer

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6278: -- Issue Type: New Feature (was: Improvement) > Allow multiple concurrent transactions on a single produc

[jira] [Commented] (KAFKA-3702) SslTransportLayer.close() does not shutdown gracefully

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549829#comment-16549829 ] ASF GitHub Bot commented on KAFKA-3702: --- rajinisivaram opened a new pull request #5

[jira] [Created] (KAFKA-7185) getMatchingAcls throws StringIndexOutOfBoundsException for empty resource name

2018-07-19 Thread Dhruvil Shah (JIRA)
Dhruvil Shah created KAFKA-7185: --- Summary: getMatchingAcls throws StringIndexOutOfBoundsException for empty resource name Key: KAFKA-7185 URL: https://issues.apache.org/jira/browse/KAFKA-7185 Project: K

[jira] [Updated] (KAFKA-7185) getMatchingAcls throws StringIndexOutOfBoundsException for empty resource name

2018-07-19 Thread Dhruvil Shah (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dhruvil Shah updated KAFKA-7185: Description: KIP-290 introduced a way to match ACLs based on prefix. Certain resource names like t

[jira] [Updated] (KAFKA-4680) min.insync.replicas can be set higher than replication factor

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4680: -- Component/s: replication config > min.insync.replicas can be set higher than replicati

[jira] [Updated] (KAFKA-4801) Transient test failure (part 2): ConsumerBounceTest.testConsumptionWithBrokerFailures

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4801: -- Component/s: unit tests > Transient test failure (part 2): > ConsumerBounceTest.testConsumptionWithBro

[jira] [Updated] (KAFKA-4336) Frequent log rolling when there's a mix of delayed and current data

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4336: -- Component/s: log > Frequent log rolling when there's a mix of delayed and current data > --

[jira] [Updated] (KAFKA-6388) Error while trying to roll a segment that already exists

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6388: -- Component/s: log > Error while trying to roll a segment that already exists > -

[jira] [Updated] (KAFKA-5933) Move timeout and validate_only protocol fields into CommonFields class

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5933: -- Component/s: core > Move timeout and validate_only protocol fields into CommonFields class > --

[jira] [Updated] (KAFKA-5578) Streams Task Assignor should consider the staleness of state directories when allocating tasks

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5578: -- Component/s: streams > Streams Task Assignor should consider the staleness of state directories when >

[jira] [Updated] (KAFKA-4573) Producer sporadic timeout

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4573: -- Component/s: producer > Producer sporadic timeout > - > > Key:

[jira] [Updated] (KAFKA-4503) Expose the log dir for a partition as a metric

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4503: -- Component/s: metrics > Expose the log dir for a partition as a metric > ---

[jira] [Updated] (KAFKA-6393) Add tool to view active brokers

2018-07-19 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6393: -- Component/s: tools > Add tool to view active brokers > --- > >

[jira] [Commented] (KAFKA-3514) Stream timestamp computation needs some further thoughts

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

  1   2   >