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

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3063 --- 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 enab

[jira] [Commented] (KAFKA-5231) TransactinoCoordinator does not bump epoch when aborting open transactions

[ https://issues.apache.org/jira/browse/KAFKA-5231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011817#comment-16011817 ] ASF GitHub Bot commented on KAFKA-5231: --- GitHub user guozhangwang opened a pull requ

[GitHub] kafka pull request #3066: KAFKA-5231: Bump up producer epoch when sending ab...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/3066 KAFKA-5231: Bump up producer epoch when sending abort txn markers on InitPid You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/k

[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&focusedCommentId=16011788#comment-16011788 ] ASF GitHub Bot commented on KAFKA-5252: --- Github user asfgit closed the pull request

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

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

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

[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&focusedCommentId=16011773#comment-16011773 ] ASF GitHub Bot commented on KAFKA-4714: --- GitHub user ewencp opened a pull request:

[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 kafka-3209-timestamp-converte

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] [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&focusedCommentId=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 https://git

[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&focusedCommentId=16011618#comment-16011618 ] Matthias J. Sax commented on KAFKA-5252: Seems it happened again: https://builds.

[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 KMinor-more-logging-in-fetc

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

[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&focusedCommentId=16011594#comment-16011594 ] Guozhang Wang commented on KAFKA-5154: -- Also if it is possible could you apply the la

[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&focusedCommentId=16011590#comment-16011590 ] Ian Springer commented on KAFKA-5226: - The pattern expression we're using is "[a-z][a

[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&focusedCommentId=16011590#comment-16011590 ] Ian Springer edited comment on KAFKA-5226 at 5/16/17 1:25 AM: --

[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&focusedCommentId=16011562#comment-16011562 ] Guozhang Wang commented on KAFKA-5154: -- [~Lukas Gemela] Could you upload the full log

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

See

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

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

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] [Commented] (KAFKA-5175) Transient failure: ControllerIntegrationTest.testPreferredReplicaLeaderElection

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

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 > testConsecutiveS

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] [Commented] (KAFKA-5024) Old clients don't support message format V2

[ https://issues.apache.org/jira/browse/KAFKA-5024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011482#comment-16011482 ] Ismael Juma commented on KAFKA-5024: Sounds good to me. We should include that informa

[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&focusedCommentId=16011478#comment-16011478 ] ASF GitHub Bot commented on KAFKA-3096: --- Github user asfgit closed the pull request

[GitHub] kafka pull request #3031: MINOR: Fix bug in `waitUntilLeaderIsElectedOrChang...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3031 --- 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 enab

[jira] [Commented] (KAFKA-5024) Old clients don't support message format V2

[ https://issues.apache.org/jira/browse/KAFKA-5024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011472#comment-16011472 ] Jason Gustafson commented on KAFKA-5024: Since we are deprecating the old consumer

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

[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&focusedCommentId=16011452#comment-16011452 ] Matthias J. Sax commented on KAFKA-5226: Thanks for the logs. It seems you subscri

[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&focusedCommentId=16011449#comment-16011449 ] Ismael Juma commented on KAFKA-5175: Another instance: {code} java.lang.AssertionErro

[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 SourceNodeRecordDeserializer.

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 > testParseSi

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

[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&focusedCommentId=16011434#comment-16011434 ] ASF GitHub Bot commented on KAFKA-5249: --- Github user asfgit closed the pull request

[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 [https://github.com/apa

[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&focusedCommentId=16011425#comment-16011425 ] Matthias J. Sax commented on KAFKA-4222: Seems not to be fixed: https://builds.ap

[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&focusedCommentId=16011422#comment-16011422 ] ASF GitHub Bot commented on KAFKA-5179: --- Github user asfgit closed the pull request

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

[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 [https://github.com/apache/kafka/pull/29

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 ad

[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&focusedCommentId=16011385#comment-16011385 ] Sriram Subramanian commented on KAFKA-5151: --- [~guozhang] can we close this? > R

[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&focusedCommentId=16011372#comment-16011372 ] ASF GitHub Bot commented on KAFKA-5244: --- Github user asfgit closed the pull request

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

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

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

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 -- [...truncated

[jira] [Updated] (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 ] Sriram Subramanian updated KAFKA-5249: -- Labels: exactly-once (was: ) > Transaction index recovery does not snapshot properly >

[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&focusedCommentId=16011360#comment-16011360 ] Tommy Becker commented on KAFKA-5241: - I should also add that it seems broken that in

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

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

Jason Gustafson created KAFKA-5251: -- Summary: Producer should drop queued sends when transaction is aborted Key: KAFKA-5251 URL: https://issues.apache.org/jira/browse/KAFKA-5251 Project: Kafka

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

[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&focusedCommentId=16011331#comment-16011331 ] Matthias J. Sax edited comment on KAFKA-5154 at 5/15/17 9:10 PM: ---

[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&focusedCommentId=16011331#comment-16011331 ] Matthias J. Sax commented on KAFKA-5154: Thanks for sharing the logs. We cycle bac

[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 ] Bharat Viswanadham updated KAFKA-5225: -- Status: Patch Available (was: In Progress) > StreamsResetter doesn't allow custom Consu

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

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

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

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

See

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

See

[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] [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&focusedCommentId=16011252#comment-16011252 ] ASF GitHub Bot commented on KAFKA-5246: --- GitHub user datalorax opened a pull request

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

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

[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&focusedCommentId=16011238#comment-16011238 ] ASF GitHub Bot commented on KAFKA-5248: --- Github user asfgit closed the pull request

[GitHub] kafka pull request #3058: KAFKA-5248: Remove unused/unneeded retention time ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3058 --- 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 enab

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

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

[jira] [Comment Edited] (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:comment-tabpanel&focusedCommentId=16011222#comment-16011222 ] Lukas Gemela edited comment on KAFKA-5242 at 5/15/17 7:48 PM: --

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16011222#comment-16011222 ] Lukas Gemela commented on KAFKA-5242: - We used two stream threads, like I said we have

[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&focusedCommentId=16011162#comment-16011162 ] ASF GitHub Bot commented on KAFKA-5249: --- GitHub user hachikuji opened a pull request

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

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3060 KAFKA-5249: Fix incorrect producer snapshot offsets when recovering segments You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka K

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

See Changes: [junrao] KAFKA-5203; Metrics: fix resetting of histogram sample -- [...truncated 1.66 MB...] org.apache.kafka.streams.processor.TopologyBuilderTest > shouldN

[jira] [Updated] (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 ] Jason Gustafson updated KAFKA-5249: --- Issue Type: Sub-task (was: Bug) Parent: KAFKA-4815 > Transaction index recovery does

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

Jason Gustafson created KAFKA-5249: -- Summary: Transaction index recovery does not snapshot properly Key: KAFKA-5249 URL: https://issues.apache.org/jira/browse/KAFKA-5249 Project: Kafka Issue

[jira] [Updated] (KAFKA-5247) Consumer GroupCoordinator should continue to materialize committed offsets in offset order even for transactional offset commits

[ https://issues.apache.org/jira/browse/KAFKA-5247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta updated KAFKA-5247: Issue Type: Sub-task (was: Bug) Parent: KAFKA-4815 > Consumer GroupCoordinator should conti

[jira] [Updated] (KAFKA-5231) TransactinoCoordinator does not bump epoch when aborting open transactions

[ https://issues.apache.org/jira/browse/KAFKA-5231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta updated KAFKA-5231: Issue Type: Sub-task (was: Bug) Parent: KAFKA-4815 > TransactinoCoordinator does not bump e

[jira] [Resolved] (KAFKA-5205) CachingSessionStore doesn't use the default keySerde.

[ https://issues.apache.org/jira/browse/KAFKA-5205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5205. -- Resolution: Fixed Fix Version/s: 0.10.2.2 0.11.0.0 > CachingSessionSto

[GitHub] kafka pull request #2963: Kafka-5205: Removed use of keySerde in CachingSess...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2963 --- 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 enab

[jira] [Assigned] (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 reassigned KAFKA-5246: -- Assignee: Andy Coates > Remove backdoor that allows any client to produce to internal topics >

Re: Can someone assign, or give me permission to assign myself to a Jira please?

Andy, I can see you now in the contributor list. Please feel free to assign JIRAs to yourself now. Guozhang On Mon, May 15, 2017 at 10:49 AM, Andrew Coates wrote: > Hi, > > I have a patch for KAFKA-5246 jira/browse/KAFKA-5246>, but don’t yet have permissions to a

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

See Changes: [junrao] KAFKA-5203; Metrics: fix resetting of histogram sample -- [...truncated 860.42 KB...] kafka.server.KafkaConfigTest > testLogRollTimeMsProvided PASSED

[GitHub] kafka pull request #3041: MINOR: Eliminate PID terminology from non test cod...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3041 --- 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 enab

[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&focusedCommentId=16011053#comment-16011053 ] ASF GitHub Bot commented on KAFKA-5244: --- GitHub user ijuma opened a pull request:

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

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/3059 KAFKA-5244: Refactor BrokerTopicStats and ControllerStats so that they are classes This removes the need to force object initialisation via hacks to register the relevant metrics during start-up.

[jira] [Resolved] (KAFKA-5206) RocksDBSessionStore doesn't use default aggSerde.

[ https://issues.apache.org/jira/browse/KAFKA-5206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5206. -- Resolution: Fixed Fix Version/s: 0.10.2.2 0.11.0.0 Issue resolved by p

[GitHub] kafka pull request #2971: Kafka-5206: Remove use of aggSerde in RocksDBSessi...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2971 --- 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 enab

[GitHub] kafka pull request #3056: HOTFIX: AddOffsetsToTxnResponse using incorrect sc...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3056 --- 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 enab

[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&focusedCommentId=16011027#comment-16011027 ] ASF GitHub Bot commented on KAFKA-5248: --- GitHub user hachikuji opened a pull request

[GitHub] kafka pull request #3058: KAFKA-5248: Remove unused/unneeded retention time ...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3058 KAFKA-5248: Remove unused/unneeded retention time in TxnOffsetCommitRequest You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KA

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16011025#comment-16011025 ] Matthias J. Sax commented on KAFKA-5242: Both should work. From a Streams perspect

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

Jason Gustafson created KAFKA-5248: -- Summary: Remove retention time from TxnOffsetCommit RPC Key: KAFKA-5248 URL: https://issues.apache.org/jira/browse/KAFKA-5248 Project: Kafka Issue Type:

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

Hi, Sorry for super late response. Thanks for your comments. I am not an expert on Lambdas. Can you elaborate a little bit? I cannot > follow the explanation in the KIP to see what the problem is. - From [1] says "A functional interface is an interface that has just one abstract method, and thu

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

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5154: Assignee: Matthias J. Sax > Kafka Streams throws NPE during rebalance > ---

Re: KafkaStreams reports RUNNING even though all StreamThreads has crashed

Hi Andreas, This is not an intended behavior. Could you file a JIRA and describe your Kafka broker version / Streams API version, the logs / stack traces you saw in that ticket? I'd like to help investigate and walk you through the process to contribute a fix if you are interested and have time.

[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&focusedCommentId=16010990#comment-16010990 ] Jun Rao commented on KAFKA-5246: [~BigAndy], thanks for your interest. Just added you to K

[jira] [Commented] (KAFKA-5203) Percentilles are calculated incorrectly

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

[GitHub] kafka pull request #3002: KAFKA-5203: Metrics: fix resetting of histogram sa...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3002 --- 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 enab

[jira] [Resolved] (KAFKA-5203) Percentilles are calculated incorrectly

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

  1   2   >