Jenkins build is back to normal : Kafka » kafka-2.7-jdk8 #130

See

Jenkins build is back to normal : Kafka » kafka-trunk-jdk11 #563

See

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

See Changes: [Manikumar Reddy] y -- [...truncated 7.31 MB...] LogValidatorTest > testUncompressedBatchWithoutRecordsNotAllowed() STARTED LogValidatorTest >

[jira] [Resolved] (KAFKA-12400) Upgrade jetty to fix CVE-2020-27223

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

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

See Changes: [github] KAFKA-12375: don't reuse thread.id until a thread has fully shut down (#10215) -- [...truncated 7.31 MB...] LogValidatorTest >

[jira] [Resolved] (KAFKA-12389) Upgrade of netty-codec due to CVE-2021-21290

[ https://issues.apache.org/jira/browse/KAFKA-12389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-12389. --- Fix Version/s: 2.8.0 2.6.2 2.7.1 Resolution: Fixed

Re: Kafka logos

The 2nd one is with a subtitle: *Distributed publish-subscribe messaging system*, which I believe is the old one. The home page log with: *A Distributed Streaming Platform *should be the newer one. Please correct me if I'm wrong. Thanks. Luke On Wed, Mar 3, 2021 at 6:42 AM Justin Mclean wrote:

Build failed in Jenkins: Kafka » kafka-2.8-jdk8 #49

See Changes: [A. Sophie Blee-Goldman] KAFKA-12375: don't reuse thread.id until a thread has fully shut down (#10215) -- [...truncated 3.63 MB...]

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

See Changes: [github] KAFKA-12375: don't reuse thread.id until a thread has fully shut down (#10215) -- [...truncated 3.65 MB...]

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

See Changes: [github] KAFKA-12375: don't reuse thread.id until a thread has fully shut down (#10215) -- [...truncated 3.68 MB...] AclAuthorizerTest >

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

See

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

See Changes: [github] KAFKA-12369; Implement `ListTransactions` API (#10206) [github] KAFKA-12177: apply log start offset retention before time and size based retention (#10216)

Build failed in Jenkins: Kafka » kafka-2.8-jdk8 #48

See Changes: [Rajini Sivaram] KAFKA-12254: Ensure MM2 creates topics with source topic configs (#10217) -- [...truncated 3.62 MB...] LogManagerTest >

[jira] [Reopened] (KAFKA-10251) Flaky Test kafka.api.TransactionsBounceTest.testWithGroupMetadata

[ https://issues.apache.org/jira/browse/KAFKA-10251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reopened KAFKA-10251: Looks like it's still failing – saw at least one test failure on a build

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

See Changes: [github] KAFKA-10251: increase timeout for consuming records (#10228) [github] KAFKA-10357: Extract setup of changelog from Streams partition assignor (#10163) [github] KAFKA-12369;

Build failed in Jenkins: Kafka » kafka-2.8-jdk8 #47

See Changes: [Jason Gustafson] KAFKA-12394; Return `TOPIC_AUTHORIZATION_FAILED` in delete topic response if no describe permission (#10223) -- [...truncated

Kafka logos

HI, I notice that the Apache Kafka Logo on the Kafka home page [1] is different to what is listed here [2]. I'm creating some training material and was wondering what is the correct logo to use? Thanks, Justin 1. https://kafka.apache.org 2. http://apache.org/logos/?#kafka

Re: [DISCUSS] Apache Kafka 2.8.0 release

Thanks, John. The fix for KAFKA-12254 is now merged into 2.8. On Tue, Mar 2, 2021 at 11:54 AM John Roesler wrote: > Hi Dhruvil, > > Thanks for this fix. I agree it would be good to get it in > for 2.8.0, so I have added it to the fix versions in KAFKA- > 12254. > > Please go ahead and

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

See Changes: [github] KAFKA-10251: increase timeout for consuming records (#10228) [github] KAFKA-10357: Extract setup of changelog from Streams partition assignor (#10163)

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

See Changes: [github] KAFKA-10251: increase timeout for consuming records (#10228) [github] KAFKA-10357: Extract setup of changelog from Streams partition assignor (#10163)

Jenkins build is back to normal : Kafka » kafka-trunk-jdk15 #586

See

Build failed in Jenkins: Kafka » kafka-2.8-jdk8 #46

See Changes: [Guozhang Wang] KAFKA-12289: Adding test cases for prefix scan in InMemoryKeyValueStore (#10052) [Guozhang Wang] KAFKA-10766: Unit test cases for RocksDBRangeIterator (#9717)

[jira] [Resolved] (KAFKA-12177) Retention is not idempotent

[ https://issues.apache.org/jira/browse/KAFKA-12177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-12177. - Fix Version/s: 3.0.0 Assignee: Lucas Bradstreet Resolution: Fixed merged the PR to

[jira] [Resolved] (KAFKA-12369) Implement ListTransactions API

[ https://issues.apache.org/jira/browse/KAFKA-12369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-12369. - Fix Version/s: 3.0.0 Resolution: Fixed > Implement ListTransactions API >

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

See Changes: [github] KAFKA-12289: Adding test cases for prefix scan in InMemoryKeyValueStore (#10052) [github] KAFKA-10766: Unit test cases for RocksDBRangeIterator (#9717) [github] MINOR:

Re: [VOTE] KIP-715: Expose Committed offset in streams

Thank you everyone for voting. This KIP has passed with: +4 binding votes (Boyang, Sophie, Guozhang and Matthias) +2 non-binding (Leah and myself) best, Walker On Tue, Mar 2, 2021 at 11:18 AM Matthias J. Sax wrote: > +1 (binding) > > On 3/1/21 4:23 PM, Guozhang Wang wrote: > > Thanks Walker

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

See Changes: [github] KAFKA-12289: Adding test cases for prefix scan in InMemoryKeyValueStore (#10052) [github] KAFKA-10766: Unit test cases for RocksDBRangeIterator (#9717) [github] MINOR:

[jira] [Created] (KAFKA-12403) Broker handling of delete topic events

Jason Gustafson created KAFKA-12403: --- Summary: Broker handling of delete topic events Key: KAFKA-12403 URL: https://issues.apache.org/jira/browse/KAFKA-12403 Project: Kafka Issue Type:

Re: [DISCUSS] Apache Kafka 2.8.0 release

Hi Dhruvil, Thanks for this fix. I agree it would be good to get it in for 2.8.0, so I have added it to the fix versions in KAFKA- 12254. Please go ahead and cherry-pick your fix onto the 2.8 branch. Thanks! -John On Mon, 2021-03-01 at 09:36 -0800, Dhruvil Shah wrote: > Hi John, > > I would

Re: [VOTE] KIP-715: Expose Committed offset in streams

+1 (binding) On 3/1/21 4:23 PM, Guozhang Wang wrote: > Thanks Walker for the updated KIP, +1 (binding) > > > Guozhang > > On Mon, Mar 1, 2021 at 3:47 PM Sophie Blee-Goldman > wrote: > >> Thanks for the KIP! +1 (binding) >> >> Sophie >> >> On Mon, Mar 1, 2021 at 10:04 AM Leah Thomas wrote:

Re: [DISCUSS] KIP-715: Expose Committed offset in streams

I think calling it endOffset is still fine. We should keep it "simple" for users and not introduce too many concepts. -Matthias On 3/2/21 8:14 AM, Walker Carlson wrote: > Okay we can document that if the state is rebalancing that a Task could be > between instances and so no show up for one

[jira] [Created] (KAFKA-12402) client_sasl_mechanism should be an explicit list instead of a .csv string

Ron Dagostino created KAFKA-12402: - Summary: client_sasl_mechanism should be an explicit list instead of a .csv string Key: KAFKA-12402 URL: https://issues.apache.org/jira/browse/KAFKA-12402 Project:

[jira] [Resolved] (KAFKA-12394) Consider topic id existence and authorization errors

[ https://issues.apache.org/jira/browse/KAFKA-12394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-12394. - Fix Version/s: 2.8.0 Resolution: Fixed > Consider topic id existence and

[jira] [Created] (KAFKA-12401) Flaky Test FeatureCommandTest#testUpgradeAllFeaturesSuccess

Matthias J. Sax created KAFKA-12401: --- Summary: Flaky Test FeatureCommandTest#testUpgradeAllFeaturesSuccess Key: KAFKA-12401 URL: https://issues.apache.org/jira/browse/KAFKA-12401 Project: Kafka

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

See

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

See Changes: [github] KAFKA-12268: Implement task idling semantics via currentLag API (#10137) -- [...truncated 3.67 MB...] SocketServerTest >

Re: [DISCUSS] KIP-715: Expose Committed offset in streams

Okay we can document that if the state is rebalancing that a Task could be between instances and so no show up for one localThreadMetadata call. but this should not cause a problem for repeated calls Bruno, to your questions. The endOffset is like the consumer's highWatermark and does not require

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

See Changes: [github] KAFKA-12268: Implement task idling semantics via currentLag API (#10137) -- [...truncated 3.65 MB...] ControllerChannelManagerTest >

[GitHub] [kafka-site] miguno commented on pull request #334: KAFKA-12393: Document multi-tenancy considerations

miguno commented on pull request #334: URL: https://github.com/apache/kafka-site/pull/334#issuecomment-789009875 PR updated with reviewer feedback. This is an automated message from the Apache Git Service. To respond to the

[GitHub] [kafka-site] miguno commented on a change in pull request #334: KAFKA-12393: Document multi-tenancy considerations

miguno commented on a change in pull request #334: URL: https://github.com/apache/kafka-site/pull/334#discussion_r585572446 ## File path: 27/ops.html ## @@ -1090,7 +1090,157 @@ - 6.4 Kafka Configuration + 6.4 Multi-Tenancy + + Multi-Tenancy Overview + + +As a

[GitHub] [kafka-site] miguno commented on a change in pull request #334: KAFKA-12393: Document multi-tenancy considerations

miguno commented on a change in pull request #334: URL: https://github.com/apache/kafka-site/pull/334#discussion_r585640800 ## File path: 27/ops.html ## @@ -1090,7 +1090,157 @@ - 6.4 Kafka Configuration + 6.4 Multi-Tenancy + + Multi-Tenancy Overview + + +As a

[GitHub] [kafka-site] miguno commented on a change in pull request #334: KAFKA-12393: Document multi-tenancy considerations

miguno commented on a change in pull request #334: URL: https://github.com/apache/kafka-site/pull/334#discussion_r585575690 ## File path: 27/ops.html ## @@ -1090,7 +1090,157 @@ - 6.4 Kafka Configuration + 6.4 Multi-Tenancy + + Multi-Tenancy Overview + + +As a

[GitHub] [kafka-site] miguno commented on a change in pull request #334: KAFKA-12393: Document multi-tenancy considerations

miguno commented on a change in pull request #334: URL: https://github.com/apache/kafka-site/pull/334#discussion_r585572446 ## File path: 27/ops.html ## @@ -1090,7 +1090,157 @@ - 6.4 Kafka Configuration + 6.4 Multi-Tenancy + + Multi-Tenancy Overview + + +As a

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

See Changes: [github] MINOR: Format the revoking active log output in `StreamsPartitionAssignor` (#10242) [github] MINOR: correct the error message of validating uint32 (#10193) [github] MINOR:

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

See Changes: [github] MINOR: Time and log producer state recovery phases (#10241) -- [...truncated 3.65 MB...] ProducerFailureHandlingTest >

Re: [DISCUSS] KIP-715: Expose Committed offset in streams

Hi Walker, Thank you for the KIP! I somehow agree that we should document that some tasks may be missing. I have one question/comment. As far as I understand, your KIP adds two methods that return data that is actually hosted on the brokers, namely committedOffsets() and endOffsets(). Thus,

[GitHub] [kafka-site] rajinisivaram commented on a change in pull request #334: KAFKA-12393: Document multi-tenancy considerations

rajinisivaram commented on a change in pull request #334: URL: https://github.com/apache/kafka-site/pull/334#discussion_r585530580 ## File path: 27/ops.html ## @@ -1090,7 +1090,157 @@ - 6.4 Kafka Configuration + 6.4 Multi-Tenancy + + Multi-Tenancy Overview + + +

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

See Changes: [github] MINOR: Format the revoking active log output in `StreamsPartitionAssignor` (#10242) [github] MINOR: correct the error message of validating uint32 (#10193) [github] MINOR:

[GitHub] [kafka-site] dajac commented on a change in pull request #334: KAFKA-12393: Document multi-tenancy considerations

dajac commented on a change in pull request #334: URL: https://github.com/apache/kafka-site/pull/334#discussion_r585427746 ## File path: 27/ops.html ## @@ -1090,7 +1090,157 @@ - 6.4 Kafka Configuration + 6.4 Multi-Tenancy + + Multi-Tenancy Overview + + +As a

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

See Changes: [github] MINOR: Format the revoking active log output in `StreamsPartitionAssignor` (#10242) [github] MINOR: correct the error message of validating uint32 (#10193)

Re: [VOTE] KIP-699: Update FindCoordinator to resolve multiple Coordinators at a time

Thanks for the KIP, Mickael. +1 (binding) On Mon, Mar 1, 2021 at 11:53 AM Tom Bentley wrote: > +1 (non-binding), thanks Mickael. > > On Thu, Feb 25, 2021 at 6:32 PM Mickael Maison > wrote: > > > Hi, > > > > I'd like to start a vote on KIP-699 to support resolving multiple > > coordinators at a

[DISCUSS] KIP-718: Make KTable Join on Foreign key unopinionated

Hi folks, I would like to invite everyone to discuss further KIP-718: https://cwiki.apache.org/confluence/display/KAFKA/KIP-718%3A+Make+KTable+Join+on+Foreign+key+unopinionated I welcome all feedback on it. Kind Regards, Marco Lotz

[jira] [Created] (KAFKA-12400) Upgrade jetty to fix CVE-2020-27223

Dongjin Lee created KAFKA-12400: --- Summary: Upgrade jetty to fix CVE-2020-27223 Key: KAFKA-12400 URL: https://issues.apache.org/jira/browse/KAFKA-12400 Project: Kafka Issue Type: Improvement

[DISCUSS] KIP-719: Add Log4J2 Appender

Hi Kafka dev, I would like to start the discussion of KIP-719: Add Log4J2 Appender. https://cwiki.apache.org/confluence/display/KAFKA/KIP-719%3A+Add+Log4J2+Appender All kinds of feedbacks are greatly appreciated! Best, Dongjin -- *Dongjin Lee* *A hitchhiker in the mathematical world.*