[jira] [Commented] (KAFKA-5900) Create Connect metrics common to source and sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-5900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181999#comment-16181999 ] ASF GitHub Bot commented on KAFKA-5900: --- Github user asfgit closed the pull request at:

[jira] [Resolved] (KAFKA-5900) Create Connect metrics common to source and sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-5900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-5900. -- Resolution: Fixed Reviewer: Ewen Cheslack-Postava Fixed via

[jira] [Commented] (KAFKA-5888) Transactions system test should check for message order

[ https://issues.apache.org/jira/browse/KAFKA-5888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181956#comment-16181956 ] ASF GitHub Bot commented on KAFKA-5888: --- GitHub user apurvam opened a pull request:

[jira] [Commented] (KAFKA-5952) Refactor Consumer Fetcher metrics

[ https://issues.apache.org/jira/browse/KAFKA-5952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181904#comment-16181904 ] ASF GitHub Bot commented on KAFKA-5952: --- GitHub user wushujames opened a pull request:

[jira] [Commented] (KAFKA-5928) Avoid redundant requests to zookeeper when reassign topic partition

[ https://issues.apache.org/jira/browse/KAFKA-5928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181900#comment-16181900 ] ASF GitHub Bot commented on KAFKA-5928: --- GitHub user uncleGen reopened a pull request:

[jira] [Comment Edited] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores

[ https://issues.apache.org/jira/browse/KAFKA-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181875#comment-16181875 ] Richard Yu edited comment on KAFKA-4499 at 9/27/17 2:21 AM: I noticed a couple

[jira] [Comment Edited] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores

[ https://issues.apache.org/jira/browse/KAFKA-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181875#comment-16181875 ] Richard Yu edited comment on KAFKA-4499 at 9/27/17 2:14 AM: I noticed a couple

[jira] [Comment Edited] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores

[ https://issues.apache.org/jira/browse/KAFKA-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181875#comment-16181875 ] Richard Yu edited comment on KAFKA-4499 at 9/27/17 2:05 AM: I noticed a couple

[jira] [Comment Edited] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores

[ https://issues.apache.org/jira/browse/KAFKA-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181875#comment-16181875 ] Richard Yu edited comment on KAFKA-4499 at 9/27/17 2:03 AM: I noticed a couple

[jira] [Comment Edited] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores

[ https://issues.apache.org/jira/browse/KAFKA-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181875#comment-16181875 ] Richard Yu edited comment on KAFKA-4499 at 9/27/17 2:02 AM: I noticed a couple

[jira] [Comment Edited] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores

[ https://issues.apache.org/jira/browse/KAFKA-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181875#comment-16181875 ] Richard Yu edited comment on KAFKA-4499 at 9/27/17 2:02 AM: I noticed a couple

[jira] [Commented] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores

[ https://issues.apache.org/jira/browse/KAFKA-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181875#comment-16181875 ] Richard Yu commented on KAFKA-4499: --- I noticed a couple of things when looking through the

[jira] [Commented] (KAFKA-5951) Autogenerate Producer RecordAccumulator metrics

[ https://issues.apache.org/jira/browse/KAFKA-5951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181860#comment-16181860 ] ASF GitHub Bot commented on KAFKA-5951: --- GitHub user wushujames opened a pull request:

[jira] [Updated] (KAFKA-5979) kip-120 changed internal streams topic naming

[ https://issues.apache.org/jira/browse/KAFKA-5979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5979: --- Component/s: streams > kip-120 changed internal streams topic naming >

[jira] [Assigned] (KAFKA-5979) kip-120 changed internal streams topic naming

[ https://issues.apache.org/jira/browse/KAFKA-5979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-5979: -- Assignee: Matthias J. Sax > kip-120 changed internal streams topic naming >

[jira] [Updated] (KAFKA-5980) FailOnInvalidTimestamp does not log error

[ https://issues.apache.org/jira/browse/KAFKA-5980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5980: --- Fix Version/s: 1.0.0 > FailOnInvalidTimestamp does not log error >

[jira] [Commented] (KAFKA-5980) FailOnInvalidTimestamp does not log error

[ https://issues.apache.org/jira/browse/KAFKA-5980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181790#comment-16181790 ] ASF GitHub Bot commented on KAFKA-5980: --- GitHub user mjsax opened a pull request:

[jira] [Updated] (KAFKA-5980) FailOnInvalidTimestamp does not log error

[ https://issues.apache.org/jira/browse/KAFKA-5980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5980: --- Component/s: streams > FailOnInvalidTimestamp does not log error >

[jira] [Assigned] (KAFKA-5980) FailOnInvalidTimestamp does not log error

[ https://issues.apache.org/jira/browse/KAFKA-5980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-5980: -- Assignee: Matthias J. Sax > FailOnInvalidTimestamp does not log error >

[jira] [Updated] (KAFKA-5980) FailOnInvalidTimestamp does not log error

[ https://issues.apache.org/jira/browse/KAFKA-5980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5980: --- Affects Version/s: 0.11.0.1 > FailOnInvalidTimestamp does not log error >

[jira] [Created] (KAFKA-5980) FailOnInvalidTimestamp does not log error

Michael Rylander created KAFKA-5980: --- Summary: FailOnInvalidTimestamp does not log error Key: KAFKA-5980 URL: https://issues.apache.org/jira/browse/KAFKA-5980 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-5979) kip-120 changed internal streams topic naming

[ https://issues.apache.org/jira/browse/KAFKA-5979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dan norwood updated KAFKA-5979: --- Fix Version/s: 1.0.0 > kip-120 changed internal streams topic naming >

[jira] [Created] (KAFKA-5979) kip-120 changed internal streams topic naming

dan norwood created KAFKA-5979: -- Summary: kip-120 changed internal streams topic naming Key: KAFKA-5979 URL: https://issues.apache.org/jira/browse/KAFKA-5979 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-5944) Add unit tests for handling of authentication failures in clients

[ https://issues.apache.org/jira/browse/KAFKA-5944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181521#comment-16181521 ] ASF GitHub Bot commented on KAFKA-5944: --- GitHub user vahidhashemian opened a pull request:

[jira] [Updated] (KAFKA-4932) Add UUID Serde

[ https://issues.apache.org/jira/browse/KAFKA-4932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Olson updated KAFKA-4932: Description: I propose adding serializers and deserializers for the java.util.UUID class. I have

[jira] [Commented] (KAFKA-5973) ShutdownableThread catching errors can lead to partial hard to diagnose broker failure

[ https://issues.apache.org/jira/browse/KAFKA-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181184#comment-16181184 ] Ted Yu commented on KAFKA-5973: --- [~tcrayford-heroku] [~theduderog]: What do you think of the PR ? >

[jira] [Commented] (KAFKA-5973) ShutdownableThread catching errors can lead to partial hard to diagnose broker failure

[ https://issues.apache.org/jira/browse/KAFKA-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181043#comment-16181043 ] ASF GitHub Bot commented on KAFKA-5973: --- GitHub user tedyu opened a pull request:

[jira] [Commented] (KAFKA-5679) Add logging to distinguish between internally and externally initiated shutdown of Kafka

[ https://issues.apache.org/jira/browse/KAFKA-5679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16180833#comment-16180833 ] Ismael Juma commented on KAFKA-5679: We added a signal handler for the cases where shutdown is

[jira] [Commented] (KAFKA-5968) Remove all broker metrics during shutdown

[ https://issues.apache.org/jira/browse/KAFKA-5968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16180754#comment-16180754 ] Rajini Sivaram commented on KAFKA-5968: --- [~tedyu] Thank you for the patch. To fix this properly,

[jira] [Created] (KAFKA-5978) Transient failure in SslTransportLayerTest.testNetworkThreadTimeRecorded

Rajini Sivaram created KAFKA-5978: - Summary: Transient failure in SslTransportLayerTest.testNetworkThreadTimeRecorded Key: KAFKA-5978 URL: https://issues.apache.org/jira/browse/KAFKA-5978 Project:

[jira] [Commented] (KAFKA-5977) Upgrade RocksDB dependency to legally acceptable version

[ https://issues.apache.org/jira/browse/KAFKA-5977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16180560#comment-16180560 ] Stevo Slavic commented on KAFKA-5977: - Not sure is this considered as duplicate of KAFKA-5576 but it's

[jira] [Updated] (KAFKA-5976) RequestChannel.sendReponse records incorrect size for NetworkSend with TRACE logging

[ https://issues.apache.org/jira/browse/KAFKA-5976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx updated KAFKA-5976: -- Description: In RequestChannel.scala, RequestChannel.sendResponse records incorrect size for `NetworkSend`

[jira] [Created] (KAFKA-5977) Upgrade RocksDB dependency to legally acceptable one

Stevo Slavic created KAFKA-5977: --- Summary: Upgrade RocksDB dependency to legally acceptable one Key: KAFKA-5977 URL: https://issues.apache.org/jira/browse/KAFKA-5977 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-5977) Upgrade RocksDB dependency to legally acceptable version

[ https://issues.apache.org/jira/browse/KAFKA-5977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stevo Slavic updated KAFKA-5977: Summary: Upgrade RocksDB dependency to legally acceptable version (was: Upgrade RocksDB dependency

[jira] [Commented] (KAFKA-5976) RequestChannel.sendReponse records incorrect size for NetworkSend with TRACE logging

[ https://issues.apache.org/jira/browse/KAFKA-5976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16180521#comment-16180521 ] ASF GitHub Bot commented on KAFKA-5976: --- GitHub user huxihx opened a pull request:

[jira] [Created] (KAFKA-5976) RequestChannel.sendReponse records incorrect size for NetworkSend with TRACE logging

huxihx created KAFKA-5976: - Summary: RequestChannel.sendReponse records incorrect size for NetworkSend with TRACE logging Key: KAFKA-5976 URL: https://issues.apache.org/jira/browse/KAFKA-5976 Project: Kafka

[jira] [Commented] (KAFKA-5938) Oracle jdbc-source-connector with kafka-connect distributed mode will result in http 500 error

[ https://issues.apache.org/jira/browse/KAFKA-5938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16180508#comment-16180508 ] Wolfgang Clemens commented on KAFKA-5938: - I tried it with a single cp-kafka-connect docker

[jira] [Commented] (KAFKA-5765) Move merge() from StreamsBuilder to KStream

[ https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16180479#comment-16180479 ] ASF GitHub Bot commented on KAFKA-5765: --- Github user asfgit closed the pull request at:

[jira] [Resolved] (KAFKA-5695) Test DeleteRecordsRequest in AuthorizerIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5695. Resolution: Fixed Fix Version/s: (was: 1.1.0) 1.0.0 > Test

[jira] [Commented] (KAFKA-5695) Test DeleteRecordsRequest in AuthorizerIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16180361#comment-16180361 ] ASF GitHub Bot commented on KAFKA-5695: --- Github user asfgit closed the pull request at:

[jira] [Updated] (KAFKA-5588) Remove deprecated new-consumer option for tools

[ https://issues.apache.org/jira/browse/KAFKA-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno updated KAFKA-5588: -- Summary: Remove deprecated new-consumer option for tools (was: ConsoleConsumer : Remove

[jira] [Updated] (KAFKA-5588) ConsoleConsumer : Remove deprecated new-consumer option for tools

[ https://issues.apache.org/jira/browse/KAFKA-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno updated KAFKA-5588: -- Summary: ConsoleConsumer : Remove deprecated new-consumer option for tools (was:

[jira] [Reopened] (KAFKA-5588) ConsoleConsumer : uselss --new-consumer option

[ https://issues.apache.org/jira/browse/KAFKA-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno reopened KAFKA-5588: --- > ConsoleConsumer : uselss --new-consumer option > --

[jira] [Commented] (KAFKA-5975) No response when deleting topics and delete.topic.enable=false

[ https://issues.apache.org/jira/browse/KAFKA-5975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16180336#comment-16180336 ] Ismael Juma commented on KAFKA-5975: We should probably return an error in this case, right? > No