Re: New Website Layout

Hi Tom, Ben, PR is ready to address the issue you saw: https://github.com/apache/kafka-site/pull/292 Thanks. On Wed, Aug 12, 2020 at 1:09 AM Tom Bentley wrote: > Hi Ben, > > Thanks for fixing that. Another problem I've just noticed is a couple of > garbled headings. E.g. scroll down from > http

[GitHub] [kafka-site] showuon opened a new pull request #292: MINOR: Fix the corrupted html content

showuon opened a new pull request #292: URL: https://github.com/apache/kafka-site/pull/292 Fix the corrupted html content by referring to the `25/design.html` html content. ![image](https://user-images.githubusercontent.com/43372967/89982013-83f8ef00-dca7-11ea-9bce-527a2bc0847d.

[jira] [Created] (KAFKA-10391) Streams should overwrite checkpoint excluding corrupted partitions

Guozhang Wang created KAFKA-10391: - Summary: Streams should overwrite checkpoint excluding corrupted partitions Key: KAFKA-10391 URL: https://issues.apache.org/jira/browse/KAFKA-10391 Project: Kafka

[jira] [Resolved] (KAFKA-9450) Decouple inner state flushing from committing

[ https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9450. -- Fix Version/s: 2.7.0 Resolution: Fixed > Decouple inner state flushing from committing >

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #4

See Changes: [github] MINOR: Remove `PartitionHeader` abstraction from `FetchResponse` schema (#9164) -- [...truncated 3.21 MB...] org.apache.kafka.streams.t

[GitHub] [kafka-site] showuon commented on pull request #289: MINOR: Fix the broken past-events link

showuon commented on pull request #289: URL: https://github.com/apache/kafka-site/pull/289#issuecomment-672543644 It's because the `quickstart.html` got removed in this PR: this PR: https://github.com/apache/kafka-site/pull/286. I think we should keep `quickstart.html`, `quickstart-zookeep

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #3

See Changes: [github] MINOR: bump 2.5 versions to 2.5.1 (#9165) -- [...truncated 6.43 MB...] org.apache.kafka.streams.test.OutputVerifierTest > shouldPassIfKe

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #3

See Changes: [github] MINOR: bump 2.5 versions to 2.5.1 (#9165) -- [...truncated 6.43 MB...] org.apache.kafka.streams.TopologyTestDriverTest > shouldSetRecordM

Jenkins build is back to normal : Kafka » kafka-trunk-jdk8 #3

See

[jira] [Created] (KAFKA-10390) kafka-server-stop lookup is not specific enough and may kill other processes

Lucas Bradstreet created KAFKA-10390: Summary: kafka-server-stop lookup is not specific enough and may kill other processes Key: KAFKA-10390 URL: https://issues.apache.org/jira/browse/KAFKA-10390

[jira] [Created] (KAFKA-10389) Fix zero copy tagged arrays

Jason Gustafson created KAFKA-10389: --- Summary: Fix zero copy tagged arrays Key: KAFKA-10389 URL: https://issues.apache.org/jira/browse/KAFKA-10389 Project: Kafka Issue Type: Bug

Build failed in Jenkins: Kafka » kafka-2.1-jdk8 #2

See Changes: -- [...truncated 2.81 MB...] org.apache.kafka.connect.converters.IntegerConverterTest > testBytesNullToNumber PASSED org.apache.kafka.connect.converters.Integer

Re: [VOTE] KIP-595: A Raft Protocol for the Metadata Quorum

Thanks everyone for the votes. I am going to close this with +5 binding (me, Colin, Boyang, Jun, and Ismael) and none against. @Jun Yes, I think it makes sense to expose the usual request metrics for the new APIs. Best, Jason On Tue, Aug 11, 2020 at 11:30 AM Ismael Juma wrote: > Thanks for t

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #2

See Changes: [github] MINOR: Upgrade Gradle to 6.6 (#9160) -- [...truncated 6.43 MB...] org.apache.kafka.streams.test.OutputVerifierTest > shouldPassIfValueIs

Re: [ANNOUNCE] New Kafka PMC Member: John Roesler

Thanks for your kind words, all. This is truly an honor. -John On Mon, 2020-08-10 at 16:26 -0700, Boyang Chen wrote: > Congrats Mr. John! > > > On Mon, Aug 10, 2020 at 3:02 PM Adam Bellemare > wrote: > > > Congratulations John! You have been an excellent help to me and many > > others. I am pl

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #2

See Changes: [github] MINOR: Upgrade Gradle to 6.6 (#9160) -- [...truncated 6.38 MB...] org.apache.kafka.streams.TopologyTestDriverTest > shouldNotUpdateStoreF

[ANNOUNCE] Apache Kafka 2.5.1

The Apache Kafka community is pleased to announce the release for Apache Kafka 2.5.1 This is a bug fix release, and it includes fixes and improvements for 72 issues, including some critical bugs. All of the changes in this release can be found in the release notes: https://www.apache.org/dist/kaf

[jira] [Created] (KAFKA-10388) Casting errors in tagged struct conversion

Jason Gustafson created KAFKA-10388: --- Summary: Casting errors in tagged struct conversion Key: KAFKA-10388 URL: https://issues.apache.org/jira/browse/KAFKA-10388 Project: Kafka Issue Type:

[GitHub] [kafka-site] vvcephei merged pull request #291: MINOR: add 2.5.1 release to Downloads

vvcephei merged pull request #291: URL: https://github.com/apache/kafka-site/pull/291 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go t

[GitHub] [kafka-site] vvcephei commented on pull request #291: MINOR: add 2.5.1 release to Downloads

vvcephei commented on pull request #291: URL: https://github.com/apache/kafka-site/pull/291#issuecomment-672256567 Thanks, all! This is an automated message from the Apache Git Service. To respond to the message, please log o

[GitHub] [kafka-site] guozhangwang commented on pull request #291: MINOR: add 2.5.1 release to Downloads

guozhangwang commented on pull request #291: URL: https://github.com/apache/kafka-site/pull/291#issuecomment-672204528 LGTM. This is an automated message from the Apache Git Service. To respond to the message, please log on t

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #2

See Changes: [github] MINOR: Upgrade Gradle to 6.6 (#9160) -- [...truncated 3.21 MB...] org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueI

[jira] [Created] (KAFKA-10387) Cannot include SMT configs with source connector that include topic.creation.* properties

Arjun Satish created KAFKA-10387: Summary: Cannot include SMT configs with source connector that include topic.creation.* properties Key: KAFKA-10387 URL: https://issues.apache.org/jira/browse/KAFKA-10387

Re: [VOTE] KIP-595: A Raft Protocol for the Metadata Quorum

Thanks for the KIP, +1 (binding). A couple of comments: 1. We have "quorum.voters=1@kafka-1:9092, 2@kafka-2:9092, 3@kafka-3:9092". Could this be a bit confusing given that the authority part of a url is defined as "authority = [userinfo@]host[:port]"? 2. With regards to the Quorum State file, do w

[GitHub] [kafka-site] vvcephei opened a new pull request #291: MINOR: add 2.5.1 release to Downloads

vvcephei opened a new pull request #291: URL: https://github.com/apache/kafka-site/pull/291 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above t

[GitHub] [kafka-site] guozhangwang merged pull request #284: MINOR: Change the arrow direction based on the view state is expanded or not

guozhangwang merged pull request #284: URL: https://github.com/apache/kafka-site/pull/284 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

Re: New Website Layout

Hi Ben, Thanks for fixing that. Another problem I've just noticed is a couple of garbled headings. E.g. scroll down from https://kafka.apache.org/documentation.html#design_compactionbasics and the "What guarantees does log compaction provide?" section is rendering as $1 class="anchor-heading">$8$

Re: [IMPORTANT] - Migration to ci-builds.a.o

I migrated kafka-trunk and kafka 2.x builds to the new CI server. I have not migrated kafka 1.x and older since 1.1.0 is nearly 2.5 years old by now. Does anyone feel strongly that we should migrate 1.x builds? The PR builds have not been migrated yet as the plugin we depend on is not installed in

[jira] [Created] (KAFKA-10386) Fix record serialization with flexible versions

Jason Gustafson created KAFKA-10386: --- Summary: Fix record serialization with flexible versions Key: KAFKA-10386 URL: https://issues.apache.org/jira/browse/KAFKA-10386 Project: Kafka Issue T

Re: [ANNOUNCE] New Kafka PMC Member: John Roesler

Congrats John! --Vahid On Tue, Aug 11, 2020, 02:37 Ismael Juma wrote: > Congratulations John! > > Ismael > > On Mon, Aug 10, 2020 at 1:11 PM Jun Rao wrote: > > > Hi, Everyone, > > > > John Roesler has been a Kafka committer since Nov. 5, 2019. He has > remained > > active in the community sinc

Build failed in Jenkins: Kafka » kafka-2.0-jdk8 #1

See Changes: -- [...truncated 435.61 KB...] kafka.log.LogValidatorTest > testCompressedBatchWithoutRecordsNotAllowed STARTED kafka.log.LogValidatorTest > testCompressedBatchW

[GitHub] [kafka-site] tom1299 opened a new pull request #290: MINOR: Add missing to to testing

tom1299 opened a new pull request #290: URL: https://github.com/apache/kafka-site/pull/290 Just added a missing "to" to testing.html This is an automated message from the Apache Git Service. To respond to the message, please

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #1

See Changes: -- [...truncated 3.19 MB...] org.apache.kafka.streams.TopologyTestDriverTest > shouldRespectTaskIdling[Eos enabled = false] STARTED org.apache.kafka.streams.To

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #1

See Changes: -- [...truncated 3.22 MB...] org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfTimestampIsDifferentForCompareValueTimestamp PASSED org.apache.ka

[jira] [Created] (KAFKA-10385) When DetailStat activated Final Print is necessary when result is out of time.

sebastien diaz created KAFKA-10385: -- Summary: When DetailStat activated Final Print is necessary when result is out of time. Key: KAFKA-10385 URL: https://issues.apache.org/jira/browse/KAFKA-10385 Pr

Re: [DISCUSS] KIP-631: The Quorum-based Kafka Controller

>>Hi Unmesh, >>Thanks, I'll take a look. Thanks. I will be adding more to the prototype and will be happy to help and collaborate. Thanks, Unmesh On Tue, Aug 11, 2020 at 12:28 AM Colin McCabe wrote: > Hi Jose, > > That'a s good point that I hadn't considered. It's probably worth having > a sep

[GitHub] [kafka-site] showuon commented on pull request #289: MINOR: Fix the broken past-events link

showuon commented on pull request #289: URL: https://github.com/apache/kafka-site/pull/289#issuecomment-671857049 @scott-confluent @mjsax , could you help review this PR? Thanks. This is an automated message from the Apache G

[GitHub] [kafka-site] showuon opened a new pull request #289: MINOR: Fix the wrong past-events link

showuon opened a new pull request #289: URL: https://github.com/apache/kafka-site/pull/289 Fix the wrong past-events link. It should be in the `kafka-summit.org` domain, not under `kafka.apache.org`. This is an automated mes

Re: [ANNOUNCE] New Kafka PMC Member: John Roesler

Congratulations John! Ismael On Mon, Aug 10, 2020 at 1:11 PM Jun Rao wrote: > Hi, Everyone, > > John Roesler has been a Kafka committer since Nov. 5, 2019. He has remained > active in the community since becoming a committer. It's my pleasure to > announce that John is now a member of Kafka PMC

Re: [ANNOUNCE] New Kafka PMC Member: John Roesler

Congrats John! On Tue, Aug 11, 2020 at 9:09 AM Tom Bentley wrote: > > Congratulations John! > > On Tue, Aug 11, 2020 at 7:19 AM Bruno Cadonna wrote: > > > Wow, that is awesome! Congrats, John! > > > > Bruno > > > > On 10.08.20 22:11, Jun Rao wrote: > > > Hi, Everyone, > > > > > > John Roesler ha

Re: [ANNOUNCE] New Kafka PMC Member: John Roesler

Congratulations John! On Tue, Aug 11, 2020 at 7:19 AM Bruno Cadonna wrote: > Wow, that is awesome! Congrats, John! > > Bruno > > On 10.08.20 22:11, Jun Rao wrote: > > Hi, Everyone, > > > > John Roesler has been a Kafka committer since Nov. 5, 2019. He has > remained > > active in the community s

Fwd: [IMPORTANT] - Migration to ci-builds.a.o

Hi all, Looks like we have 4 days to migrate all of our Jenkins builds to the new CI server. I have started the process: https://ci-builds.apache.org/job/Kafka/ To avoid confusion, I have disabled the equivalent builds in the old CI server. I will migrate a few more tomorrow. Ismael --

Re: [DISCUSS] KIP-647: Add ability to handle late messages in streams-aggregation

Hi Igor, Thanks for the KIP! Similar to Matthias, I am also wondering why you rejected the more general solution involving a callback. I also think that writing to a topic is just one of multiple ways to handle late records. For example, one could compute statistics over the late records befo