[jira] [Created] (KAFKA-10123) Regression resetting offsets in consumer when fetching from old broker

Jason Gustafson created KAFKA-10123: --- Summary: Regression resetting offsets in consumer when fetching from old broker Key: KAFKA-10123 URL: https://issues.apache.org/jira/browse/KAFKA-10123

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

See Changes: [github] KAFKA-10005: Decouple RestoreListener from RestoreCallback (#8676) [github] MINOR: Remove unused isSticky assert out from tests only do [github] KAFKA-10102: update ProcessorTopology

[jira] [Created] (KAFKA-10122) Consumer should allow heartbeat during rebalance as well

Guozhang Wang created KAFKA-10122: - Summary: Consumer should allow heartbeat during rebalance as well Key: KAFKA-10122 URL: https://issues.apache.org/jira/browse/KAFKA-10122 Project: Kafka

Jenkins build is back to normal : kafka-trunk-jdk14 #199

See

Re: [VOTE] KIP-599: Throttle Create Topic, Create Partition and Delete Topic Operations

On Mon, Jun 8, 2020, at 14:41, Jun Rao wrote: > Hi, Colin, > > Thanks for the comment. You brought up several points. > > 1. Should we set up a per user quota? To me, it does seem we need some sort > of a quota. When the controller runs out of resources, ideally, we only > want to penalize the

[jira] [Resolved] (KAFKA-10063) UnsupportedOperation when querying cleaner metrics after shutdown

[ https://issues.apache.org/jira/browse/KAFKA-10063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-10063. - Fix Version/s: 2.6.0 Resolution: Fixed > UnsupportedOperation when querying

Jenkins build is back to normal : kafka-trunk-jdk11 #1551

See

[jira] [Resolved] (KAFKA-7608) A Kafka Streams DSL transform or process call should potentially trigger a repartition

[ https://issues.apache.org/jira/browse/KAFKA-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7608. Resolution: Fixed KIP-221 is merged. Closing this ticket. > A Kafka Streams DSL transform

Re: [VOTE] KIP-599: Throttle Create Topic, Create Partition and Delete Topic Operations

Hi, Colin, Thanks for the comment. You brought up several points. 1. Should we set up a per user quota? To me, it does seem we need some sort of a quota. When the controller runs out of resources, ideally, we only want to penalize the bad behaving applications, instead of every application. To

[jira] [Resolved] (KAFKA-10005) Decouple RestoreListener from RestoreCallback and not enable bulk loading for RocksDB

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

[jira] [Resolved] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8803. -- Resolution: Fixed > Stream will not start due to TimeoutException: Timeout expired after >

[VOTE] KIP-590: Redirect Zookeeper Mutation Protocols to The Controller

Hey all, I would like to start the vote for KIP-590: https://cwiki.apache.org/confluence/display/KAFKA/KIP-590%3A+Redirect+Zookeeper+Mutation+Protocols+to+The+Controller Thanks!

Build failed in Jenkins: kafka-trunk-jdk14 #198

See Changes: [github] MINOR: fix HTML markup (#8823) -- [...truncated 6.31 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

Re: KIP-599: Throttle Create Topic, Create Partition and Delete Topic Operations

Hi, David, Thanks for the updated KIP. Another minor comment below. 40. For the new `QUOTA_VIOLATED` error in the response to CreateTopics/CreatePartitions/DeleteTopics, could you clarify whether ThrottleTimeMs is set when the error code is set to QUOTA_VIOLATED? Jun On Mon, Jun 8, 2020 at

[jira] [Resolved] (KAFKA-10106) log time taken to handle LeaderAndIsr request

[ https://issues.apache.org/jira/browse/KAFKA-10106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-10106. - Fix Version/s: 2.7.0 Assignee: NIKHIL Resolution: Fixed Merged the PR to trunk. > log

[jira] [Created] (KAFKA-10121) Streams Task Assignment optimization design

John Roesler created KAFKA-10121: Summary: Streams Task Assignment optimization design Key: KAFKA-10121 URL: https://issues.apache.org/jira/browse/KAFKA-10121 Project: Kafka Issue Type: Task

Build failed in Jenkins: kafka-trunk-jdk11 #1550

See Changes: [github] MINOR: fix HTML markup (#8823) -- [...truncated 1.50 MB...] kafka.server.RequestQuotaTest > testResponseThrottleTime STARTED

Re: Granting permission for Create KIP

Done, added Rhett.Wang On Mon, Jun 8, 2020 at 7:40 AM wang120445...@sina.com < wang120445...@sina.com> wrote: > > Please grant permission for Create KIP to wiki ID: wang120445...@sina.com > Rhett.wang > > > wang120445...@sina.com > -- -- Guozhang

Re: [DISCUSS] KIP-590: Redirect Zookeeper Mutation Protocols to The Controller

Hey there, If no more question is raised, I will go ahead and start the vote shortly. On Thu, Jun 4, 2020 at 12:39 PM Boyang Chen wrote: > Hey there, > > bumping this thread for any further KIP-590 discussion, since it's been > quiet for a while. > > Boyang > > On Thu, May 21, 2020 at 10:31 AM

Re: KIP-599: Throttle Create Topic, Create Partition and Delete Topic Operations

Hi Jun, 30. The rate is accumulated at the partition level. Let me clarify this in the KIP. Best, David On Sat, Jun 6, 2020 at 2:37 AM Anna Povzner wrote: > Hi David, > > The KIP looks good to me. I am going to the voting thread... > > Hi Jun, > > Yes, exactly. That's a separate thing from

[DISCUSS] KIP-621: Deprecate and replace DescribeLogDirsResult.all() and .values()

Hi all, I've opened a small KIP seeking to deprecate and replace a couple of methods of DescribeLogDirsResult which refer to internal classes in their return type. https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=158862109 Please take a look if you have the time. Kind regards,

[jira] [Created] (KAFKA-10120) DescribeLogDirsResult exposes internal classes

Tom Bentley created KAFKA-10120: --- Summary: DescribeLogDirsResult exposes internal classes Key: KAFKA-10120 URL: https://issues.apache.org/jira/browse/KAFKA-10120 Project: Kafka Issue Type: Bug

Re: [DISCUSS] 2.5.1 Bug Fix Release

Hello again, all, Just a quick status update: There are currently two tickets blocking the 2.5.1 release: KAFKA-10049 KTable-KTable Foreign Key join throwing Serialization Exception KAFKA-9891 Invalid state store content after task migration with exactly_once and standby replicas

[jira] [Created] (KAFKA-10119) StreamsResetter fails with TimeoutException for older Brokers

Bruno Cadonna created KAFKA-10119: - Summary: StreamsResetter fails with TimeoutException for older Brokers Key: KAFKA-10119 URL: https://issues.apache.org/jira/browse/KAFKA-10119 Project: Kafka

Granting permission for Create KIP

Please grant permission for Create KIP to wiki ID: wang120445...@sina.com Rhett.wang wang120445...@sina.com

Re: [VOTE] KIP-584: Versioning scheme for features

Hi all, I wanted to let you know that I have made the following minor changes to the KIP-584 write up. The purpose is to ensure the design is correct for a few things which came up during implementation: 1. Feature version data type has been made to be int16 (instead of int64). The reason is two

Re: [VOTE] KIP-578: Add configuration to limit number of partitions

Hi. Can we resume the voting process for KIP-578? Thanks. On Mon, Jun 1, 2020 at 11:09 AM Gokul Ramanan Subramanian < gokul24...@gmail.com> wrote: > Thanks Colin. Have updated the KIP per your recommendations. Let me know > what you think. > > Thanks Harsha for the vote. > > On Wed, May 27, 2020

Jenkins build is back to normal : kafka-2.4-jdk8 #222

See

[GitHub] [kafka-site] showuon commented on pull request #268: MINOR: Make contact.html more clear

showuon commented on pull request #268: URL: https://github.com/apache/kafka-site/pull/268#issuecomment-640413373 @mjsax @guozhangwang , could please review this small PR? Thanks. This is an automated message from the

[GitHub] [kafka-site] showuon opened a new pull request #268: MINOR: Make contact.html more clear

showuon opened a new pull request #268: URL: https://github.com/apache/kafka-site/pull/268 In our `contact us` page, we said: > To subscribe, send an email to users-subscr...@kafka.apache.org. Once subscribed, send your emails to us...@kafka.apache.org. which will confuse users

Jenkins build is back to normal : kafka-trunk-jdk11 #1549

See