[jira] [Commented] (KAFKA-4764) Improve diagnostics for SASL authentication failures

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

[jira] [Created] (KAFKA-5890) records.lag should use tags for topic and partition rather than using metric name.

Charly Molter created KAFKA-5890: Summary: records.lag should use tags for topic and partition rather than using metric name. Key: KAFKA-5890 URL: https://issues.apache.org/jira/browse/KAFKA-5890

[jira] [Commented] (KAFKA-5881) Consuming from added partitions without restarting the consumer

[ https://issues.apache.org/jira/browse/KAFKA-5881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166350#comment-16166350 ] Viliam Durina commented on KAFKA-5881: -- Thanks for the reply, i'll give it a test on Monday. If it

[jira] [Updated] (KAFKA-5891) Cast transformation fails if record schema contains timestamp field

[ https://issues.apache.org/jira/browse/KAFKA-5891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Artem Plotnikov updated KAFKA-5891: --- Description: I have the following simple type cast transformation: {code}

[jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166376#comment-16166376 ] Seweryn Habdank-Wojewodzki commented on KAFKA-5882: --- I do not have any more logs as I

[jira] [Commented] (KAFKA-4392) Failed to lock the state directory due to an unexpected exception

[ https://issues.apache.org/jira/browse/KAFKA-4392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166378#comment-16166378 ] Seweryn Habdank-Wojewodzki commented on KAFKA-4392: --- Sure, but next week :-). > Failed

[jira] [Updated] (KAFKA-5750) Elevate log messages for denials to INFO in SimpleAclAuthorizer class

[ https://issues.apache.org/jira/browse/KAFKA-5750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-5750: - Summary: Elevate log messages for denials to INFO in SimpleAclAuthorizer class (was: Elevate log

[jira] [Commented] (KAFKA-5892) Connector property override does not work unless setting ALL converter properties

[ https://issues.apache.org/jira/browse/KAFKA-5892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166456#comment-16166456 ] Randall Hauch commented on KAFKA-5892: -- At first blush, it seems like Connect should be able to do

[jira] [Updated] (KAFKA-5892) Connector property override does not work unless setting ALL converter properties

[ https://issues.apache.org/jira/browse/KAFKA-5892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-5892: - Labels: newbie (was: ) > Connector property override does not work unless setting ALL converter

[jira] [Created] (KAFKA-5892) Connector property override does not work unless setting ALL converter properties

Yeva Byzek created KAFKA-5892: - Summary: Connector property override does not work unless setting ALL converter properties Key: KAFKA-5892 URL: https://issues.apache.org/jira/browse/KAFKA-5892 Project:

[jira] [Updated] (KAFKA-5892) Connector property override does not work unless setting ALL converter properties

[ https://issues.apache.org/jira/browse/KAFKA-5892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-5892: - Description: A single connector setting override {{value.converter.schemas.enable=false}} only

[jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166549#comment-16166549 ] Matthias J. Sax commented on KAFKA-5882: We actually do have system test for broker bounces. Thus,

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

[ https://issues.apache.org/jira/browse/KAFKA-5805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16167247#comment-16167247 ] huxihx commented on KAFKA-5805: --- Do you run the Kafka broker on Window 32bit platform? > The console

[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=16167264#comment-16167264 ] Richard Yu commented on KAFKA-5765: --- Could I work on this? Thanks. > Move merge() from StreamsBuilder

[jira] [Updated] (KAFKA-5906) Change metric.reporters configuration key to metrics.reporters to be consistent

[ https://issues.apache.org/jira/browse/KAFKA-5906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5906: Description: The "metric.reporters" configuration key should be consistent with the actual classes.

[jira] [Commented] (KAFKA-5301) Improve exception handling on consumer path

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

[jira] [Commented] (KAFKA-5407) Mirrormaker dont start after upgrade

[ https://issues.apache.org/jira/browse/KAFKA-5407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16167363#comment-16167363 ] Manikumar commented on KAFKA-5407: -- [~fvegaucr] Can you upload broker logs at the time of error? >

[jira] [Commented] (KAFKA-5874) Incorrect command line handling

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

[jira] [Assigned] (KAFKA-5874) Incorrect command line handling

[ https://issues.apache.org/jira/browse/KAFKA-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-5874: - Assignee: huxihx > Incorrect command line handling > --- > >

[jira] [Created] (KAFKA-5906) Change metric.reporters configuration key to metrics.reporters to be consistent

Kevin Lu created KAFKA-5906: --- Summary: Change metric.reporters configuration key to metrics.reporters to be consistent Key: KAFKA-5906 URL: https://issues.apache.org/jira/browse/KAFKA-5906 Project: Kafka

[jira] [Commented] (KAFKA-5896) Kafka Connect task threads never interrupted

[ https://issues.apache.org/jira/browse/KAFKA-5896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16167174#comment-16167174 ] Nick Pillitteri commented on KAFKA-5896: [~rhauch] sure! > Kafka Connect task threads never

[jira] [Commented] (KAFKA-5822) Consistent logging of topic partitions

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

[jira] [Commented] (KAFKA-5793) Tighten up situations where OutOfOrderSequence may be returned

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

[jira] [Created] (KAFKA-5891) Cast transformation fails if record schema contains timestamp field

Artem Plotnikov created KAFKA-5891: -- Summary: Cast transformation fails if record schema contains timestamp field Key: KAFKA-5891 URL: https://issues.apache.org/jira/browse/KAFKA-5891 Project: Kafka

[jira] [Updated] (KAFKA-5876) IQ should throw different exceptions for different errors

[ https://issues.apache.org/jira/browse/KAFKA-5876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5876: --- Labels: needs-kip newbie++ (was: needs-kip) > IQ should throw different exceptions for

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

[ https://issues.apache.org/jira/browse/KAFKA-5660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-5660: -- Assignee: Matthias J. Sax > Don't throw TopologyBuilderException during runtime >

[jira] [Commented] (KAFKA-5896) Kafka Connect task threads never interrupted

[ https://issues.apache.org/jira/browse/KAFKA-5896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166907#comment-16166907 ] Ted Yu commented on KAFKA-5896: --- Good find. Mind sending a PR (hopefully with test showing the

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

[ https://issues.apache.org/jira/browse/KAFKA-5660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5660: --- Issue Type: Sub-task (was: Bug) Parent: KAFKA-5156 > Don't throw

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

[ https://issues.apache.org/jira/browse/KAFKA-4932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4932: --- Labels: newbie (was: ) > Add UUID Serde > -- > > Key: KAFKA-4932

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

[ https://issues.apache.org/jira/browse/KAFKA-4932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4932: --- Labels: needs-kip newbie (was: newbie) > Add UUID Serde > -- > >

[jira] [Comment Edited] (KAFKA-5407) Mirrormaker dont start after upgrade

[ https://issues.apache.org/jira/browse/KAFKA-5407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166938#comment-16166938 ] Fernando Vega edited comment on KAFKA-5407 at 9/14/17 8:42 PM: --- [~huxi_2b]

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

[ https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5765: --- Labels: needs-kip newbie (was: needs-kip) > Move merge() from StreamsBuilder to KStream >

[jira] [Assigned] (KAFKA-5158) Options for handling exceptions during processing

[ https://issues.apache.org/jira/browse/KAFKA-5158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-5158: -- Assignee: Matthias J. Sax > Options for handling exceptions during processing >

[jira] [Updated] (KAFKA-5158) Options for handling exceptions during processing

[ https://issues.apache.org/jira/browse/KAFKA-5158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5158: --- Issue Type: Sub-task (was: New Feature) Parent: KAFKA-5156 > Options for handling

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

[ https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5765: --- Description: Merging multiple {{KStream}} is done via {{StreamsBuilder#merge()}} (formally

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

[ https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5765: --- Fix Version/s: (was: 1.0.0) 1.1.0 > Move merge() from StreamsBuilder

[jira] [Updated] (KAFKA-5893) ResetIntegrationTest fails

[ https://issues.apache.org/jira/browse/KAFKA-5893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5893: --- Description: {noformat} java.lang.AssertionError: expected:<0> but was:<1> at

[jira] [Commented] (KAFKA-5301) Improve exception handling on consumer path

[ https://issues.apache.org/jira/browse/KAFKA-5301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166793#comment-16166793 ] Matthias J. Sax commented on KAFKA-5301: I did assign this JIRA to myself, as we need to tackle

[jira] [Commented] (KAFKA-5893) ResetIntegrationTest fails

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

[jira] [Assigned] (KAFKA-5302) Improve exception handling on streams client (communication with brokers)

[ https://issues.apache.org/jira/browse/KAFKA-5302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-5302: -- Assignee: Matthias J. Sax > Improve exception handling on streams client

[jira] [Assigned] (KAFKA-5313) Improve exception handling on coordinator interactions

[ https://issues.apache.org/jira/browse/KAFKA-5313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-5313: -- Assignee: Matthias J. Sax > Improve exception handling on coordinator interactions >

[jira] [Assigned] (KAFKA-5569) Document any changes from this task

[ https://issues.apache.org/jira/browse/KAFKA-5569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-5569: -- Assignee: Matthias J. Sax > Document any changes from this task >

[jira] [Created] (KAFKA-5895) Update readme to reflect that Gradle 2 is no longer good enough

Matthias Weßendorf created KAFKA-5895: - Summary: Update readme to reflect that Gradle 2 is no longer good enough Key: KAFKA-5895 URL: https://issues.apache.org/jira/browse/KAFKA-5895 Project:

[jira] [Commented] (KAFKA-5895) Update readme to reflect that Gradle 2 is no longer good enough

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

[jira] [Commented] (KAFKA-5225) StreamsResetter doesn't allow custom Consumer properties

[ https://issues.apache.org/jira/browse/KAFKA-5225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166731#comment-16166731 ] Matthias J. Sax commented on KAFKA-5225: [~bharatviswa] Are you still working on this? >

[jira] [Updated] (KAFKA-5895) Gradle 3.0+ is needed on the build

[ https://issues.apache.org/jira/browse/KAFKA-5895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Weßendorf updated KAFKA-5895: -- Summary: Gradle 3.0+ is needed on the build (was: Update readme to reflect that Gradle

[jira] [Created] (KAFKA-5893) ResetIntegrationTest fails

Matthias J. Sax created KAFKA-5893: -- Summary: ResetIntegrationTest fails Key: KAFKA-5893 URL: https://issues.apache.org/jira/browse/KAFKA-5893 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-5894) add the notion of max inflight requests to async ZookeeperClient

Onur Karaman created KAFKA-5894: --- Summary: add the notion of max inflight requests to async ZookeeperClient Key: KAFKA-5894 URL: https://issues.apache.org/jira/browse/KAFKA-5894 Project: Kafka

[jira] [Commented] (KAFKA-5894) add the notion of max inflight requests to async ZookeeperClient

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

[jira] [Assigned] (KAFKA-5301) Improve exception handling on consumer path

[ https://issues.apache.org/jira/browse/KAFKA-5301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-5301: -- Assignee: Matthias J. Sax > Improve exception handling on consumer path >

[jira] [Created] (KAFKA-5897) The producerId can be reset unnecessarily

Apurva Mehta created KAFKA-5897: --- Summary: The producerId can be reset unnecessarily Key: KAFKA-5897 URL: https://issues.apache.org/jira/browse/KAFKA-5897 Project: Kafka Issue Type:

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

Randall Hauch created KAFKA-5900: Summary: Create Connect metrics common to source and sink tasks Key: KAFKA-5900 URL: https://issues.apache.org/jira/browse/KAFKA-5900 Project: Kafka Issue

[jira] [Comment Edited] (KAFKA-5301) Improve exception handling on consumer path

[ https://issues.apache.org/jira/browse/KAFKA-5301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166989#comment-16166989 ] Richard Yu edited comment on KAFKA-5301 at 9/14/17 10:54 PM: - [~mjsax] You

[jira] [Created] (KAFKA-5898) Client consume more than one time a message

Cyril WIRTH created KAFKA-5898: -- Summary: Client consume more than one time a message Key: KAFKA-5898 URL: https://issues.apache.org/jira/browse/KAFKA-5898 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-5903) Create Connect metrics for workers

Randall Hauch created KAFKA-5903: Summary: Create Connect metrics for workers Key: KAFKA-5903 URL: https://issues.apache.org/jira/browse/KAFKA-5903 Project: Kafka Issue Type: Sub-task

[jira] [Commented] (KAFKA-5899) Create Connect metrics for connectors

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

[jira] [Created] (KAFKA-5899) Create Connect metrics for connectors

Randall Hauch created KAFKA-5899: Summary: Create Connect metrics for connectors Key: KAFKA-5899 URL: https://issues.apache.org/jira/browse/KAFKA-5899 Project: Kafka Issue Type: Sub-task

[jira] [Comment Edited] (KAFKA-5301) Improve exception handling on consumer path

[ https://issues.apache.org/jira/browse/KAFKA-5301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166989#comment-16166989 ] Richard Yu edited comment on KAFKA-5301 at 9/14/17 10:48 PM: - [~mjsax] You

[jira] [Commented] (KAFKA-5896) Kafka Connect task threads never interrupted

[ https://issues.apache.org/jira/browse/KAFKA-5896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166977#comment-16166977 ] Nick Pillitteri commented on KAFKA-5896: Sure, will do! > Kafka Connect task threads never

[jira] [Commented] (KAFKA-5301) Improve exception handling on consumer path

[ https://issues.apache.org/jira/browse/KAFKA-5301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166989#comment-16166989 ] Richard Yu commented on KAFKA-5301: --- [~mjsax] You could take this issue. Due to the slight ambiguity

[jira] [Commented] (KAFKA-5896) Kafka Connect task threads never interrupted

[ https://issues.apache.org/jira/browse/KAFKA-5896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16167008#comment-16167008 ] Randall Hauch commented on KAFKA-5896: -- [~56quarters], can you please @rhauch on the PR? Thanks! >

[jira] [Assigned] (KAFKA-2376) Add Kafka Connect metrics

[ https://issues.apache.org/jira/browse/KAFKA-2376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch reassigned KAFKA-2376: Assignee: Randall Hauch > Add Kafka Connect metrics > - > >

[jira] [Created] (KAFKA-5905) Remove PrincipalBuilder and DefaultPrincipalBuilder

Jason Gustafson created KAFKA-5905: -- Summary: Remove PrincipalBuilder and DefaultPrincipalBuilder Key: KAFKA-5905 URL: https://issues.apache.org/jira/browse/KAFKA-5905 Project: Kafka Issue

[jira] [Commented] (KAFKA-5898) Client consume more than one time a message

[ https://issues.apache.org/jira/browse/KAFKA-5898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16167127#comment-16167127 ] Ted Yu commented on KAFKA-5898: --- Just curious: 0.11.0.1 has been released. Is this reproducible using

[jira] [Reopened] (KAFKA-5792) Transient failure in KafkaAdminClientTest.testHandleTimeout

[ https://issues.apache.org/jira/browse/KAFKA-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reopened KAFKA-5792: Still seeing this:

[jira] [Commented] (KAFKA-5738) Add cumulative count attribute for all Kafka rate metrics

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

[jira] [Commented] (KAFKA-5494) Idempotent producer should not require max.in.flight.requests.per.connection=1

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