[jira] [Commented] (KAFKA-5241) GlobalKTable does not checkpoint offsets after restoring state

[ https://issues.apache.org/jira/browse/KAFKA-5241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16011360#comment-16011360 ] Tommy Becker commented on KAFKA-5241: - I should also add that it seems broken that in the absence of

[jira] [Updated] (KAFKA-5241) GlobalKTable does not checkpoint offsets after restoring state

[ https://issues.apache.org/jira/browse/KAFKA-5241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tommy Becker updated KAFKA-5241: Fix Version/s: 0.11.0.0 Status: Patch Available (was: Open) > GlobalKTable does not

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

[GitHub] kafka pull request #3062: KAFKA-5225: StreamsResetter tool to allow custom c...

GitHub user bharatviswa504 opened a pull request: https://github.com/apache/kafka/pull/3062 KAFKA-5225: StreamsResetter tool to allow custom consumer properties @mjsax @guozhangwang Could you please review the changes. You can merge this pull request into a Git repository by

[jira] [Commented] (KAFKA-5246) Remove backdoor that allows any client to produce to internal topics

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

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

[ https://issues.apache.org/jira/browse/KAFKA-5225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5225 started by Bharat Viswanadham. - > StreamsResetter doesn't allow custom Consumer properties >

[jira] [Updated] (KAFKA-4923) Add Exactly-Once Semantics to Streams

[ https://issues.apache.org/jira/browse/KAFKA-4923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4923: --- Labels: exactly-once kip (was: kip) > Add Exactly-Once Semantics to Streams >

[jira] [Resolved] (KAFKA-5244) Tests which delete singleton metrics break subsequent metrics tests

[ https://issues.apache.org/jira/browse/KAFKA-5244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5244. Resolution: Fixed Issue resolved by pull request 3059 [https://github.com/apache/kafka/pull/3059]

[GitHub] kafka pull request #3059: KAFKA-5244: Refactor BrokerTopicStats and Controll...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3059 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] kafka pull request #3061: KAFKA-5246: Remove backdoor that allows any client...

GitHub user datalorax opened a pull request: https://github.com/apache/kafka/pull/3061 KAFKA-5246: Remove backdoor that allows any client to produce to internal topics removing unused `AdminUtils.AdminClientId`, as its a security hole. You can merge this pull request into a Git

[jira] [Commented] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16011331#comment-16011331 ] Matthias J. Sax commented on KAFKA-5154: Thanks for sharing the logs. We cycle back if we need

[jira] [Comment Edited] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16011331#comment-16011331 ] Matthias J. Sax edited comment on KAFKA-5154 at 5/15/17 9:10 PM: - Thanks

Build failed in Jenkins: kafka-trunk-jdk8 #1529

See Changes: [wangguoz] KAFKA-5205: Use default values of keySerde if it is not specified by [jason] KAFKA-5248; Remove unused/unneeded retention time in --

[jira] [Commented] (KAFKA-5244) Tests which delete singleton metrics break subsequent metrics tests

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

[jira] [Updated] (KAFKA-5251) Producer should drop queued sends when transaction is aborted

[ https://issues.apache.org/jira/browse/KAFKA-5251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-5251: -- Labels: exactly-once (was: ) > Producer should drop queued sends when transaction is

[jira] [Commented] (KAFKA-5151) Refactor TransactionCoordinator in-memory structure and error handling logic

[ https://issues.apache.org/jira/browse/KAFKA-5151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16011385#comment-16011385 ] Sriram Subramanian commented on KAFKA-5151: --- [~guozhang] can we close this? > Refactor

Jenkins build is back to normal : kafka-trunk-jdk8 #1528

See

[jira] [Commented] (KAFKA-5248) Remove retention time from TxnOffsetCommit RPC

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

[jira] [Updated] (KAFKA-5246) Remove backdoor that allows any client to produce to internal topics

[ https://issues.apache.org/jira/browse/KAFKA-5246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy Coates updated KAFKA-5246: --- Status: Patch Available (was: Open) > Remove backdoor that allows any client to produce to internal

[jira] [Created] (KAFKA-5250) handleFetchRequest should do down conversion after throttling

Ismael Juma created KAFKA-5250: -- Summary: handleFetchRequest should do down conversion after throttling Key: KAFKA-5250 URL: https://issues.apache.org/jira/browse/KAFKA-5250 Project: Kafka

[jira] [Commented] (KAFKA-5200) Deleting topic when one broker is down will prevent topic to be re-creatable

[ https://issues.apache.org/jira/browse/KAFKA-5200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010608#comment-16010608 ] Edoardo Comar commented on KAFKA-5200: -- I am actually hoping for someone familiar with the non-open

[jira] [Comment Edited] (KAFKA-5200) Deleting topic when one broker is down will prevent topic to be re-creatable

[ https://issues.apache.org/jira/browse/KAFKA-5200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010608#comment-16010608 ] Edoardo Comar edited comment on KAFKA-5200 at 5/15/17 2:29 PM: --- I am

[jira] [Updated] (KAFKA-5242) state task directory locked forever

[ https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukas Gemela updated KAFKA-5242: Description: >From time to time, during relabance we are getting a lot of exceptions saying

[jira] [Resolved] (KAFKA-5179) Log connection termination during authentication

[ https://issues.apache.org/jira/browse/KAFKA-5179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-5179. --- Resolution: Fixed Issue resolved by pull request 2980

[GitHub] kafka pull request #2980: KAFKA-5179: Log connection termination during auth...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2980 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (KAFKA-5179) Log connection termination during authentication

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

[jira] [Commented] (KAFKA-4222) Transient failure in QueryableStateIntegrationTest.queryOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16011425#comment-16011425 ] Matthias J. Sax commented on KAFKA-4222: Seems not to be fixed:

[jira] [Commented] (KAFKA-5175) Transient failure: ControllerIntegrationTest.testPreferredReplicaLeaderElection

[ https://issues.apache.org/jira/browse/KAFKA-5175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16011449#comment-16011449 ] Ismael Juma commented on KAFKA-5175: Another instance: {code} java.lang.AssertionError: failed to get

[jira] [Updated] (KAFKA-5093) Load only batch header when rebuilding producer ID map

[ https://issues.apache.org/jira/browse/KAFKA-5093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-5093: --- Issue Type: Sub-task (was: Improvement) Parent: KAFKA-4815 > Load only batch header

[jira] [Commented] (KAFKA-5175) Transient failure: ControllerIntegrationTest.testPreferredReplicaLeaderElection

[ https://issues.apache.org/jira/browse/KAFKA-5175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16011500#comment-16011500 ] Onur Karaman commented on KAFKA-5175: - Thanks [~ijuma]. I've been staring at this and couldn't figure

[jira] [Created] (KAFKA-5252) Fix flaky test LogCleanerTest.testCommitMarkerRemoval

Jason Gustafson created KAFKA-5252: -- Summary: Fix flaky test LogCleanerTest.testCommitMarkerRemoval Key: KAFKA-5252 URL: https://issues.apache.org/jira/browse/KAFKA-5252 Project: Kafka

[jira] [Assigned] (KAFKA-5228) Revisit Streams DSL JavaDocs

[ https://issues.apache.org/jira/browse/KAFKA-5228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-5228: -- Assignee: Jeyhun Karimov > Revisit Streams DSL JavaDocs >

Jenkins build is back to normal : kafka-trunk-jdk7 #2201

See

[jira] [Commented] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16011594#comment-16011594 ] Guozhang Wang commented on KAFKA-5154: -- Also if it is possible could you apply the latest patch from

[jira] [Commented] (KAFKA-5226) NullPointerException (NPE) in SourceNodeRecordDeserializer.deserialize

[ https://issues.apache.org/jira/browse/KAFKA-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16011590#comment-16011590 ] Ian Springer commented on KAFKA-5226: - The pattern expression we're using is

Re: [DISCUSS]: KIP-149: Enabling key access in ValueTransformer, ValueMapper, and ValueJoiner

Jeyhun, thanks for the update. I think supporting Lambdas for `withKey` and `AbstractRichFunction` don't go together, as Lambdas are only supported for interfaces AFAIK. Thus, if we want to support Lambdas for `withKey`, we need to have a interface approach like this - RichFunction -> only

[jira] [Commented] (KAFKA-3096) Leader is not set to -1 when it is shutdown if followers are down

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

Build failed in Jenkins: kafka-trunk-jdk8 #1532

See Changes: [junrao] MINOR: Fix bug in `waitUntilLeaderIsElectedOrChanged` and simplify -- [...truncated 671.95 KB...] kafka.server.ServerShutdownTest >

[jira] [Updated] (KAFKA-5228) Revisit Streams DSL JavaDocs

[ https://issues.apache.org/jira/browse/KAFKA-5228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5228: --- Fix Version/s: 0.11.0.0 Status: Patch Available (was: Open) > Revisit Streams DSL

[jira] [Commented] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16011562#comment-16011562 ] Guozhang Wang commented on KAFKA-5154: -- [~Lukas Gemela] Could you upload the full log as well? We

[jira] [Comment Edited] (KAFKA-5226) NullPointerException (NPE) in SourceNodeRecordDeserializer.deserialize

[ https://issues.apache.org/jira/browse/KAFKA-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16011590#comment-16011590 ] Ian Springer edited comment on KAFKA-5226 at 5/16/17 1:25 AM: -- The pattern

[jira] [Commented] (KAFKA-5252) Fix flaky test LogCleanerTest.testCommitMarkerRemoval

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

[GitHub] kafka pull request #3064: KAFKA-5252: Fix transient failures LogCleanerTest ...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3064 KAFKA-5252: Fix transient failures LogCleanerTest testCommitMarkerRemoval and testAbortMarkerRemoval You can merge this pull request into a Git repository by running: $ git pull

Reg: [VOTE] KIP 157 - Add consumer config options to streams reset tool

Hi All, Given the simple and non-controversial nature of the KIP, I would like to start the voting process for KIP-157: Add consumer config options to streams reset tool *https://cwiki.apache.org/confluence/display/KAFKA/KIP+157+-+Add+consumer+config+options+to+streams+reset+tool

[jira] [Resolved] (KAFKA-5249) Transaction index recovery does not snapshot properly

[ https://issues.apache.org/jira/browse/KAFKA-5249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-5249. Resolution: Fixed Fix Version/s: 0.11.0.0 Issue resolved by pull request 3060

Build failed in Jenkins: kafka-trunk-jdk7 #2200

See Changes: [rajinisivaram] KAFKA-5179; Log connection termination during authentication [junrao] KAFKA-5249; Fix incorrect producer snapshot offsets when recovering --

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

[ https://issues.apache.org/jira/browse/KAFKA-5225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5225: --- Labels: needs-kip (was: ) > StreamsResetter doesn't allow custom Consumer properties >

[GitHub] kafka pull request #3063: MINOR: Print offset and size in sendFetches

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/3063 MINOR: Print offset and size in sendFetches You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka

[GitHub] kafka pull request #3060: KAFKA-5249: Fix incorrect producer snapshot offset...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3060 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

Build failed in Jenkins: kafka-trunk-jdk8 #1530

See Changes: [ismael] KAFKA-5244; Refactor BrokerTopicStats and ControllerStats so that they -- [...truncated 860.98 KB...] kafka.utils.CommandLineUtilsTest >

[jira] [Commented] (KAFKA-5249) Transaction index recovery does not snapshot properly

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

[jira] [Commented] (KAFKA-5226) NullPointerException (NPE) in SourceNodeRecordDeserializer.deserialize

[ https://issues.apache.org/jira/browse/KAFKA-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16011452#comment-16011452 ] Matthias J. Sax commented on KAFKA-5226: Thanks for the logs. It seems you subscribe via pattern.

Build failed in Jenkins: kafka-trunk-jdk8 #1531

See Changes: [rajinisivaram] KAFKA-5179; Log connection termination during authentication [junrao] KAFKA-5249; Fix incorrect producer snapshot offsets when recovering --

[jira] [Assigned] (KAFKA-5226) NullPointerException (NPE) in SourceNodeRecordDeserializer.deserialize

[ https://issues.apache.org/jira/browse/KAFKA-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-5226: -- Assignee: Matthias J. Sax > NullPointerException (NPE) in

[jira] [Commented] (KAFKA-5252) Fix flaky test LogCleanerTest.testCommitMarkerRemoval

[ https://issues.apache.org/jira/browse/KAFKA-5252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16011618#comment-16011618 ] Matthias J. Sax commented on KAFKA-5252: Seems it happened again:

[jira] [Commented] (KAFKA-5252) Fix flaky test LogCleanerTest.testCommitMarkerRemoval

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

[GitHub] kafka pull request #3064: KAFKA-5252: Fix transient failures LogCleanerTest ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3064 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] kafka pull request #3065: KAFKA-4714: TimestampConverter transformation (KIP...

GitHub user ewencp opened a pull request: https://github.com/apache/kafka/pull/3065 KAFKA-4714: TimestampConverter transformation (KIP-66) You can merge this pull request into a Git repository by running: $ git pull https://github.com/ewencp/kafka

[jira] [Commented] (KAFKA-4714) Implement remaining KIP-66 SMTs

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

[jira] [Created] (KAFKA-5243) Request to add row limit in ReadOnlyKeyValueStore range function

Joe Wood created KAFKA-5243: --- Summary: Request to add row limit in ReadOnlyKeyValueStore range function Key: KAFKA-5243 URL: https://issues.apache.org/jira/browse/KAFKA-5243 Project: Kafka Issue

Build failed in Jenkins: kafka-0.10.2-jdk7 #162

See Changes: [ismael] KAFKA-5232; Fix Log.parseTopicPartitionName to handle deleted topics -- [...truncated 815.11 KB...] org.apache.kafka.streams.kstream.TimeWindowsTest

[jira] [Updated] (KAFKA-5242) state task directory locked forever

[ https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukas Gemela updated KAFKA-5242: Issue Type: Improvement (was: Bug) > state task directory locked forever >

[jira] [Work started] (KAFKA-5233) Changes to punctuate semantics (KIP-138)

[ https://issues.apache.org/jira/browse/KAFKA-5233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5233 started by Michal Borowiecki. > Changes to punctuate semantics (KIP-138) >

[jira] [Updated] (KAFKA-5233) Changes to punctuate semantics (KIP-138)

[ https://issues.apache.org/jira/browse/KAFKA-5233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michal Borowiecki updated KAFKA-5233: - Status: Patch Available (was: In Progress) Pull request here:

[jira] [Updated] (KAFKA-5242) add max_number _of_retries to exponential backoff strategy

[ https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukas Gemela updated KAFKA-5242: Summary: add max_number _of_retries to exponential backoff strategy (was: state task directory

[jira] [Updated] (KAFKA-5242) add max_number _of_retries to exponential backoff strategy

[ https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukas Gemela updated KAFKA-5242: Description: >From time to time, during relabance we are getting a lot of exceptions saying

[jira] [Updated] (KAFKA-5242) add max_number _of_retries to exponential backoff strategy

[ https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukas Gemela updated KAFKA-5242: Attachment: (was: clio_170511.log) > add max_number _of_retries to exponential backoff strategy

[jira] [Updated] (KAFKA-5240) Make persistent checkpointedOffsets optionable

[ https://issues.apache.org/jira/browse/KAFKA-5240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukas Gemela updated KAFKA-5240: Description: By looking at the ProcessorStateManager class kafka streams library tries to persist

[jira] [Updated] (KAFKA-5242) add max_number _of_retries to exponential backoff strategy

[ https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukas Gemela updated KAFKA-5242: Priority: Minor (was: Major) > add max_number _of_retries to exponential backoff strategy >

[jira] [Updated] (KAFKA-5240) Make persistent checkpointedOffsets optionable

[ https://issues.apache.org/jira/browse/KAFKA-5240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukas Gemela updated KAFKA-5240: Priority: Minor (was: Major) > Make persistent checkpointedOffsets optionable >

<    1   2