[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=16011851#comment-16011851 ] Onur Karaman commented on KAFKA-5175: - Cool. I can steadily reproduce this by insertin

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

[ https://issues.apache.org/jira/browse/KAFKA-5175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011851#comment-16011851 ] Onur Karaman edited comment on KAFKA-5175 at 5/16/17 7:01 AM: --

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

See Changes: [wangguoz] MINOR: Print offset and size in sendFetches -- [...truncated 860.25 KB...] kafka.server.LogOffsetTest > testEmptyLogsGetOffsets PASSED kafka.serve

[GitHub] kafka pull request #3067: KAFKA-5175: Fix transient failure in ControllerInt...

GitHub user onurkaraman opened a pull request: https://github.com/apache/kafka/pull/3067 KAFKA-5175: Fix transient failure in ControllerIntegrationTest.testPreferredReplicaLeaderElection The transient failure came from the controller processing the preferred replica leader election

[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=16011926#comment-16011926 ] ASF GitHub Bot commented on KAFKA-5175: --- GitHub user onurkaraman opened a pull reque

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

See

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

+1 thanks. Eno > On 16 May 2017, at 04:20, BigData dev wrote: > > 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/KAFK

[jira] [Commented] (KAFKA-4950) ConcurrentModificationException when iterating over Kafka Metrics

[ https://issues.apache.org/jira/browse/KAFKA-4950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011958#comment-16011958 ] Dumitru Postoronca commented on KAFKA-4950: --- [~vahid]: I would try to simulate b

[jira] [Comment Edited] (KAFKA-4950) ConcurrentModificationException when iterating over Kafka Metrics

[ https://issues.apache.org/jira/browse/KAFKA-4950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011958#comment-16011958 ] Dumitru Postoronca edited comment on KAFKA-4950 at 5/16/17 8:17 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=16011966#comment-16011966 ] Lukas Gemela commented on KAFKA-5154: - [~mjsax] I really can't give you any ultimate

Re: [DISCUSS] KIP-150 - Kafka-Streams Cogroup

Hi Kyle, Sorry for the delay in reviews, tomorrow is feature freeze deadline (https://cwiki.apache.org/confluence/display/KAFKA/Release+Plan+0.11.0.0 ) so people are busier than usual. Stay tuned. Eno > On 15 May 2017, at

[jira] [Created] (KAFKA-5253) KStreamTestDriver must handle streams created with patterns

Wim Van Leuven created KAFKA-5253: - Summary: KStreamTestDriver must handle streams created with patterns Key: KAFKA-5253 URL: https://issues.apache.org/jira/browse/KAFKA-5253 Project: Kafka

[jira] [Created] (KAFKA-5254) rethink KTable API overloads

Eno Thereska created KAFKA-5254: --- Summary: rethink KTable API overloads Key: KAFKA-5254 URL: https://issues.apache.org/jira/browse/KAFKA-5254 Project: Kafka Issue Type: Improvement Co

[jira] [Updated] (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 ] Lukas Gemela updated KAFKA-5154: Attachment: clio_afa596e9b809.gz [~guozhang] full logs attached. > Kafka Streams throws NPE during

[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=16011982#comment-16011982 ] Lukas Gemela edited comment on KAFKA-5154 at 5/16/17 8:33 AM: --

[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=16011966#comment-16011966 ] Lukas Gemela edited comment on KAFKA-5154 at 5/16/17 8:37 AM: --

[jira] [Assigned] (KAFKA-4623) Change Default unclean.leader.election.enabled from True to False

[ https://issues.apache.org/jira/browse/KAFKA-4623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-4623: -- Assignee: Sharad (was: Ben Stopford) > Change Default unclean.leader.election.enabled from Tru

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

[ https://issues.apache.org/jira/browse/KAFKA-5175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5175. Resolution: Fixed Fix Version/s: 0.11.0.0 Issue resolved by pull request 3067 [https://github

[GitHub] kafka pull request #3067: KAFKA-5175: Fix transient failure in ControllerInt...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3067 --- 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-5175) Transient failure: ControllerIntegrationTest.testPreferredReplicaLeaderElection

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

[jira] [Updated] (KAFKA-3984) Broker doesn't retry reconnecting to an expired Zookeeper connection

[ https://issues.apache.org/jira/browse/KAFKA-3984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Braedon Vickers updated KAFKA-3984: --- Affects Version/s: 0.10.1.1 > Broker doesn't retry reconnecting to an expired Zookeeper connec

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

See

[jira] [Resolved] (KAFKA-5215) Small JavaDoc fix for AdminClient#describeTopics

[ https://issues.apache.org/jira/browse/KAFKA-5215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5215. Resolution: Fixed Fix Version/s: 0.11.0.0 Issue resolved by pull request 3013 [https://github

[GitHub] kafka pull request #3013: KAFKA-5215. Small JavaDoc fix for AdminClient#desc...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3013 --- 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-5215) Small JavaDoc fix for AdminClient#describeTopics

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

Re: [DISCUSS] KIP-150 - Kafka-Streams Cogroup

No problem, I just wanted to make sure people still had more to say. I will wait another week. Thanks, Kyle On May 16, 2017 4:25 AM, "Eno Thereska" wrote: > Hi Kyle, > > Sorry for the delay in reviews, tomorrow is feature freeze deadline ( > https://cwiki.apache.org/confluence/display/KAFKA/Rel

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

See Changes: [ismael] KAFKA-5215; Small Javadoc fixes for AdminClient#describeTopics -- [...truncated 1.66 MB...] org.apache.kafka.streams.processor.TopologyBuilderTest >

[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=16012270#comment-16012270 ] Damian Guy commented on KAFKA-5241: --- [~twbecker] Probably worth filing another JIRA for

[jira] [Updated] (KAFKA-977) Implement generation/term per leader to reconcile messages correctly

[ https://issues.apache.org/jira/browse/KAFKA-977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-977: -- Fix Version/s: 0.11.0.0 > Implement generation/term per leader to reconcile messages correctly >

[jira] [Resolved] (KAFKA-977) Implement generation/term per leader to reconcile messages correctly

[ https://issues.apache.org/jira/browse/KAFKA-977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-977. --- Resolution: Fixed Marking this as fixed since it seems to be the same as KIP-101/KAFKA-1211. > Impleme

[jira] [Created] (KAFKA-5255) Auto generate request/response classes

Ismael Juma created KAFKA-5255: -- Summary: Auto generate request/response classes Key: KAFKA-5255 URL: https://issues.apache.org/jira/browse/KAFKA-5255 Project: Kafka Issue Type: New Feature

Re: [DISCUSS] KIP-150 - Kafka-Streams Cogroup

Hi Kyle, Can you put the code examples etc in {code} blocks to make it easier to read? I think this is probably a pretty common use-case and therefore a worthwhile addition to the API. I'd suggest dropping the K from KCogroupedStream and calling it CogroupedStream or CogroupedKStream. In your ex

[GitHub] kafka pull request #3068: KAFKA-5250: Do fetch down conversion after throttl...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/3068 KAFKA-5250: Do fetch down conversion after throttling Perform down conversion after throttling to avoid retaining messages in memory during throttling since this could result in OOM. Also upda

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

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

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

Hi, Thanks for your comments. I think supporting Lambdas for `withKey` and `AbstractRichFunction` > don't go together, as Lambdas are only supported for interfaces AFAIK. Maybe I misunderstood your comment. *withKey* and and *withOnlyValue* are interfaces. So they don't have direct relation wit

[GitHub] kafka pull request #2766: KAFKA-4913: creating a window store with one segme...

Github user dguy closed the pull request at: https://github.com/apache/kafka/pull/2766 --- 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 enable

[jira] [Commented] (KAFKA-4913) creating a window store with one segment throws division by zero error

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

[jira] [Created] (KAFKA-5256) Non-checkpointed state stores should be deleted before restore

Tommy Becker created KAFKA-5256: --- Summary: Non-checkpointed state stores should be deleted before restore Key: KAFKA-5256 URL: https://issues.apache.org/jira/browse/KAFKA-5256 Project: Kafka I

[jira] [Created] (KAFKA-5257) CLONE - Change Default unclean.leader.election.enabled from True to False

Chris Lambertus created KAFKA-5257: -- Summary: CLONE - Change Default unclean.leader.election.enabled from True to False Key: KAFKA-5257 URL: https://issues.apache.org/jira/browse/KAFKA-5257 Project:

Kafka Connect: To much restarting with a SourceConnector with dynamic set of tasks

Hi Kafka (Connect) 0.10.2.1 I am writing my own SourceConnector. It will communicate with a remote server, and continuously calculate the set of tasks that has to be running. Each task also makes a connection to the remote server from which it will get its data to forward to Kafka. When the

CreateTopicRequest Protocol

Hi, >From the CreateTopicRequest protocol documentation here ( https://kafka.apache.org/protocol#The_Messages_CreateTopics), it looks like we can set numPartitions=-1 and replicationFactor=-1 to unset it. My understanding is that if I set the values as those (-1), then the topic will be created wi

[jira] [Commented] (KAFKA-5257) CLONE - Change Default unclean.leader.election.enabled from True to False

[ https://issues.apache.org/jira/browse/KAFKA-5257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012595#comment-16012595 ] Ismael Juma commented on KAFKA-5257: The original JIRA for KIP-106 was KAFKA-4623, but

[jira] [Resolved] (KAFKA-5257) CLONE - Change Default unclean.leader.election.enabled from True to False

[ https://issues.apache.org/jira/browse/KAFKA-5257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5257. Resolution: Fixed > CLONE - Change Default unclean.leader.election.enabled from True to False >

[jira] [Deleted] (KAFKA-4623) Change Default unclean.leader.election.enabled from True to False

[ https://issues.apache.org/jira/browse/KAFKA-4623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Lambertus deleted KAFKA-4623: --- > Change Default unclean.leader.election.enabled from True to False > ---

[jira] [Commented] (KAFKA-977) Implement generation/term per leader to reconcile messages correctly

[ https://issues.apache.org/jira/browse/KAFKA-977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012637#comment-16012637 ] Jun Rao commented on KAFKA-977: --- Just to clarify. KAFKA-1211 added leader epoch in message se

[jira] [Commented] (KAFKA-977) Implement generation/term per leader to reconcile messages correctly

[ https://issues.apache.org/jira/browse/KAFKA-977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012645#comment-16012645 ] Ismael Juma commented on KAFKA-977: --- [~junrao], should we reopen this then? I believe the

[jira] [Commented] (KAFKA-5256) Non-checkpointed state stores should be deleted before restore

[ https://issues.apache.org/jira/browse/KAFKA-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012717#comment-16012717 ] Guozhang Wang commented on KAFKA-5256: -- [~twbecker] Thanks for reporting this. Could

[jira] [Assigned] (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 ] Guozhang Wang reassigned KAFKA-5241: Assignee: Tommy Becker > GlobalKTable does not checkpoint offsets after restoring state > -

[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=16012722#comment-16012722 ] Guozhang Wang commented on KAFKA-5241: -- [~twbecker] Added you to the contributor list

[jira] [Resolved] (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:all-tabpanel ] Guozhang Wang resolved KAFKA-5151. -- Resolution: Fixed Fix Version/s: 0.11.0.0 > Refactor TransactionCoordinator in-memory str

[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=16012726#comment-16012726 ] Guozhang Wang commented on KAFKA-5151: -- Fixed as part of KAFKA-5130 > Refactor Trans

Re: [DISCUSS] KIP-150 - Kafka-Streams Cogroup

I have added code blocks and a note about the partial results. Can I ask why you dont like KCogroupedStream? I just think that because it is created from a KGroupedStream we should keep a similar name format. On May 16, 2017 9:23 AM, "Damian Guy" wrote: Hi Kyle, Can you put the code examples e

[jira] [Commented] (KAFKA-5256) Non-checkpointed state stores should be deleted before restore

[ https://issues.apache.org/jira/browse/KAFKA-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012736#comment-16012736 ] Tommy Becker commented on KAFKA-5256: - Well ideally it is idempotent yes, but consider

[jira] [Commented] (KAFKA-5256) Non-checkpointed state stores should be deleted before restore

[ https://issues.apache.org/jira/browse/KAFKA-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012738#comment-16012738 ] Tommy Becker commented on KAFKA-5256: - I noticed this originally when my state store d

[jira] [Resolved] (KAFKA-5129) TransactionCoordinator - Add ACL check for each request

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

[GitHub] kafka pull request #2979: KAFKA-5129: Add ACL checks for Transactional APIs

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2979 --- 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-5129) TransactionCoordinator - Add ACL check for each request

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

Re: [DISCUSS] KIP-150 - Kafka-Streams Cogroup

Yeah - i wish we'd named KGroupedStream GroupedKStream, similarly for KGroupedTable. On Tue, 16 May 2017 at 17:59 Kyle Winkelman wrote: > I have added code blocks and a note about the partial results. > > Can I ask why you dont like KCogroupedStream? I just think that because it > is created fro

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

See

[GitHub] kafka pull request #3069: KAFKA-4957: Request rate quotas documentation

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/3069 KAFKA-4957: Request rate quotas documentation You can merge this pull request into a Git repository by running: $ git pull https://github.com/rajinisivaram/kafka KAFKA-4957 Alternativel

[jira] [Commented] (KAFKA-4957) Add documentation for request quotas

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

[GitHub] kafka pull request #3040: MINOR: Some minor improvements to TxnOffsetCommit ...

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

You're Invited: Streams Processing Meetup at LinkedIn on May 24

Hi Kafka & Samza communities, I wanted to send a reminder that the Streams team at LinkedIn invites you to attend a meetup here at Linkedin on Wednesday, May 24 from 6-9PM . You will learn about the interesting things th

[jira] [Created] (KAFKA-5258) move all partition and replica state transition rules into a map

Onur Karaman created KAFKA-5258: --- Summary: move all partition and replica state transition rules into a map Key: KAFKA-5258 URL: https://issues.apache.org/jira/browse/KAFKA-5258 Project: Kafka

[GitHub] kafka pull request #3070: AdminClient: add some more APIs

GitHub user cmccabe opened a pull request: https://github.com/apache/kafka/pull/3070 AdminClient: add some more APIs Add a public create API that takes an AdminClientConf object. Make the constructors for TopicDescription, TopicListing, and TopicPartitionInfo public to enabl

[jira] [Work started] (KAFKA-5229) Reflections logs excessive warnings when scanning classpaths

[ https://issues.apache.org/jira/browse/KAFKA-5229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5229 started by Bharat Viswanadham. - > Reflections logs excessive warnings when scanning classpaths > --

[jira] [Assigned] (KAFKA-5229) Reflections logs excessive warnings when scanning classpaths

[ https://issues.apache.org/jira/browse/KAFKA-5229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharat Viswanadham reassigned KAFKA-5229: - Assignee: Bharat Viswanadham > Reflections logs excessive warnings when scanning

[jira] [Created] (KAFKA-5259) TransactionalId authorization should imply ProducerId authorization

Jason Gustafson created KAFKA-5259: -- Summary: TransactionalId authorization should imply ProducerId authorization Key: KAFKA-5259 URL: https://issues.apache.org/jira/browse/KAFKA-5259 Project: Kafka

[GitHub] kafka pull request #3071: KAFKA-5258: move all partition and replica state t...

GitHub user onurkaraman opened a pull request: https://github.com/apache/kafka/pull/3071 KAFKA-5258: move all partition and replica state transition rules into a map Today the PartitionStateMachine and ReplicaStateMachine defines and asserts the valid state transitions inline for ea

[jira] [Commented] (KAFKA-5258) move all partition and replica state transition rules into a map

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

[jira] [Work started] (KAFKA-5258) move all partition and replica state transition rules into a map

[ https://issues.apache.org/jira/browse/KAFKA-5258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5258 started by Onur Karaman. --- > move all partition and replica state transition rules into a map > --

[GitHub] kafka pull request #3054: KAFKA-5241: GlobalKTable does not checkpoint offse...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3054 --- 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-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=16013101#comment-16013101 ] ASF GitHub Bot commented on KAFKA-5241: --- Github user asfgit closed the pull request

[jira] [Updated] (KAFKA-5258) move all partition and replica state transition rules into a map

[ https://issues.apache.org/jira/browse/KAFKA-5258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Onur Karaman updated KAFKA-5258: Status: Patch Available (was: In Progress) > move all partition and replica state transition rules

[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 ] Guozhang Wang updated KAFKA-5241: - Resolution: Fixed Fix Version/s: 0.10.2.2 Status: Resolved (was: Patch Available

[GitHub] kafka pull request #3072: KAFKA-5229:Reflections logs excessive warnings whe...

GitHub user bharatviswa504 opened a pull request: https://github.com/apache/kafka/pull/3072 KAFKA-5229:Reflections logs excessive warnings when scanning classpaths changed the reflections log level to ERROR. And tested it, now the warning logs are not shown up during the start of

[jira] [Commented] (KAFKA-5229) Reflections logs excessive warnings when scanning classpaths

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

[jira] [Updated] (KAFKA-5229) Reflections logs excessive warnings when scanning classpaths

[ https://issues.apache.org/jira/browse/KAFKA-5229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharat Viswanadham updated KAFKA-5229: -- Status: Patch Available (was: In Progress) > Reflections logs excessive warnings when s

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

See Changes: [jason] MINOR: Some minor improvements to TxnOffsetCommit handling -- [...truncated 866.12 KB...] kafka.log.ProducerStateManagerTest > testDeleteSnapshotsBef

[jira] [Commented] (KAFKA-5256) Non-checkpointed state stores should be deleted before restore

[ https://issues.apache.org/jira/browse/KAFKA-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16013135#comment-16013135 ] Tommy Becker commented on KAFKA-5256: - Thinking about this some more, the scenario out

[jira] [Updated] (KAFKA-5166) Add option "dry run" to Streams application reset tool

[ https://issues.apache.org/jira/browse/KAFKA-5166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5166: - Resolution: Fixed Fix Version/s: 0.11.0.0 Status: Resolved (was: Patch Available

[GitHub] kafka pull request #3005: KAFKA-5166: Add option "dry run" to Streams applic...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3005 --- 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-5166) Add option "dry run" to Streams application reset tool

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

[jira] [Updated] (KAFKA-5254) rethink KTable API overloads

[ https://issues.apache.org/jira/browse/KAFKA-5254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5254: --- Labels: needs-kip (was: ) > rethink KTable API overloads > > >

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

[ https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-4222: Reopening this: test failed yesterday and today. https://builds.apache.org/blue/organizations/j

[jira] [Commented] (KAFKA-5256) Non-checkpointed state stores should be deleted before restore

[ https://issues.apache.org/jira/browse/KAFKA-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16013159#comment-16013159 ] Guozhang Wang commented on KAFKA-5256: -- Thanks for the explanation. I agree that idea

Re: [VOTE] KIP-155 Add range scan for windowed state stores

Hi, Given the lack of any further comments or new votes, I'm assuming everyone who already voted is still in agreement and I will close the vote. The vote passed with 3 binding +1 votes (Guozhang, Sriram, Jason) and 2 non-binding +1 votes (Bill, Eno) Thank you, Xavier On Fri, May 12, 2017 at 9:

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

See Changes: [wangguoz] KAFKA-5241: GlobalKTable should checkpoint offsets after restoring state -- [...truncated 159.00 KB...] kafka.server.AbstractFetcherThreadTest > t

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

See

Re: [DISCUSS] Modify / Remove "Unstable" annotations in Streams API

Hello Matthias, Reply inlined. On Sat, May 13, 2017 at 1:40 PM, Matthias J. Sax wrote: > +1 for the overall proposal. > > Some comments: > > Currently, `Windowed#window()` returns type `Window` and I am wondering > if we should improve type safety here and return the actual window type > (ie, T

[GitHub] kafka pull request #3073: KAFKA-5210:Application Reset Tool does not need to...

GitHub user bharatviswa504 opened a pull request: https://github.com/apache/kafka/pull/3073 KAFKA-5210:Application Reset Tool does not need to seek for internal topics @mjsax @dguy @guozhangwang Could you please review the changes. You can merge this pull request into a Git reposito

[jira] [Updated] (KAFKA-5210) Application Reset Tool does not need to seek for internal topics

[ https://issues.apache.org/jira/browse/KAFKA-5210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharat Viswanadham updated KAFKA-5210: -- Status: Patch Available (was: In Progress) > Application Reset Tool does not need to se

[jira] [Commented] (KAFKA-5210) Application Reset Tool does not need to seek for internal topics

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

Re: [DISCUSS] Modify / Remove "Unstable" annotations in Streams API

About Windows: We got the request to add TimeWindows etc to public API anyway. I guess it's helpful for people adding their own window aggregates using low-level API. But as mentioned already, it was just a thought, and I am also not 100% sure if we would gain much by changing the return type. Th

[GitHub] kafka pull request #3074: KAFKA-5036: hold onto the leader lock in Partition...

GitHub user junrao opened a pull request: https://github.com/apache/kafka/pull/3074 KAFKA-5036: hold onto the leader lock in Partition while serving an O… …ffsetForLeaderEpoch request You can merge this pull request into a Git repository by running: $ git pull https://githu

[jira] [Commented] (KAFKA-5036) Followups from KIP-101

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

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

See Changes: [wangguoz] KAFKA-5241: GlobalKTable should checkpoint offsets after restoring state [wangguoz] KAFKA-5166: Add option "dry run" to Streams application reset tool --

[jira] [Created] (KAFKA-5260) Producer should not send AbortTxn unless transaction has actually begun

Jason Gustafson created KAFKA-5260: -- Summary: Producer should not send AbortTxn unless transaction has actually begun Key: KAFKA-5260 URL: https://issues.apache.org/jira/browse/KAFKA-5260 Project: Ka

[GitHub] kafka pull request #3069: KAFKA-4957: Request rate quotas documentation

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3069 --- 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-4957) Add documentation for request quotas

[ https://issues.apache.org/jira/browse/KAFKA-4957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-4957. Resolution: Fixed Issue resolved by pull request 3069 [https://github.com/apache/kafka/pull/3069] > Add doc

  1   2   >