[jira] [Created] (KAFKA-10157) Multiple tests failed due to "Failed to process feature ZK node change event"

Anna Povzner created KAFKA-10157: Summary: Multiple tests failed due to "Failed to process feature ZK node change event" Key: KAFKA-10157 URL: https://issues.apache.org/jira/browse/KAFKA-10157

[jira] [Created] (KAFKA-10156) Flaky Test SslSelectorTest.testCloseOldestConnection

Sophie Blee-Goldman created KAFKA-10156: --- Summary: Flaky Test SslSelectorTest.testCloseOldestConnection Key: KAFKA-10156 URL: https://issues.apache.org/jira/browse/KAFKA-10156 Project: Kafka

[jira] [Created] (KAFKA-10155) Flaky Test ReassignPartitionsUnitTest.testModifyBrokerThrottles

Sophie Blee-Goldman created KAFKA-10155: --- Summary: Flaky Test ReassignPartitionsUnitTest.testModifyBrokerThrottles Key: KAFKA-10155 URL: https://issues.apache.org/jira/browse/KAFKA-10155

[jira] [Created] (KAFKA-10154) Issue in updating metadata if not exists during sending message to different topics

Dipti Gupta created KAFKA-10154: --- Summary: Issue in updating metadata if not exists during sending message to different topics Key: KAFKA-10154 URL: https://issues.apache.org/jira/browse/KAFKA-10154

[jira] [Resolved] (KAFKA-8686) Flaky test ExampleConnectIntegrationTest#testSinkConnector

[ https://issues.apache.org/jira/browse/KAFKA-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-8686. --- Resolution: Fixed This test class has been running dependably for some time.

[jira] [Resolved] (KAFKA-8661) Flaky Test RebalanceSourceConnectorsIntegrationTest#testStartTwoConnectors

[ https://issues.apache.org/jira/browse/KAFKA-8661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-8661. --- Resolution: Fixed The tests have been fixed and reenabled with 

[jira] [Resolved] (KAFKA-8391) Flaky Test RebalanceSourceConnectorsIntegrationTest#testDeleteConnector

[ https://issues.apache.org/jira/browse/KAFKA-8391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-8391. --- Resolution: Fixed The tests have been fixed and reenabled with 

Re: Can't disable kafka broker on springboot application

Hi Quentin, when i start springboot application this is logged (because kafka server is not running): [image: Selección_459.png] (mvn clean test was runned) Otherwise, i need run unit tests without depending of kafka server is raised Thank u Regardss!!! El El jue, 11 jun. 2020 a la(s) 07:11,

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

Hello Boyang, Thanks for the updated information. A few questions here: 1) Should the quorum-file also update to support multi-raft? 2) In the previous proposal, there's fields in the FetchQuorumRecords like latestDirtyOffset, is that dropped intentionally? 3) I think we also need to elaborate

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

See Changes: [konstantine] KAFKA-9841: Revoke duplicate connectors and tasks when zombie workers [rhauch] KAFKA-9985: Sink connector may exhaust broker when writing in DLQ [rhauch] KAFKA-9845: Warn users about

[jira] [Created] (KAFKA-10153) Documentation for the Errant Record Reporter

Aakash Shah created KAFKA-10153: --- Summary: Documentation for the Errant Record Reporter Key: KAFKA-10153 URL: https://issues.apache.org/jira/browse/KAFKA-10153 Project: Kafka Issue Type: Task

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

See Changes: [github] KAFKA-10027: Implement read path for feature versioning system (KIP-584) -- [...truncated 2.07 MB...] org.apache.kafka.streams.TestTopicsTest >

Re: [DISCUSS] KIP-622 Add currentSystemTimeMs and currentStreamTimeMs to ProcessorContext

Hi Will, Thank you for the KIP. 1. Could you elaborate a bit more on the motivation in the KIP? An example would make the motivation clearer. 2. In section "Proposed Changes" you do not need to show the implementation and describe internals. A description of the expected behavior of the newly

Re: [VOTE] KIP-597: MirrorMaker2 internal topics Formatters

Hi Mickael, Thanks for the updated KIP. 1) I don’t feel too strong about this. I understand your point of view. 2) I just looked at the updated interface and I find a little weird to already have a deprecated method in a new interface, don’t you? If we believe that using Configurable is a good

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

See Changes: [github] KAFKA-10027: Implement read path for feature versioning system (KIP-584) -- [...truncated 2.13 MB...]

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

See Changes: [github] KAFKA-10027: Implement read path for feature versioning system (KIP-584) -- [...truncated 1.79 MB...]

[jira] [Created] (KAFKA-10152) Attempt to write checkpoint without first committing during recycle

Sophie Blee-Goldman created KAFKA-10152: --- Summary: Attempt to write checkpoint without first committing during recycle Key: KAFKA-10152 URL: https://issues.apache.org/jira/browse/KAFKA-10152

[jira] [Created] (KAFKA-10151) Flaky Test StoreUpgradeIntegrationTest.shouldMigratePersistentKeyValueStoreToTimestampedKeyValueStoreUsingPapiStoreUpgradeIntegrationTest.shouldMigratePersistentKeyValue

Sophie Blee-Goldman created KAFKA-10151: --- Summary: Flaky Test

[jira] [Resolved] (KAFKA-10027) Implement read path for feature versioning scheme

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

Build failed in Jenkins: kafka-2.6-jdk8 #41

See Changes: [vvcephei] KAFKA-10085: correctly compute lag for optimized source changelogs -- [...truncated 3.14 MB...]

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

See Changes: [github] KAFKA-10085: correctly compute lag for optimized source changelogs -- [...truncated 3.16 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

[jira] [Created] (KAFKA-10150) IllegalStateException when revoking task in CREATED state

Sophie Blee-Goldman created KAFKA-10150: --- Summary: IllegalStateException when revoking task in CREATED state Key: KAFKA-10150 URL: https://issues.apache.org/jira/browse/KAFKA-10150 Project:

[jira] [Created] (KAFKA-10149) Do not prevent automatic preferred election when reassignment in progress

Jason Gustafson created KAFKA-10149: --- Summary: Do not prevent automatic preferred election when reassignment in progress Key: KAFKA-10149 URL: https://issues.apache.org/jira/browse/KAFKA-10149

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

See Changes: [github] KAFKA-10085: correctly compute lag for optimized source changelogs -- [...truncated 3.14 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

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

See Changes: [github] KAFKA-10085: correctly compute lag for optimized source changelogs -- [...truncated 3.16 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

[jira] [Resolved] (KAFKA-8555) Flaky test ExampleConnectIntegrationTest#testSourceConnector

[ https://issues.apache.org/jira/browse/KAFKA-8555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-8555. --- Resolution: Fixed This test class has been running dependably for some time.

Re: [DISCUSS] KIP-623: Add "internal-topics" option to streams application reset tool

Thanks for the KIP Joel! Some quick questions and suggestions: 1. The KIP links to a wrong JIRA, which should be https://issues.apache.org/jira/browse/KAFKA-6435 2. Typo: *deletes all topic that *-> *deletes all topics that* 3. We need to explain in the Motivation section that we want to

Build failed in Jenkins: kafka-2.6-jdk8 #40

See Changes: [vvcephei] KAFKA-10086: Integration test for ensuring warmups are effective (#8818) -- [...truncated 3.14 MB...]

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

See Changes: [github] KAFKA-10086: Integration test for ensuring warmups are effective (#8818) -- [...truncated 3.16 MB...]

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

See Changes: [github] KAFKA-10086: Integration test for ensuring warmups are effective (#8818) -- [...truncated 3.14 MB...]

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

See Changes: [github] KAFKA-10086: Integration test for ensuring warmups are effective (#8818) -- [...truncated 3.16 MB...]

[jira] [Resolved] (KAFKA-9374) Worker can be disabled by blocked connectors

[ https://issues.apache.org/jira/browse/KAFKA-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-9374. -- Reviewer: Konstantine Karantasis Resolution: Fixed Merged to `trunk` and backported to

[jira] [Resolved] (KAFKA-9969) ConnectorClientConfigRequest is loaded in isolation and throws LinkageError

[ https://issues.apache.org/jira/browse/KAFKA-9969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-9969. -- Reviewer: Konstantine Karantasis Resolution: Fixed [~kkonstantine] merged to `trunk` and

Re: [VOTE] KIP-597: MirrorMaker2 internal topics Formatters

Jun, Yes I'm aware this is allowed but I feel like it's a bit cheating =) Anyway it's a relatively minor KIP so let's do it, +1 binding David, 1) I understand compatibility is important but I feel like supporting both the old and new interface is excessive. The console tool does not mention the

[jira] [Resolved] (KAFKA-10086) Standby state isn't always re-used when transitioning to active

[ https://issues.apache.org/jira/browse/KAFKA-10086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-10086. -- Resolution: Fixed > Standby state isn't always re-used when transitioning to active >

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

See Changes: [github] KAFKA-9216: Enforce that Connect’s internal topics use `compact` cleanup [rhauch] KAFKA-10115: Incorporate errors.tolerance with the Errant Record [github] MINOR: reduce sizeInBytes for

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

See Changes: [rhauch] KAFKA-9845: Warn users about using config providers with plugin.path -- [...truncated 2.93 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

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

See Changes: [github] KAFKA-9991: Fix flaky unit tests (#8843) [github] KAFKA-9969: Exclude ConnectorClientConfigRequest from class loading [github] KAFKA-7833: Add Global/StateStore name conflict check

Build failed in Jenkins: kafka-2.6-jdk8 #39

See Changes: [matthias] MINOR: reduce sizeInBytes for percentiles metrics (#8835) [konstantine] KAFKA-9374: Make connector interactions asynchronous (#8069) --

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

See Changes: [github] MINOR: reduce sizeInBytes for percentiles metrics (#8835) [github] KAFKA-9374: Make connector interactions asynchronous (#8069) -- [...truncated

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

See Changes: [konstantine] KAFKA-9841: Revoke duplicate connectors and tasks when zombie workers -- [...truncated 2.74 MB...] kafka.zk.KafkaZkClientTest >

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

See Changes: [konstantine] KAFKA-9969: Exclude ConnectorClientConfigRequest from class loading -- [...truncated 7.42 MB...] kafka.api.GroupAuthorizerIntegrationTest >

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

See Changes: [github] MINOR: reduce sizeInBytes for percentiles metrics (#8835) [github] KAFKA-9374: Make connector interactions asynchronous (#8069) -- [...truncated

Re: Can't disable kafka broker on springboot application

Hi Ignacio, not sure if I understood your question, but have you tried the spring EmbedKafka feature? Regards On Thu, Jun 11, 2020 at 2:47 AM ignacio gioya wrote: > Hi, > i have an application that use kafka broker, but when i run junit test, > springboot try to run kafka listeners, and i am

Jenkins build is back to normal : kafka-2.5-jdk8 #151

See

[jira] [Created] (KAFKA-10148) Kafka Streams Restores too few Records with eos-beta Enabled

Bruno Cadonna created KAFKA-10148: - Summary: Kafka Streams Restores too few Records with eos-beta Enabled Key: KAFKA-10148 URL: https://issues.apache.org/jira/browse/KAFKA-10148 Project: Kafka

Build failed in Jenkins: kafka-2.6-jdk8 #38

See Changes: [github] KAFKA-10115: Incorporate errors.tolerance with the Errant Record [rhauch] KAFKA-9216: Enforce that Connect’s internal topics use `compact` cleanup --

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

See Changes: [github] KAFKA-9216: Enforce that Connect’s internal topics use `compact` cleanup [rhauch] KAFKA-10115: Incorporate errors.tolerance with the Errant Record

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

See Changes: [github] KAFKA-9216: Enforce that Connect’s internal topics use `compact` cleanup [rhauch] KAFKA-10115: Incorporate errors.tolerance with the Errant Record

[jira] [Created] (KAFKA-10147) MockAdminClient#describeConfigs(Collection) does not handle broker resource

Chia-Ping Tsai created KAFKA-10147: -- Summary: MockAdminClient#describeConfigs(Collection) does not handle broker resource Key: KAFKA-10147 URL: https://issues.apache.org/jira/browse/KAFKA-10147

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

See Changes: [github] KAFKA-7833: Add Global/StateStore name conflict check (#8825) [github] KAFKA-9441: remove prepareClose() to simplify task management (#8833) [github] KAFKA-9985: Sink connector may

[jira] [Resolved] (KAFKA-9314) Connect put() and poll() retries not conforming to KIP-298

[ https://issues.apache.org/jira/browse/KAFKA-9314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nigel Liang resolved KAFKA-9314. Resolution: Duplicate > Connect put() and poll() retries not conforming to KIP-298 >