Build failed in Jenkins: kafka-2.4-jdk8 #143

See Changes: [rhauch] KAFKA-9192: fix NPE when for converting optional json schema in structs [rhauch] allow ReplaceField SMT to handle tombstone records (#7731) [rhauch] MINOR: Small Connect integration test fixe

Build failed in Jenkins: kafka-2.3-jdk8 #176

See Changes: [rhauch] KAFKA-9192: fix NPE when for converting optional json schema in structs [rhauch] allow ReplaceField SMT to handle tombstone records (#7731) [rhauch] MINOR: Small Connect integration test fixe

[jira] [Resolved] (KAFKA-9538) Flaky Test `testResetOffsetsExportImportPlan`

[ https://issues.apache.org/jira/browse/KAFKA-9538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9538. Resolution: Fixed > Flaky Test `testResetOffsetsExportImportPlan` > ---

Build failed in Jenkins: kafka-2.5-jdk8 #21

See Changes: [rhauch] KAFKA-9192: fix NPE when for converting optional json schema in structs [rhauch] allow ReplaceField SMT to handle tombstone records (#7731) [rhauch] MINOR: Small Connect integration test fixes

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

See Changes: [github] MINOR: Small Connect integration test fixes (#8100) -- [...truncated 2.89 MB...] org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldR

Jenkins build is back to normal : kafka-2.3-jdk8 #175

See

Jenkins build is back to normal : kafka-2.2-jdk8 #27

See

Re: [DISCUSS] KIP-568: Explicit rebalance triggering on the Consumer

Ok, I think I see what you're getting at. No, we obviously would only want to trigger one additional rebalance after the current one completes since the next rebalance would of course have the metadata updates we want. But if enforceRebalance returns false a second time, we don't know whether it w

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

See Changes: [github] allow ReplaceField SMT to handle tombstone records (#7731) [github] MINOR: Small Connect integration test fixes (#8100) -- [...truncated 2.87 MB...

Re: [DISCUSS] KIP-568: Explicit rebalance triggering on the Consumer

Hi Sophie, So just to clarify, with the updated API we would keep calling enforceRebalance until it returns true for cases where we rely on it with new subscription metadata? Guozhang On Wed, Feb 12, 2020 at 5:14 PM Sophie Blee-Goldman wrote: > Thanks Boyang -- makes sense to me. I've optimist

Build failed in Jenkins: kafka-2.4-jdk8 #142

See Changes: [jason] KAFKA-9181; Maintain clean separation between local and group [jason] MINOR: Fix unnecessary metadata fetch before group assignment (#8095) -- [...trun

Re: [DISCUSS] KIP-568: Explicit rebalance triggering on the Consumer

Thanks Boyang -- makes sense to me. I've optimistically updated the KIP with this new signature and behavior. On Wed, Feb 12, 2020 at 4:27 PM Boyang Chen wrote: > Hey Sophie, > > I'm satisfied with making enforceRebalance() not throwing any exception > other than illegal state. You could imagin

Build failed in Jenkins: kafka-2.2-jdk8-old #210

See Changes: [rhauch] MINOR: Small Connect integration test fixes (#8100) -- Started by an SCM change Running as SYSTEM [EnvInject] - Loading node environment variables.

Re: [DISCUSS] KIP-494 Connect REST Endpoint for Transformations (SMTs) and other Plugins

Hi Cyrus, Thanks for the KIP! One quick question--I see the use case for being able to list per-connector plugins (SMTs, converters, and header converters) via REST API, but I'm not so sure about worker plugins (REST extensions and config providers). Since those are configured at startup for the

Build failed in Jenkins: kafka-2.5-jdk8 #20

See Changes: [jason] MINOR: Fix unnecessary metadata fetch before group assignment (#8095) [jason] KAFKA-9499; Improve deletion process by batching more aggressively [wangguoz] KAFKA-9447: Add new customized EOS mo

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

See Changes: [github] KAFKA-9417: New Integration Test for KIP-447 (#8000) [github] KAFKA-9192: fix NPE when for converting optional json schema in structs [github] allow ReplaceField SMT to handle tombstone r

Re: [DISCUSS] KIP-568: Explicit rebalance triggering on the Consumer

Hey Sophie, I'm satisfied with making enforceRebalance() not throwing any exception other than illegal state. You could imagine this KIP is just making the `rejoinNeededOrPending` external to user requests. Make it as lightweight as possible makes sense. Boyang On Wed, Feb 12, 2020 at 2:14 PM So

[jira] [Created] (KAFKA-9545) Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted`

Jason Gustafson created KAFKA-9545: -- Summary: Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted` Key: KAFKA-9545 URL: https://issues.apache.org/jira/browse/KAFKA-9545 Project:

Build failed in Jenkins: kafka-2.2-jdk8-old #209

See Changes: [rhauch] allow ReplaceField SMT to handle tombstone records (#7731) -- Started by an SCM change Running as SYSTEM [EnvInject] - Loading node environment var

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

See Changes: [github] KAFKA-6607: Commit correct offsets for transactional input data (#8091) [github] KAFKA-9417: New Integration Test for KIP-447 (#8000) [github] KAFKA-9192: fix NPE when for converting optio

[jira] [Resolved] (KAFKA-9204) ReplaceField transformation fails when encountering tombstone event

[ https://issues.apache.org/jira/browse/KAFKA-9204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-9204. -- Fix Version/s: 2.4.1 2.3.2 2.5.0 2.2.3

Build failed in Jenkins: kafka-2.2-jdk8-old #208

See Changes: [rhauch] KAFKA-9192: fix NPE when for converting optional json schema in structs -- Started by an SCM change Running as SYSTEM [EnvInject] - Loading node en

[jira] [Created] (KAFKA-9544) Flaky Test `KafkaAdminClientTest.testDefaultApiTimeoutOverride`

Jason Gustafson created KAFKA-9544: -- Summary: Flaky Test `KafkaAdminClientTest.testDefaultApiTimeoutOverride` Key: KAFKA-9544 URL: https://issues.apache.org/jira/browse/KAFKA-9544 Project: Kafka

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

See Changes: [github] MINOR: Fix unnecessary metadata fetch before group assignment (#8095) [github] KAFKA-9499; Improve deletion process by batching more aggressively [github] KAFKA-6607: Commit correct offse

[jira] [Resolved] (KAFKA-9192) NullPointerException if field in schema not present in value

[ https://issues.apache.org/jira/browse/KAFKA-9192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-9192. -- Fix Version/s: 2.4.1 2.3.2 2.5.0 2.2.3

Re: [DISCUSS] KIP-568: Explicit rebalance triggering on the Consumer

Hey Guozhang, thanks for the thorough reply! I definitely went back and forth on whether to make it a blocking call, and ultimately went with blocking just to leave it open to potential future use cases (in particular non-Streams apps). But on second (or third) thought I think I agree that no use

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

See Changes: [github] MINOR: Fix unnecessary metadata fetch before group assignment (#8095) [github] KAFKA-9499; Improve deletion process by batching more aggressively -

[jira] [Resolved] (KAFKA-9417) Integration test for new EOS model with vanilla Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-9417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9417. -- Resolution: Fixed > Integration test for new EOS model with vanilla Producer and Consumer > ---

Build failed in Jenkins: kafka-2.5-jdk8 #19

See Changes: [mickael.maison] KAFKA-9423: Refine layout of configuration options on website and make -- [...truncated 2.89 MB...] org.apache.kafka.streams.TopologyTestDrive

[jira] [Resolved] (KAFKA-6607) Kafka Streams lag not zero when input topic transactional

[ https://issues.apache.org/jira/browse/KAFKA-6607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6607. Fix Version/s: 2.5.0 Resolution: Fixed > Kafka Streams lag not zero when input topic

[jira] [Resolved] (KAFKA-9499) Improve deletion process by batching more aggressively

[ https://issues.apache.org/jira/browse/KAFKA-9499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9499. Fix Version/s: 2.5.0 Resolution: Fixed > Improve deletion process by batching more a

Build failed in Jenkins: kafka-2.5-jdk8 #18

See Changes: -- [...truncated 2.89 MB...] org.apache.kafka.streams.TestTopicsTest > testNegativeAdvance STARTED org.apache.kafka.streams.TestTopicsTest > testNegativeAdvance PASSED org.a

Build failed in Jenkins: kafka-2.4-jdk8 #141

See Changes: [vvcephei] KAKFA-9503: Fix TopologyTestDriver output order (#8065) [vvcephei] KAFKA-9500: Fix FK Join Topology (#8015) -- [...truncated 5.56 MB...] org.apache

[jira] [Created] (KAFKA-9543) Consumer offset reset after new segment rolling

Rafał Boniecki created KAFKA-9543: - Summary: Consumer offset reset after new segment rolling Key: KAFKA-9543 URL: https://issues.apache.org/jira/browse/KAFKA-9543 Project: Kafka Issue Type: B

[jira] [Created] (KAFKA-9542) ZSTD Compression Not Working

Prashant created KAFKA-9542: --- Summary: ZSTD Compression Not Working Key: KAFKA-9542 URL: https://issues.apache.org/jira/browse/KAFKA-9542 Project: Kafka Issue Type: Bug Components: compre

Re: [DISCUSS] KIP-405: Kafka Tiered Storage

Hi Jun, Thanks for your comments on the separation of remote log metadata storage and remote log storage. We had a few discussions since early Jan on how to support eventually consistent stores like S3 by uncoupling remote log segment metadata and remote log storage. It is written with details in t

Build failed in Jenkins: kafka-2.4-jdk8 #140

See Changes: [github] KAFKA-9540: Move "Could not find the standby task while closing it" log [rhauch] MINOR: Start using Response and replace IOException in [vvcephei] KAFKA-9390: Make serde pseudo-topics unique

Build failed in Jenkins: kafka-2.3-jdk8 #174

See Changes: [rhauch] MINOR: Start using Response and replace IOException in -- [...truncated 2.96 MB...] kafka.log.LogCleanerTest > testPartialSegmentClean STARTED kafka.

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

See Changes: [github] KAFKA-9500: Fix FK Join Topology (#8015) -- [...truncated 2.89 MB...] org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldRequireCusto

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

See Changes: [github] KAFKA-9500: Fix FK Join Topology (#8015) -- [...truncated 2.87 MB...] org.apache.kafka.streams.TopologyTestDriverTest > shouldCreateStateDirectory

Re: [DISCUSS] KIP-552: Add interface to handle unused config

Hi John Regarding Kafka Streams this can probably be fixed easily, but it does not handle the underlying issue that other custom prefixes are not supported. Seems I even did a short analysis several months ago and forgot about it, see https://issues.apache.org/jira/browse/KAFKA-6793?focusedComment

Build failed in Jenkins: kafka-2.5-jdk8 #17

See Changes: [vvcephei] KAKFA-9503: Fix TopologyTestDriver output order (#8065) [vvcephei] KAFKA-9500: Fix FK Join Topology (#8015) -- [...truncated 2.89 MB...] org.apache.