[jira] [Created] (KAFKA-12429) Serdes for all message types in internal topic which is used in default implementation for RLMM.

Satish Duggana created KAFKA-12429: -- Summary: Serdes for all message types in internal topic which is used in default implementation for RLMM. Key: KAFKA-12429 URL:

[jira] [Resolved] (KAFKA-12412) Group Coordinator followers are failing with OffsetsOutOfOrderException

[ https://issues.apache.org/jira/browse/KAFKA-12412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sandeep resolved KAFKA-12412. - Resolution: Fixed > Group Coordinator followers are failing with OffsetsOutOfOrderException >

[jira] [Reopened] (KAFKA-12416) Group Coordinator followers are failing with OffsetsOutOfOrderException

[ https://issues.apache.org/jira/browse/KAFKA-12416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sandeep reopened KAFKA-12416: - > Group Coordinator followers are failing with OffsetsOutOfOrderException >

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

See

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

See Changes: [github] MINOR: Raft max batch size needs to propagate to log config (#10256) [github] MINOR: add missing docs for record-e2e-latency metrics (#10251)

Build failed in Jenkins: Kafka » kafka-2.6-jdk8 #103

See Changes: [A. Sophie Blee-Goldman] Remove ReassigningPartitions metric when shutting down ReplicaManager (#10260) -- [...truncated 6.35 MB...]

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

See

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

See Changes: [github] MINOR: Raft max batch size needs to propagate to log config (#10256) [github] MINOR: add missing docs for record-e2e-latency metrics (#10251)

[jira] [Created] (KAFKA-12428) Add a last-heartbeat-seconds-ago metric to Kafka Consumer

Guozhang Wang created KAFKA-12428: - Summary: Add a last-heartbeat-seconds-ago metric to Kafka Consumer Key: KAFKA-12428 URL: https://issues.apache.org/jira/browse/KAFKA-12428 Project: Kafka

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

See Changes: [David Arthur] KAFKA-12376: Apply atomic append to the log (#10253) [David Arthur] HOTFIX: Controller topic deletion should be atomic (#10264) [A. Sophie Blee-Goldman] MINOR: add missing

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

See Changes: [github] Remove ReassigningPartitions metric when shutting down ReplicaManager (#10260) -- [...truncated 3.67 MB...]

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

See

[jira] [Created] (KAFKA-12427) Broker does not close muted idle connections with buffered data

David Mao created KAFKA-12427: - Summary: Broker does not close muted idle connections with buffered data Key: KAFKA-12427 URL: https://issues.apache.org/jira/browse/KAFKA-12427 Project: Kafka

[jira] [Created] (KAFKA-12426) Missing logic to create partition.metadata files in RaftReplicaManager

Jason Gustafson created KAFKA-12426: --- Summary: Missing logic to create partition.metadata files in RaftReplicaManager Key: KAFKA-12426 URL: https://issues.apache.org/jira/browse/KAFKA-12426

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

See Changes: [Jason Gustafson] MINOR: Enable topic deletion in the KIP-500 controller (#10184) -- [...truncated 7.23 MB...] SocketServerTest >

[jira] [Created] (KAFKA-12425) Connector status report could include a timestamp

James C. McPherson created KAFKA-12425: -- Summary: Connector status report could include a timestamp Key: KAFKA-12425 URL: https://issues.apache.org/jira/browse/KAFKA-12425 Project: Kafka

[jira] [Resolved] (KAFKA-12409) Leaking gauge in ReplicaManager

[ https://issues.apache.org/jira/browse/KAFKA-12409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-12409. Resolution: Fixed > Leaking gauge in ReplicaManager >

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

See Changes: [github] KAFKA-12376: Apply atomic append to the log (#10253) [github] KAFKA-12415 Prepare for Gradle 7.0 and restrict transitive scope for non api dependencies (#10203) [github]

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

See Changes: [github] MINOR: Enable topic deletion in the KIP-500 controller (#10184) [github] HOTFIX: Controller topic deletion should be atomic (#10264)

[jira] [Created] (KAFKA-12424) Separate build logging in jenkins

Jason Gustafson created KAFKA-12424: --- Summary: Separate build logging in jenkins Key: KAFKA-12424 URL: https://issues.apache.org/jira/browse/KAFKA-12424 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-12423) Consider which log configs should be overridable for the metadata topic

Jason Gustafson created KAFKA-12423: --- Summary: Consider which log configs should be overridable for the metadata topic Key: KAFKA-12423 URL: https://issues.apache.org/jira/browse/KAFKA-12423

[jira] [Created] (KAFKA-12422) Add getter for KafkaConsumer configs

Max Rothman created KAFKA-12422: --- Summary: Add getter for KafkaConsumer configs Key: KAFKA-12422 URL: https://issues.apache.org/jira/browse/KAFKA-12422 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-12421) Improve controller's atomic grouping

Jose Armando Garcia Sancio created KAFKA-12421: -- Summary: Improve controller's atomic grouping Key: KAFKA-12421 URL: https://issues.apache.org/jira/browse/KAFKA-12421 Project: Kafka

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

See Changes: [github] KAFKA-12376: Apply atomic append to the log (#10253) [github] KAFKA-12415 Prepare for Gradle 7.0 and restrict transitive scope for non api dependencies (#10203)

[jira] [Created] (KAFKA-12420) Kafka network Selector class has many constructors; use a Builder pattern instead

Steve Rodrigues created KAFKA-12420: --- Summary: Kafka network Selector class has many constructors; use a Builder pattern instead Key: KAFKA-12420 URL: https://issues.apache.org/jira/browse/KAFKA-12420

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

See Changes: [github] KAFKA-12376: Apply atomic append to the log (#10253) [github] KAFKA-12415 Prepare for Gradle 7.0 and restrict transitive scope for non api dependencies (#10203) [github]

[jira] [Resolved] (KAFKA-12414) Group Coordinator followers are failing with OffsetsOutOfOrderException

[ https://issues.apache.org/jira/browse/KAFKA-12414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sandeep resolved KAFKA-12414. - Resolution: Duplicate > Group Coordinator followers are failing with OffsetsOutOfOrderException >

[jira] [Resolved] (KAFKA-12413) Group Coordinator followers are failing with OffsetsOutOfOrderException

[ https://issues.apache.org/jira/browse/KAFKA-12413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sandeep resolved KAFKA-12413. - Resolution: Duplicate > Group Coordinator followers are failing with OffsetsOutOfOrderException >

[jira] [Resolved] (KAFKA-12416) Group Coordinator followers are failing with OffsetsOutOfOrderException

[ https://issues.apache.org/jira/browse/KAFKA-12416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sandeep resolved KAFKA-12416. - Resolution: Duplicate > Group Coordinator followers are failing with OffsetsOutOfOrderException >

[jira] [Resolved] (KAFKA-12411) Group Coordinator Followers failing with OutOfOrderOffsetException

[ https://issues.apache.org/jira/browse/KAFKA-12411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sandeep resolved KAFKA-12411. - Resolution: Duplicate > Group Coordinator Followers failing with OutOfOrderOffsetException >

[jira] [Resolved] (KAFKA-12415) Prepare for Gradle 7.0 and restrict transitive scope for non api dependencies

[ https://issues.apache.org/jira/browse/KAFKA-12415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-12415. - Resolution: Fixed > Prepare for Gradle 7.0 and restrict transitive scope for non api

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

See

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

Thanks Marco, Just a quick thought: what if we reuse the existing Materialized object for both subscription and join stores, instead of introducing a new param / class? Guozhang On Tue, Mar 2, 2021 at 1:07 AM Marco Aurélio Lotz wrote: > Hi folks, > > I would like to invite everyone to discuss

Re: [DISCUSS] KIP-634: Complementary support for headers in Kafka Streams DSL

Hi everyone! I'd like to revamp this KIP. I have made some significant changes on the scope: - Added `mapRecordValue` to map not only headers, but other record metadata: topic name, partition, offset, and timestamp into a new type `RecordValue`. - Added a serde for `RecordValue` to support

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

See Changes: [github] KAFKA-12393: Document multi-tenancy considerations (#334) (#10263) [github] MINOR: make sure all generated data tests cover all versions (#10078)

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

See Changes: [Bill Bejeck] KAFKA-12393: Document multi-tenancy considerations (#334) (#10263) -- [...truncated 3.62 MB...] SocketServerTest > testConnectionId()

[jira] [Created] (KAFKA-12419) Remove Deprecated APIs of Kafka Streams in 3.0

Guozhang Wang created KAFKA-12419: - Summary: Remove Deprecated APIs of Kafka Streams in 3.0 Key: KAFKA-12419 URL: https://issues.apache.org/jira/browse/KAFKA-12419 Project: Kafka Issue Type:

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

See Changes: [github] KAFKA-12407: Document Controller Health Metrics (#10257) -- [...truncated 3.66 MB...] PlaintextConsumerTest >

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

See Changes: [github] KAFKA-12407: Document Controller Health Metrics (#10257) -- [...truncated 3.67 MB...] UserQuotaTest >

[jira] [Resolved] (KAFKA-12393) Document multi-tenancy considerations

[ https://issues.apache.org/jira/browse/KAFKA-12393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-12393. - Resolution: Fixed Merged to trunk and cherry-picked to 2.8 > Document multi-tenancy

[GitHub] [kafka-site] bbejeck merged pull request #334: KAFKA-12393: Document multi-tenancy considerations

bbejeck merged pull request #334: URL: https://github.com/apache/kafka-site/pull/334 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

[jira] [Resolved] (KAFKA-12407) Document omitted Controller Health Metrics

[ https://issues.apache.org/jira/browse/KAFKA-12407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-12407. -- Resolution: Fixed > Document omitted Controller Health Metrics >

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

See Changes: [github] MINOR: remove FetchResponse.AbortedTransaction and redundant construc… (#9758) -- [...truncated 3.67 MB...] SocketServerTest >

[jira] [Created] (KAFKA-12418) Make sure it's ok not to include test jars in the release tarball

Ismael Juma created KAFKA-12418: --- Summary: Make sure it's ok not to include test jars in the release tarball Key: KAFKA-12418 URL: https://issues.apache.org/jira/browse/KAFKA-12418 Project: Kafka

[jira] [Created] (KAFKA-12417) streams module should use `testRuntimeClasspath` instead of `testRuntime` configuration

Ismael Juma created KAFKA-12417: --- Summary: streams module should use `testRuntimeClasspath` instead of `testRuntime` configuration Key: KAFKA-12417 URL: https://issues.apache.org/jira/browse/KAFKA-12417

[jira] [Created] (KAFKA-12414) Group Coordinator followers are failing with OffsetsOutOfOrderException

Sandeep created KAFKA-12414: --- Summary: Group Coordinator followers are failing with OffsetsOutOfOrderException Key: KAFKA-12414 URL: https://issues.apache.org/jira/browse/KAFKA-12414 Project: Kafka

[jira] [Created] (KAFKA-12416) Group Coordinator followers are failing with OffsetsOutOfOrderException

Sandeep created KAFKA-12416: --- Summary: Group Coordinator followers are failing with OffsetsOutOfOrderException Key: KAFKA-12416 URL: https://issues.apache.org/jira/browse/KAFKA-12416 Project: Kafka

[jira] [Created] (KAFKA-12415) Prepare for Gradle 7.0 and restrict transitive scope for non api dependencies

Ismael Juma created KAFKA-12415: --- Summary: Prepare for Gradle 7.0 and restrict transitive scope for non api dependencies Key: KAFKA-12415 URL: https://issues.apache.org/jira/browse/KAFKA-12415 Project:

[jira] [Created] (KAFKA-12412) Group Coordinator followers are failing with OffsetsOutOfOrderException

Sandeep created KAFKA-12412: --- Summary: Group Coordinator followers are failing with OffsetsOutOfOrderException Key: KAFKA-12412 URL: https://issues.apache.org/jira/browse/KAFKA-12412 Project: Kafka

[jira] [Created] (KAFKA-12413) Group Coordinator followers are failing with OffsetsOutOfOrderException

Sandeep created KAFKA-12413: --- Summary: Group Coordinator followers are failing with OffsetsOutOfOrderException Key: KAFKA-12413 URL: https://issues.apache.org/jira/browse/KAFKA-12413 Project: Kafka

[jira] [Created] (KAFKA-12411) Group Coordinator Followers failing with OutOfOrderOffsetException

Sandeep created KAFKA-12411: --- Summary: Group Coordinator Followers failing with OutOfOrderOffsetException Key: KAFKA-12411 URL: https://issues.apache.org/jira/browse/KAFKA-12411 Project: Kafka

[jira] [Created] (KAFKA-12410) Remove FetchResponse#of

Chia-Ping Tsai created KAFKA-12410: -- Summary: Remove FetchResponse#of Key: KAFKA-12410 URL: https://issues.apache.org/jira/browse/KAFKA-12410 Project: Kafka Issue Type: Improvement

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

See Changes: [github] MINOR; Clean up LeaderAndIsrResponse construction in `ReplicaManager#becomeLeaderOrFollower` (#10234) -- [...truncated 7.34 MB...]

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

See Changes: [github] MINOR; Clean up LeaderAndIsrResponse construction in `ReplicaManager#becomeLeaderOrFollower` (#10234) [github] MINOR: remove FetchResponse.AbortedTransaction and redundant

Re: [DISCUSS] KIP-708: Rack aware Kafka Streams with pluggable StandbyTask assignor

Hi Bruno, Thanks a lot for the feedback. I’ve updated KIP [1] based on suggestions. Regards, Levani [1] - https://cwiki.apache.org/confluence/display/KAFKA/KIP-708%3A+Rack+awarness+for+Kafka+Streams > On 1. Mar 2021, at 22:55, Bruno Cadonna wrote: > > clientTagPrefix

[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-790412618 Thanks all for reviewing, much appreciated! This is an automated message from the Apache Git Service. To