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

2021-01-14 Thread Apache Jenkins Server 
See

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

2021-01-14 Thread Apache Jenkins Server 
See 


Changes:

[github] KAFKA-12201: Migrate connect:basic-auth-extensio module to JUnit 5 
(#9892)

[github] MINOR: Initialize QuorumState lazily in RaftClient.initialize() (#9881)


--
[...truncated 3.65 MB...]
MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@29abc31, 
timestamped = false, caching = false, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@768ec679,
 timestamped = true, caching = true, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@768ec679,
 timestamped = true, caching = true, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@4bfc27df,
 timestamped = true, caching = true, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@4bfc27df,
 timestamped = true, caching = true, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@4bdf61c9,
 timestamped = true, caching = true, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@4bdf61c9,
 timestamped = true, caching = true, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@3393e4a3,
 timestamped = true, caching = true, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@3393e4a3,
 timestamped = true, caching = true, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@6b52b06f,
 timestamped = true, caching = true, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@6b52b06f,
 timestamped = true, caching = true, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@23d05ff4,
 timestamped = true, caching = true, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@23d05ff4,
 timestamped = true, caching = true, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@4f48f2e5,
 timestamped = true, caching = false, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@4f48f2e5,
 timestamped = true, caching = false, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@6a2f400e,
 timestamped = true, caching = false, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@6a2f400e,
 timestamped = true, caching = false, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@74257e5d,
 timestamped = true, caching = false, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@74257e5d,
 timestamped = true, caching = false, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@30734e02,
 timestamped = true, caching = false, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@30734e02,
 timestamped = true, caching = false, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@1544eb55,
 timestamped = true, caching = false, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@1544eb55,
 timestamped = true, caching = false, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@23b95071,
 timestamped = true, caching = false, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.intern

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

2021-01-14 Thread Apache Jenkins Server 
See 


Changes:

[github] KAFKA-12201: Migrate connect:basic-auth-extensio module to JUnit 5 
(#9892)

[github] MINOR: Initialize QuorumState lazily in RaftClient.initialize() (#9881)


--
[...truncated 3.65 MB...]
MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@1106b3fd, 
timestamped = false, caching = true, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@1106b3fd, 
timestamped = false, caching = true, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@1ba6d161, 
timestamped = false, caching = true, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@1ba6d161, 
timestamped = false, caching = true, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@25b4f168, 
timestamped = false, caching = false, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@25b4f168, 
timestamped = false, caching = false, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@16fb09d5, 
timestamped = false, caching = false, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@16fb09d5, 
timestamped = false, caching = false, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@54f92f39, 
timestamped = false, caching = false, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@54f92f39, 
timestamped = false, caching = false, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@20a8580f, 
timestamped = false, caching = false, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@20a8580f, 
timestamped = false, caching = false, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@66920b40, 
timestamped = false, caching = false, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@66920b40, 
timestamped = false, caching = false, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@220644c6, 
timestamped = false, caching = false, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@220644c6, 
timestamped = false, caching = false, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@3374de01,
 timestamped = true, caching = true, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@3374de01,
 timestamped = true, caching = true, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@390723bf,
 timestamped = true, caching = true, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@390723bf,
 timestamped = true, caching = true, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@396d899c,
 timestamped = true, caching = true, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@396d899c,
 timestamped = true, caching = true, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@6f0a2f95,
 timestamped = true, caching = true, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@6f0a2f95,
 timestamped = true, caching = true, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@62c1c7f6,
 timestamped = true, caching = true, logging = false STARTED

MockProcessor

[jira] [Resolved] (KAFKA-12203) Migrate connect:mirror-client module to JUnit 5

2021-01-14 Thread Chia-Ping Tsai (Jira) 


 [ 
https://issues.apache.org/jira/browse/KAFKA-12203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Chia-Ping Tsai resolved KAFKA-12203.

Fix Version/s: 2.8.0
   Resolution: Fixed

> Migrate connect:mirror-client module to JUnit 5
> ---
>
> Key: KAFKA-12203
> URL: https://issues.apache.org/jira/browse/KAFKA-12203
> Project: Kafka
>  Issue Type: Sub-task
>Reporter: Chia-Ping Tsai
>Assignee: Chia-Ping Tsai
>Priority: Major
> Fix For: 2.8.0
>
>




--
This message was sent by Atlassian Jira
(v8.3.4#803005)

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

2021-01-14 Thread Apache Jenkins Server 
See 


Changes:

[github] KAFKA-12201: Migrate connect:basic-auth-extensio module to JUnit 5 
(#9892)

[github] MINOR: Initialize QuorumState lazily in RaftClient.initialize() (#9881)


--
[...truncated 3.64 MB...]

TopologyTestDriverEosTest > shouldReturnCorrectInMemoryStoreTypeOnly() STARTED

TopologyTestDriverEosTest > shouldReturnCorrectInMemoryStoreTypeOnly() PASSED

TopologyTestDriverEosTest > shouldThrowForMissingTime() STARTED

TopologyTestDriverEosTest > shouldThrowForMissingTime() PASSED

TopologyTestDriverEosTest > shouldCaptureInternalTopicNamesIfWrittenInto() 
STARTED

TopologyTestDriverEosTest > shouldCaptureInternalTopicNamesIfWrittenInto() 
PASSED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTimeDeprecated() STARTED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTimeDeprecated() PASSED

TopologyTestDriverEosTest > shouldProcessRecordForTopic() STARTED

TopologyTestDriverEosTest > shouldProcessRecordForTopic() PASSED

TopologyTestDriverEosTest > shouldForwardRecordsFromSubtopologyToSubtopology() 
STARTED

TopologyTestDriverEosTest > shouldForwardRecordsFromSubtopologyToSubtopology() 
PASSED

TopologyTestDriverEosTest > shouldNotUpdateStoreForSmallerValue() STARTED

TopologyTestDriverEosTest > shouldNotUpdateStoreForSmallerValue() PASSED

TopologyTestDriverEosTest > shouldCreateStateDirectoryForStatefulTopology() 
STARTED

TopologyTestDriverEosTest > shouldCreateStateDirectoryForStatefulTopology() 
PASSED

TopologyTestDriverEosTest > shouldNotRequireParameters() STARTED

TopologyTestDriverEosTest > shouldNotRequireParameters() PASSED

TopologyTestDriverEosTest > shouldPunctuateIfWallClockTimeAdvances() STARTED

TopologyTestDriverEosTest > shouldPunctuateIfWallClockTimeAdvances() PASSED

TestTopicsTest > testNonUsedOutputTopic() STARTED

TestTopicsTest > testNonUsedOutputTopic() PASSED

TestTopicsTest > testEmptyTopic() STARTED

TestTopicsTest > testEmptyTopic() PASSED

TestTopicsTest > testStartTimestamp() STARTED

TestTopicsTest > testStartTimestamp() PASSED

TestTopicsTest > testNegativeAdvance() STARTED

TestTopicsTest > testNegativeAdvance() PASSED

TestTopicsTest > shouldNotAllowToCreateWithNullDriver() STARTED

TestTopicsTest > shouldNotAllowToCreateWithNullDriver() PASSED

TestTopicsTest > testDuration() STARTED

TestTopicsTest > testDuration() PASSED

TestTopicsTest > testOutputToString() STARTED

TestTopicsTest > testOutputToString() PASSED

TestTopicsTest > testValue() STARTED

TestTopicsTest > testValue() PASSED

TestTopicsTest > testTimestampAutoAdvance() STARTED

TestTopicsTest > testTimestampAutoAdvance() PASSED

TestTopicsTest > testOutputWrongSerde() STARTED

TestTopicsTest > testOutputWrongSerde() PASSED

TestTopicsTest > shouldNotAllowToCreateOutputTopicWithNullTopicName() STARTED

TestTopicsTest > shouldNotAllowToCreateOutputTopicWithNullTopicName() PASSED

TestTopicsTest > testWrongSerde() STARTED

TestTopicsTest > testWrongSerde() PASSED

TestTopicsTest > testKeyValuesToMapWithNull() STARTED

TestTopicsTest > testKeyValuesToMapWithNull() PASSED

TestTopicsTest > testNonExistingOutputTopic() STARTED

TestTopicsTest > testNonExistingOutputTopic() PASSED

TestTopicsTest > testMultipleTopics() STARTED

TestTopicsTest > testMultipleTopics() PASSED

TestTopicsTest > testKeyValueList() STARTED

TestTopicsTest > testKeyValueList() PASSED

TestTopicsTest > shouldNotAllowToCreateOutputWithNullDriver() STARTED

TestTopicsTest > shouldNotAllowToCreateOutputWithNullDriver() PASSED

TestTopicsTest > testValueList() STARTED

TestTopicsTest > testValueList() PASSED

TestTopicsTest > testRecordList() STARTED

TestTopicsTest > testRecordList() PASSED

TestTopicsTest > testNonExistingInputTopic() STARTED

TestTopicsTest > testNonExistingInputTopic() PASSED

TestTopicsTest > testKeyValuesToMap() STARTED

TestTopicsTest > testKeyValuesToMap() PASSED

TestTopicsTest > testRecordsToList() STARTED

TestTopicsTest > testRecordsToList() PASSED

TestTopicsTest > testKeyValueListDuration() STARTED

TestTopicsTest > testKeyValueListDuration() PASSED

TestTopicsTest > testInputToString() STARTED

TestTopicsTest > testInputToString() PASSED

TestTopicsTest > testTimestamp() STARTED

TestTopicsTest > testTimestamp() PASSED

TestTopicsTest > testWithHeaders() STARTED

TestTopicsTest > testWithHeaders() PASSED

TestTopicsTest > testKeyValue() STARTED

TestTopicsTest > testKeyValue() PASSED

TestTopicsTest > shouldNotAllowToCreateTopicWithNullTopicName() STARTED

TestTopicsTest > shouldNotAllowToCreateTopicWithNullTopicName() PASSED

> Task :streams:upgrade-system-tests-20:processTestResources NO-SOURCE
> Task :streams:upgrade-system-tests-20:testClasses
> Task :streams:upgrade-system-tests-20:checkstyleTest
> Task :streams:upgrade-system-tests-20:spotbugsMain NO-SOURCE
> Task :streams:upgrade-system-tests-20:test
> Task :streams:upgrade-system-tests-21:co

[jira] [Resolved] (KAFKA-12189) ShellTest can replace 'assumeTrue' by (junit 5) conditional test

2021-01-14 Thread Chia-Ping Tsai (Jira) 


 [ 
https://issues.apache.org/jira/browse/KAFKA-12189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Chia-Ping Tsai resolved KAFKA-12189.

Fix Version/s: 2.8.0
   Resolution: Fixed

> ShellTest can replace 'assumeTrue' by (junit 5) conditional test
> 
>
> Key: KAFKA-12189
> URL: https://issues.apache.org/jira/browse/KAFKA-12189
> Project: Kafka
>  Issue Type: Improvement
>Reporter: Chia-Ping Tsai
>Assignee: GeordieMai
>Priority: Minor
> Fix For: 2.8.0
>
>
> from https://github.com/apache/kafka/pull/9874#discussion_r556664433
> the conditional test is more readable than assumeTest in testing code.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Resolved] (KAFKA-12191) SslTransportTls12Tls13Test can replace 'assumeTrue' by (junit 5) conditional test

2021-01-14 Thread Chia-Ping Tsai (Jira) 


 [ 
https://issues.apache.org/jira/browse/KAFKA-12191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Chia-Ping Tsai resolved KAFKA-12191.

Fix Version/s: 2.8.0
   Resolution: Fixed

> SslTransportTls12Tls13Test can replace 'assumeTrue' by (junit 5) conditional 
> test
> -
>
> Key: KAFKA-12191
> URL: https://issues.apache.org/jira/browse/KAFKA-12191
> Project: Kafka
>  Issue Type: Improvement
>Reporter: Chia-Ping Tsai
>Assignee: GeordieMai
>Priority: Minor
> Fix For: 2.8.0
>
>
> the conditional test is more readable than assumeTest in testing code.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Created] (KAFKA-12194) fix flaky AdjustStreamThreadCountTest tests

2021-01-14 Thread Luke Chen (Jira) 
Luke Chen created KAFKA-12194:
-

 Summary: fix flaky AdjustStreamThreadCountTest tests
 Key: KAFKA-12194
 URL: https://issues.apache.org/jira/browse/KAFKA-12194
 Project: Kafka
  Issue Type: Test
Reporter: Luke Chen
Assignee: Luke Chen


h3. Error Message

java.lang.AssertionError: Expected all streams instances in 
[org.apache.kafka.streams.KafkaStreams@7d253260] to be REBALANCING within 3 
ms, but the following were not: 
\{org.apache.kafka.streams.KafkaStreams@7d253260=RUNNING}
h3. Stacktrace

java.lang.AssertionError: Expected all streams instances in 
[org.apache.kafka.streams.KafkaStreams@7d253260] to be REBALANCING within 3 
ms, but the following were not: 
\{org.apache.kafka.streams.KafkaStreams@7d253260=RUNNING} at 
org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:26) at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.lambda$waitForApplicationState$12(IntegrationTestUtils.java:936)
 at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:350) 
at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:318) 
at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitForApplicationState(IntegrationTestUtils.java:919)
 at 
org.apache.kafka.streams.integration.AdjustStreamThreadCountTest.shouldRemoveStreamThread(AdjustStreamThreadCountTest.java:134)

 

 

 

 

The error also applies to all tests in AdjustStreamThreadCountTest

 

https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/380/testReport/junit/org.apache.kafka.streams.integration/AdjustStreamThreadCountTest/shouldAddStreamThread/
https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/381/testReport/junit/org.apache.kafka.streams.integration/AdjustStreamThreadCountTest/shouldAddAndRemoveStreamThreadsWhileKeepingNamesCorrect/
https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/380/testReport/junit/org.apache.kafka.streams.integration/AdjustStreamThreadCountTest/shouldRemoveStreamThread/
https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk15/398/testReport/junit/org.apache.kafka.streams.integration/AdjustStreamThreadCountTest/shouldAddAndRemoveStreamThreadsWhileKeepingNamesCorrect/



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

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

2021-01-14 Thread Apache Jenkins Server 
See 


Changes:

[github] KAFKA-12171: Migrate streams:test-utils module to JUnit 5 (#9856)


--
[...truncated 3.67 MB...]
TopologyTestDriverEosTest > shouldReturnAllStoresNames() PASSED

TopologyTestDriverEosTest > 
shouldPassRecordHeadersIntoSerializersAndDeserializers() STARTED

TopologyTestDriverEosTest > 
shouldPassRecordHeadersIntoSerializersAndDeserializers() PASSED

TopologyTestDriverEosTest > shouldProcessConsumerRecordList() STARTED

TopologyTestDriverEosTest > shouldProcessConsumerRecordList() PASSED

TopologyTestDriverEosTest > shouldUseSinkSpecificSerializers() STARTED

TopologyTestDriverEosTest > shouldUseSinkSpecificSerializers() PASSED

TopologyTestDriverEosTest > shouldFlushStoreForFirstInput() STARTED

TopologyTestDriverEosTest > shouldFlushStoreForFirstInput() PASSED

TopologyTestDriverEosTest > shouldProcessFromSourceThatMatchPattern() STARTED

TopologyTestDriverEosTest > shouldProcessFromSourceThatMatchPattern() PASSED

TopologyTestDriverEosTest > shouldCaptureSinkTopicNamesIfWrittenInto() STARTED

TopologyTestDriverEosTest > shouldCaptureSinkTopicNamesIfWrittenInto() PASSED

TopologyTestDriverEosTest > shouldUpdateStoreForNewKey() STARTED

TopologyTestDriverEosTest > shouldUpdateStoreForNewKey() PASSED

TopologyTestDriverEosTest > shouldSendRecordViaCorrectSourceTopicDeprecated() 
STARTED

TopologyTestDriverEosTest > shouldSendRecordViaCorrectSourceTopicDeprecated() 
PASSED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTime() STARTED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTime() PASSED

TopologyTestDriverEosTest > shouldSetRecordMetadata() STARTED

TopologyTestDriverEosTest > shouldSetRecordMetadata() PASSED

TopologyTestDriverEosTest > shouldNotUpdateStoreForLargerValue() STARTED

TopologyTestDriverEosTest > shouldNotUpdateStoreForLargerValue() PASSED

TopologyTestDriverEosTest > shouldReturnCorrectInMemoryStoreTypeOnly() STARTED

TopologyTestDriverEosTest > shouldReturnCorrectInMemoryStoreTypeOnly() PASSED

TopologyTestDriverEosTest > shouldThrowForMissingTime() STARTED

TopologyTestDriverEosTest > shouldThrowForMissingTime() PASSED

TopologyTestDriverEosTest > shouldCaptureInternalTopicNamesIfWrittenInto() 
STARTED

TopologyTestDriverEosTest > shouldCaptureInternalTopicNamesIfWrittenInto() 
PASSED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTimeDeprecated() STARTED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTimeDeprecated() PASSED

TopologyTestDriverEosTest > shouldProcessRecordForTopic() STARTED

TopologyTestDriverEosTest > shouldProcessRecordForTopic() PASSED

TopologyTestDriverEosTest > shouldForwardRecordsFromSubtopologyToSubtopology() 
STARTED

TopologyTestDriverEosTest > shouldForwardRecordsFromSubtopologyToSubtopology() 
PASSED

TopologyTestDriverEosTest > shouldNotUpdateStoreForSmallerValue() STARTED

TopologyTestDriverEosTest > shouldNotUpdateStoreForSmallerValue() PASSED

TopologyTestDriverEosTest > shouldCreateStateDirectoryForStatefulTopology() 
STARTED

TopologyTestDriverEosTest > shouldCreateStateDirectoryForStatefulTopology() 
PASSED

TopologyTestDriverEosTest > shouldNotRequireParameters() STARTED

TopologyTestDriverEosTest > shouldNotRequireParameters() PASSED

TopologyTestDriverEosTest > shouldPunctuateIfWallClockTimeAdvances() STARTED

TopologyTestDriverEosTest > shouldPunctuateIfWallClockTimeAdvances() PASSED

KeyValueStoreFacadeTest > shouldReturnIsOpen() STARTED

KeyValueStoreFacadeTest > shouldReturnIsOpen() PASSED

KeyValueStoreFacadeTest > shouldDeleteAndReturnPlainValue() STARTED

KeyValueStoreFacadeTest > shouldDeleteAndReturnPlainValue() PASSED

KeyValueStoreFacadeTest > shouldReturnName() STARTED

KeyValueStoreFacadeTest > shouldReturnName() PASSED

KeyValueStoreFacadeTest > shouldPutWithUnknownTimestamp() STARTED

KeyValueStoreFacadeTest > shouldPutWithUnknownTimestamp() PASSED

KeyValueStoreFacadeTest > shouldPutAllWithUnknownTimestamp() STARTED

KeyValueStoreFacadeTest > shouldPutAllWithUnknownTimestamp() PASSED

KeyValueStoreFacadeTest > shouldReturnIsPersistent() STARTED

KeyValueStoreFacadeTest > shouldReturnIsPersistent() PASSED

KeyValueStoreFacadeTest > shouldForwardDeprecatedInit() STARTED

KeyValueStoreFacadeTest > shouldForwardDeprecatedInit() PASSED

KeyValueStoreFacadeTest > shouldPutIfAbsentWithUnknownTimestamp() STARTED

KeyValueStoreFacadeTest > shouldPutIfAbsentWithUnknownTimestamp() PASSED

KeyValueStoreFacadeTest > shouldForwardClose() STARTED

KeyValueStoreFacadeTest > shouldForwardClose() PASSED

KeyValueStoreFacadeTest > shouldForwardFlush() STARTED

KeyValueStoreFacadeTest > shouldForwardFlush() PASSED

KeyValueStoreFacadeTest > shouldForwardInit() STARTED

KeyValueStoreFacadeTest > shouldForwardInit() PASSED

> Task :streams:upgrade-system-tests-11:processTestResources NO-SOURCE
> Task :streams:upgrade-system-tests-11:testClasses
> Task :streams:up

[jira] [Created] (KAFKA-12195) Fix synchronization issue happening in KafkaStreams (related to flaky AdjustStreamThreadCountTest)

2021-01-14 Thread Chia-Ping Tsai (Jira) 
Chia-Ping Tsai created KAFKA-12195:
--

 Summary: Fix synchronization issue happening in KafkaStreams 
(related to flaky AdjustStreamThreadCountTest)
 Key: KAFKA-12195
 URL: https://issues.apache.org/jira/browse/KAFKA-12195
 Project: Kafka
  Issue Type: Improvement
Reporter: Chia-Ping Tsai
Assignee: Chia-Ping Tsai


{code}
threads = Collections.synchronizedList(new LinkedList<>());
{code}

The synchronization list requires us to manually synchronize the iterator. 
non-synchronizing the list results in inconsistent results and consequently 
unstabilize the AdjustStreamThreadCountTest.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Created] (KAFKA-12196) Migrate connect:api module to JUnit 5

2021-01-14 Thread Chia-Ping Tsai (Jira) 
Chia-Ping Tsai created KAFKA-12196:
--

 Summary: Migrate connect:api module to JUnit 5
 Key: KAFKA-12196
 URL: https://issues.apache.org/jira/browse/KAFKA-12196
 Project: Kafka
  Issue Type: Sub-task
Reporter: Chia-Ping Tsai






--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Created] (KAFKA-12198) Migrate connect:json module to JUnit 5

2021-01-14 Thread Chia-Ping Tsai (Jira) 
Chia-Ping Tsai created KAFKA-12198:
--

 Summary: Migrate connect:json module to JUnit 5
 Key: KAFKA-12198
 URL: https://issues.apache.org/jira/browse/KAFKA-12198
 Project: Kafka
  Issue Type: Sub-task
Reporter: Chia-Ping Tsai






--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Created] (KAFKA-12197) Migrate connect:transforms module to JUnit 5

2021-01-14 Thread Chia-Ping Tsai (Jira) 
Chia-Ping Tsai created KAFKA-12197:
--

 Summary: Migrate connect:transforms module to JUnit 5
 Key: KAFKA-12197
 URL: https://issues.apache.org/jira/browse/KAFKA-12197
 Project: Kafka
  Issue Type: Sub-task
Reporter: Chia-Ping Tsai






--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Created] (KAFKA-12200) Migrate connect:file module to JUnit 5

2021-01-14 Thread Chia-Ping Tsai (Jira) 
Chia-Ping Tsai created KAFKA-12200:
--

 Summary: Migrate connect:file module to JUnit 5
 Key: KAFKA-12200
 URL: https://issues.apache.org/jira/browse/KAFKA-12200
 Project: Kafka
  Issue Type: Sub-task
Reporter: Chia-Ping Tsai






--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Created] (KAFKA-12202) Migrate connect:mirror module to JUnit 5

2021-01-14 Thread Chia-Ping Tsai (Jira) 
Chia-Ping Tsai created KAFKA-12202:
--

 Summary: Migrate connect:mirror module to JUnit 5
 Key: KAFKA-12202
 URL: https://issues.apache.org/jira/browse/KAFKA-12202
 Project: Kafka
  Issue Type: Sub-task
Reporter: Chia-Ping Tsai






--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Created] (KAFKA-12199) Migrate connect:runtime module to JUnit 5

2021-01-14 Thread Chia-Ping Tsai (Jira) 
Chia-Ping Tsai created KAFKA-12199:
--

 Summary: Migrate connect:runtime module to JUnit 5
 Key: KAFKA-12199
 URL: https://issues.apache.org/jira/browse/KAFKA-12199
 Project: Kafka
  Issue Type: Sub-task
Reporter: Chia-Ping Tsai






--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Created] (KAFKA-12203) Migrate connect:mirror-client module to JUnit 5

2021-01-14 Thread Chia-Ping Tsai (Jira) 
Chia-Ping Tsai created KAFKA-12203:
--

 Summary: Migrate connect:mirror-client module to JUnit 5
 Key: KAFKA-12203
 URL: https://issues.apache.org/jira/browse/KAFKA-12203
 Project: Kafka
  Issue Type: Sub-task
Reporter: Chia-Ping Tsai






--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Created] (KAFKA-12201) Migrate connect:basic-auth-extensio module to JUnit 5

2021-01-14 Thread Chia-Ping Tsai (Jira) 
Chia-Ping Tsai created KAFKA-12201:
--

 Summary: Migrate connect:basic-auth-extensio module to JUnit 5
 Key: KAFKA-12201
 URL: https://issues.apache.org/jira/browse/KAFKA-12201
 Project: Kafka
  Issue Type: Sub-task
Reporter: Chia-Ping Tsai






--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Reopened] (KAFKA-12185) Flaky Test StoreQueryIntegrationTest#shouldQueryAllStalePartitionStores

2021-01-14 Thread Bruno Cadonna (Jira) 


 [ 
https://issues.apache.org/jira/browse/KAFKA-12185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Bruno Cadonna reopened KAFKA-12185:
---

> Flaky Test StoreQueryIntegrationTest#shouldQueryAllStalePartitionStores
> ---
>
> Key: KAFKA-12185
> URL: https://issues.apache.org/jira/browse/KAFKA-12185
> Project: Kafka
>  Issue Type: Bug
>  Components: streams, unit tests
>Reporter: Matthias J. Sax
>Assignee: Bruno Cadonna
>Priority: Critical
>  Labels: flaky-test
>
> java.lang.AssertionError: Application did not reach a RUNNING state for 
> all streams instances. Non-running instances: 
> \{org.apache.kafka.streams.KafkaStreams@651720d3=NOT_RUNNING}
>   at org.junit.Assert.fail(Assert.java:89)
>   at 
> org.apache.kafka.streams.integration.utils.IntegrationTestUtils.startApplicationAndWaitUntilRunning(IntegrationTestUtils.java:892)
>   at 
> org.apache.kafka.streams.integration.StoreQueryIntegrationTest.shouldQueryAllStalePartitionStores(StoreQueryIntegrationTest.java:270)
>  
> {{https://github.com/apache/kafka/pull/9835/checks?check_run_id=139314}}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

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

2021-01-14 Thread Apache Jenkins Server 
See 


Changes:

[github] KAFKA-12171: Migrate streams:test-utils module to JUnit 5 (#9856)


--
[...truncated 3.64 MB...]
OutputVerifierTest > 
shouldPassIfKeyAndValueIsEqualForCompareKeyValueWithProducerRecord() STARTED

OutputVerifierTest > 
shouldPassIfKeyAndValueIsEqualForCompareKeyValueWithProducerRecord() PASSED

OutputVerifierTest > 
shouldFailIfValueIsDifferentForCompareKeyValueWithProducerRecord() STARTED

OutputVerifierTest > 
shouldFailIfValueIsDifferentForCompareKeyValueWithProducerRecord() PASSED

OutputVerifierTest > shouldFailIfValueIsDifferentForCompareValueTimestamp() 
STARTED

OutputVerifierTest > shouldFailIfValueIsDifferentForCompareValueTimestamp() 
PASSED

OutputVerifierTest > shouldNotAllowNullProducerRecordForCompareValue() STARTED

OutputVerifierTest > shouldNotAllowNullProducerRecordForCompareValue() PASSED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullForCompareValueTimestamp() STARTED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullForCompareValueTimestamp() PASSED

OutputVerifierTest > shouldFailIfKeyIsDifferentForCompareKeyValueTimestamp() 
STARTED

OutputVerifierTest > shouldFailIfKeyIsDifferentForCompareKeyValueTimestamp() 
PASSED

OutputVerifierTest > 
shouldFailIfKeyIsDifferentForCompareKeyValueTimestampWithProducerRecord() 
STARTED

OutputVerifierTest > 
shouldFailIfKeyIsDifferentForCompareKeyValueTimestampWithProducerRecord() PASSED

OutputVerifierTest > 
shouldPassIfValueIsEqualWithNullForCompareValueWithProducerRecord() STARTED

OutputVerifierTest > 
shouldPassIfValueIsEqualWithNullForCompareValueWithProducerRecord() PASSED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullReverseForCompareValueTimestamp() STARTED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullReverseForCompareValueTimestamp() PASSED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullReverseForCompareValue() STARTED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullReverseForCompareValue() PASSED

OutputVerifierTest > shouldFailIfTimestampIsDifferentForCompareValueTimestamp() 
STARTED

OutputVerifierTest > shouldFailIfTimestampIsDifferentForCompareValueTimestamp() 
PASSED

OutputVerifierTest > 
shouldPassIfKeyAndValueAndTimestampIsEqualWithNullForCompareKeyValueTimestampWithProducerRecord()
 STARTED

OutputVerifierTest > 
shouldPassIfKeyAndValueAndTimestampIsEqualWithNullForCompareKeyValueTimestampWithProducerRecord()
 PASSED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullForCompareKeyValueWithProducerRecord() 
STARTED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullForCompareKeyValueWithProducerRecord() 
PASSED

OutputVerifierTest > 
shouldFailIfValueIsDifferentForCompareKeyValueTimestampWithProducerRecord() 
STARTED

OutputVerifierTest > 
shouldFailIfValueIsDifferentForCompareKeyValueTimestampWithProducerRecord() 
PASSED

OutputVerifierTest > 
shouldNotAllowNullProducerRecordWithExpectedRecordForCompareValueTimestamp() 
STARTED

OutputVerifierTest > 
shouldNotAllowNullProducerRecordWithExpectedRecordForCompareValueTimestamp() 
PASSED

OutputVerifierTest > shouldNotAllowNullExpectedRecordForCompareValue() STARTED

OutputVerifierTest > shouldNotAllowNullExpectedRecordForCompareValue() PASSED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullReversForCompareKeyValueTimestampWithProducerRecord()
 STARTED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullReversForCompareKeyValueTimestampWithProducerRecord()
 PASSED

OutputVerifierTest > shouldNotAllowNullProducerRecordForCompareKeyValue() 
STARTED

OutputVerifierTest > shouldNotAllowNullProducerRecordForCompareKeyValue() PASSED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullReversForCompareKeyValueWithProducerRecord()
 STARTED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullReversForCompareKeyValueWithProducerRecord()
 PASSED

OutputVerifierTest > 
shouldPassIfKeyAndValueAndTimestampIsEqualForCompareKeyValueTimestamp() STARTED

OutputVerifierTest > 
shouldPassIfKeyAndValueAndTimestampIsEqualForCompareKeyValueTimestamp() PASSED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullForCompareKeyValueTimestampWithProducerRecord()
 STARTED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullForCompareKeyValueTimestampWithProducerRecord()
 PASSED

OutputVerifierTest > 
shouldFailIfKeyIsDifferentWithNullReversForCompareKeyValueWithProducerRecord() 
STARTED

OutputVerifierTest > 
shouldFailIfKeyIsDifferentWithNullReversForCompareKeyValueWithProducerRecord() 
PASSED

OutputVerifierTest > 
shouldPassIfKeyAndValueIsEqualWithNullForCompareKeyValueWithProducerRecord() 
STARTED

OutputVerifierTest > 
shouldPassIfKeyAndValueIsEqualWithNullForCompareKeyValueWithProducerRecord() 
PASSED

OutputVerifierTest > 
shouldFailIfKeyIsDifferentWithNullForCompareKeyValueTimestampWithProducerRecord()
 STARTED

Ou

Re: [DISCUSS] KIP-703: Add a metrics for reporting idle connections closed

2021-01-14 Thread Rajini Sivaram 
Hi Pere,

Thanks for the KIP, it is a useful metric. Btw, in the `Public Interfaces`
section, can we just document the metric names since the code and sensors
are not part of the public API? The proposed changes section includes the
code anyway. You can use `Selector Monitoring` in the docs (
https://kafka.apache.org/documentation/#selector_monitoring) as an example.

Regards,

Rajini

On Fri, Jan 8, 2021 at 12:22 PM Pere Urbón Bayes 
wrote:

> Hi,
>   I would love to kick start a discussion for KIP-703, the proposal is
> available
>
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-703%3A+Add+a+metrics+for+reporting+idle+connections+closed
>
> It is a minor change but certainly helps to improve the ops day2day life.
>
> What do you think? Looking forward to hearing your thoughts and feedback.
>
> --
> Pere Urbon-Bayes
> Software Architect
> https://twitter.com/purbon
> https://www.linkedin.com/in/purbon/
>

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

2021-01-14 Thread Apache Jenkins Server 
See 


Changes:

[github] MINOR: Rename examples to example (#9886)


--
[...truncated 3.66 MB...]
MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@4a5e5dd, 
timestamped = true, caching = false, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@4a5e5dd, 
timestamped = true, caching = false, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@3673293b,
 timestamped = true, caching = false, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@3673293b,
 timestamped = true, caching = false, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@1d19cd64,
 timestamped = true, caching = false, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@1d19cd64,
 timestamped = true, caching = false, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@755f8ced,
 timestamped = true, caching = false, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@755f8ced,
 timestamped = true, caching = false, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@29ab64de,
 timestamped = true, caching = false, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@29ab64de,
 timestamped = true, caching = false, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@3dc3a570,
 timestamped = true, caching = false, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@3dc3a570,
 timestamped = true, caching = false, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@2c482d4d, 
timestamped = false, caching = true, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@2c482d4d, 
timestamped = false, caching = true, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@26cb30e3, 
timestamped = false, caching = true, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@26cb30e3, 
timestamped = false, caching = true, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@4207e1c9, 
timestamped = false, caching = true, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@4207e1c9, 
timestamped = false, caching = true, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@2385583a, 
timestamped = false, caching = true, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@2385583a, 
timestamped = false, caching = true, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@4bdf61c9, 
timestamped = false, caching = true, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@4bdf61c9, 
timestamped = false, caching = true, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@3393e4a3, 
timestamped = false, caching = true, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@3393e4a3, 
timestamped = false, caching = true, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@6b52b06f, 
timestamped = false, caching = false, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@6b52b06f, 
timestamped =

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

2021-01-14 Thread Apache Jenkins Server 
See 


Changes:

[github] MINOR: Rename examples to example (#9886)


--
[...truncated 3.64 MB...]

TopologyTestDriverEosTest > 
shouldApplyGlobalUpdatesCorrectlyInRecursiveTopologies() STARTED

TopologyTestDriverEosTest > 
shouldApplyGlobalUpdatesCorrectlyInRecursiveTopologies() PASSED

TopologyTestDriverEosTest > shouldReturnAllStoresNames() STARTED

TopologyTestDriverEosTest > shouldReturnAllStoresNames() PASSED

TopologyTestDriverEosTest > 
shouldPassRecordHeadersIntoSerializersAndDeserializers() STARTED

TopologyTestDriverEosTest > 
shouldPassRecordHeadersIntoSerializersAndDeserializers() PASSED

TopologyTestDriverEosTest > shouldProcessConsumerRecordList() STARTED

TopologyTestDriverEosTest > shouldProcessConsumerRecordList() PASSED

TopologyTestDriverEosTest > shouldUseSinkSpecificSerializers() STARTED

TopologyTestDriverEosTest > shouldUseSinkSpecificSerializers() PASSED

TopologyTestDriverEosTest > shouldFlushStoreForFirstInput() STARTED

TopologyTestDriverEosTest > shouldFlushStoreForFirstInput() PASSED

TopologyTestDriverEosTest > shouldProcessFromSourceThatMatchPattern() STARTED

TopologyTestDriverEosTest > shouldProcessFromSourceThatMatchPattern() PASSED

TopologyTestDriverEosTest > shouldCaptureSinkTopicNamesIfWrittenInto() STARTED

TopologyTestDriverEosTest > shouldCaptureSinkTopicNamesIfWrittenInto() PASSED

TopologyTestDriverEosTest > shouldUpdateStoreForNewKey() STARTED

TopologyTestDriverEosTest > shouldUpdateStoreForNewKey() PASSED

TopologyTestDriverEosTest > shouldSendRecordViaCorrectSourceTopicDeprecated() 
STARTED

TopologyTestDriverEosTest > shouldSendRecordViaCorrectSourceTopicDeprecated() 
PASSED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTime() STARTED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTime() PASSED

TopologyTestDriverEosTest > shouldSetRecordMetadata() STARTED

TopologyTestDriverEosTest > shouldSetRecordMetadata() PASSED

TopologyTestDriverEosTest > shouldNotUpdateStoreForLargerValue() STARTED

TopologyTestDriverEosTest > shouldNotUpdateStoreForLargerValue() PASSED

TopologyTestDriverEosTest > shouldReturnCorrectInMemoryStoreTypeOnly() STARTED

TopologyTestDriverEosTest > shouldReturnCorrectInMemoryStoreTypeOnly() PASSED

TopologyTestDriverEosTest > shouldThrowForMissingTime() STARTED

TopologyTestDriverEosTest > shouldThrowForMissingTime() PASSED

TopologyTestDriverEosTest > shouldCaptureInternalTopicNamesIfWrittenInto() 
STARTED

TopologyTestDriverEosTest > shouldCaptureInternalTopicNamesIfWrittenInto() 
PASSED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTimeDeprecated() STARTED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTimeDeprecated() PASSED

TopologyTestDriverEosTest > shouldProcessRecordForTopic() STARTED

TopologyTestDriverEosTest > shouldProcessRecordForTopic() PASSED

TopologyTestDriverEosTest > shouldForwardRecordsFromSubtopologyToSubtopology() 
STARTED

TopologyTestDriverEosTest > shouldForwardRecordsFromSubtopologyToSubtopology() 
PASSED

TopologyTestDriverEosTest > shouldNotUpdateStoreForSmallerValue() STARTED

TopologyTestDriverEosTest > shouldNotUpdateStoreForSmallerValue() PASSED

TopologyTestDriverEosTest > shouldCreateStateDirectoryForStatefulTopology() 
STARTED

TopologyTestDriverEosTest > shouldCreateStateDirectoryForStatefulTopology() 
PASSED

TopologyTestDriverEosTest > shouldNotRequireParameters() STARTED

TopologyTestDriverEosTest > shouldNotRequireParameters() PASSED

TopologyTestDriverEosTest > shouldPunctuateIfWallClockTimeAdvances() STARTED

TopologyTestDriverEosTest > shouldPunctuateIfWallClockTimeAdvances() PASSED

> Task :streams:upgrade-system-tests-0100:processTestResources NO-SOURCE
> Task :streams:upgrade-system-tests-0100:testClasses
> Task :streams:upgrade-system-tests-0100:checkstyleTest
> Task :streams:upgrade-system-tests-0100:spotbugsMain NO-SOURCE
> Task :streams:upgrade-system-tests-0100:test
> Task :streams:upgrade-system-tests-0101:compileJava NO-SOURCE
> Task :streams:upgrade-system-tests-0101:processResources NO-SOURCE
> Task :streams:upgrade-system-tests-0101:classes UP-TO-DATE
> Task :streams:upgrade-system-tests-0101:checkstyleMain NO-SOURCE
> Task :streams:upgrade-system-tests-0101:compileTestJava
> Task :streams:upgrade-system-tests-0101:processTestResources NO-SOURCE
> Task :streams:upgrade-system-tests-0101:testClasses
> Task :streams:upgrade-system-tests-0101:checkstyleTest
> Task :streams:upgrade-system-tests-0101:spotbugsMain NO-SOURCE
> Task :streams:upgrade-system-tests-0101:test
> Task :streams:upgrade-system-tests-0102:compileJava NO-SOURCE
> Task :streams:upgrade-system-tests-0102:processResources NO-SOURCE
> Task :streams:upgrade-system-tests-0102:classes UP-TO-DATE
> Task :streams:upgrade-system-tests-0102:checkstyleMain NO-SOURCE
> Task :streams:upgrade-system-tests-0102:compileTestJava
> Task :streams:upgrade-system-tests-01

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

2021-01-14 Thread Apache Jenkins Server 
See 


Changes:

[github] MINOR: Rename examples to example (#9886)


--
[...truncated 3.66 MB...]

TopologyTestDriverEosTest > 
shouldApplyGlobalUpdatesCorrectlyInRecursiveTopologies() STARTED

TopologyTestDriverEosTest > 
shouldApplyGlobalUpdatesCorrectlyInRecursiveTopologies() PASSED

TopologyTestDriverEosTest > shouldReturnAllStoresNames() STARTED

TopologyTestDriverEosTest > shouldReturnAllStoresNames() PASSED

TopologyTestDriverEosTest > 
shouldPassRecordHeadersIntoSerializersAndDeserializers() STARTED

TopologyTestDriverEosTest > 
shouldPassRecordHeadersIntoSerializersAndDeserializers() PASSED

TopologyTestDriverEosTest > shouldProcessConsumerRecordList() STARTED

TopologyTestDriverEosTest > shouldProcessConsumerRecordList() PASSED

TopologyTestDriverEosTest > shouldUseSinkSpecificSerializers() STARTED

TopologyTestDriverEosTest > shouldUseSinkSpecificSerializers() PASSED

TopologyTestDriverEosTest > shouldFlushStoreForFirstInput() STARTED

TopologyTestDriverEosTest > shouldFlushStoreForFirstInput() PASSED

TopologyTestDriverEosTest > shouldProcessFromSourceThatMatchPattern() STARTED

TopologyTestDriverEosTest > shouldProcessFromSourceThatMatchPattern() PASSED

TopologyTestDriverEosTest > shouldCaptureSinkTopicNamesIfWrittenInto() STARTED

TopologyTestDriverEosTest > shouldCaptureSinkTopicNamesIfWrittenInto() PASSED

TopologyTestDriverEosTest > shouldUpdateStoreForNewKey() STARTED

TopologyTestDriverEosTest > shouldUpdateStoreForNewKey() PASSED

TopologyTestDriverEosTest > shouldSendRecordViaCorrectSourceTopicDeprecated() 
STARTED

TopologyTestDriverEosTest > shouldSendRecordViaCorrectSourceTopicDeprecated() 
PASSED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTime() STARTED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTime() PASSED

TopologyTestDriverEosTest > shouldSetRecordMetadata() STARTED

TopologyTestDriverEosTest > shouldSetRecordMetadata() PASSED

TopologyTestDriverEosTest > shouldNotUpdateStoreForLargerValue() STARTED

TopologyTestDriverEosTest > shouldNotUpdateStoreForLargerValue() PASSED

TopologyTestDriverEosTest > shouldReturnCorrectInMemoryStoreTypeOnly() STARTED

TopologyTestDriverEosTest > shouldReturnCorrectInMemoryStoreTypeOnly() PASSED

TopologyTestDriverEosTest > shouldThrowForMissingTime() STARTED

TopologyTestDriverEosTest > shouldThrowForMissingTime() PASSED

TopologyTestDriverEosTest > shouldCaptureInternalTopicNamesIfWrittenInto() 
STARTED

TopologyTestDriverEosTest > shouldCaptureInternalTopicNamesIfWrittenInto() 
PASSED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTimeDeprecated() STARTED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTimeDeprecated() PASSED

TopologyTestDriverEosTest > shouldProcessRecordForTopic() STARTED

TopologyTestDriverEosTest > shouldProcessRecordForTopic() PASSED

TopologyTestDriverEosTest > shouldForwardRecordsFromSubtopologyToSubtopology() 
STARTED

TopologyTestDriverEosTest > shouldForwardRecordsFromSubtopologyToSubtopology() 
PASSED

TopologyTestDriverEosTest > shouldNotUpdateStoreForSmallerValue() STARTED

TopologyTestDriverEosTest > shouldNotUpdateStoreForSmallerValue() PASSED

TopologyTestDriverEosTest > shouldCreateStateDirectoryForStatefulTopology() 
STARTED

TopologyTestDriverEosTest > shouldCreateStateDirectoryForStatefulTopology() 
PASSED

TopologyTestDriverEosTest > shouldNotRequireParameters() STARTED

TopologyTestDriverEosTest > shouldNotRequireParameters() PASSED

TopologyTestDriverEosTest > shouldPunctuateIfWallClockTimeAdvances() STARTED

TopologyTestDriverEosTest > shouldPunctuateIfWallClockTimeAdvances() PASSED

> Task :streams:upgrade-system-tests-0100:processTestResources NO-SOURCE
> Task :streams:upgrade-system-tests-0100:testClasses
> Task :streams:upgrade-system-tests-0100:checkstyleTest
> Task :streams:upgrade-system-tests-0100:spotbugsMain NO-SOURCE
> Task :streams:upgrade-system-tests-0100:test
> Task :streams:upgrade-system-tests-0101:compileJava NO-SOURCE
> Task :streams:upgrade-system-tests-0101:processResources NO-SOURCE
> Task :streams:upgrade-system-tests-0101:classes UP-TO-DATE
> Task :streams:upgrade-system-tests-0101:checkstyleMain NO-SOURCE
> Task :streams:upgrade-system-tests-0101:compileTestJava
> Task :streams:upgrade-system-tests-0101:processTestResources NO-SOURCE
> Task :streams:upgrade-system-tests-0101:testClasses
> Task :streams:upgrade-system-tests-0101:checkstyleTest
> Task :streams:upgrade-system-tests-0101:spotbugsMain NO-SOURCE
> Task :streams:upgrade-system-tests-0101:test
> Task :streams:upgrade-system-tests-0102:compileJava NO-SOURCE
> Task :streams:upgrade-system-tests-0102:processResources NO-SOURCE
> Task :streams:upgrade-system-tests-0102:classes UP-TO-DATE
> Task :streams:upgrade-system-tests-0102:checkstyleMain NO-SOURCE
> Task :streams:upgrade-system-tests-0102:compileTestJava
> Task :streams:upgrade-system-tests-0

[GitHub] [kafka-site] mimaison opened a new pull request #322: KAFKA-6223: Use archives.apache.org for older releases

2021-01-14 Thread GitBox 


mimaison opened a new pull request #322:
URL: https://github.com/apache/kafka-site/pull/322


   



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 to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

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

2021-01-14 Thread Apache Jenkins Server 
See 


Changes:

[github] MINOR: replace NotLeaderForPartitionException with 
NotLeaderOrFollowerException (#9885)

[github] MINOR: Updating files with release 2.6.1 (#9844)


--
[...truncated 3.66 MB...]

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@3673293b,
 timestamped = true, caching = false, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@3673293b,
 timestamped = true, caching = false, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@1d19cd64,
 timestamped = true, caching = false, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@1d19cd64,
 timestamped = true, caching = false, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@755f8ced,
 timestamped = true, caching = false, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@755f8ced,
 timestamped = true, caching = false, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@29ab64de,
 timestamped = true, caching = false, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@29ab64de,
 timestamped = true, caching = false, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@3dc3a570,
 timestamped = true, caching = false, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@3dc3a570,
 timestamped = true, caching = false, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@2c482d4d, 
timestamped = false, caching = true, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@2c482d4d, 
timestamped = false, caching = true, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@26cb30e3, 
timestamped = false, caching = true, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@26cb30e3, 
timestamped = false, caching = true, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@4207e1c9, 
timestamped = false, caching = true, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@4207e1c9, 
timestamped = false, caching = true, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@2385583a, 
timestamped = false, caching = true, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@2385583a, 
timestamped = false, caching = true, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@4bdf61c9, 
timestamped = false, caching = true, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@4bdf61c9, 
timestamped = false, caching = true, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@3393e4a3, 
timestamped = false, caching = true, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@3393e4a3, 
timestamped = false, caching = true, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@6b52b06f, 
timestamped = false, caching = false, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@6b52b06f, 
timestamped = false, caching = false, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@23d05ff4, 
timestamped = false, caching = false, logging = true STARTED

MockProcessorContextStateStoreTest > builder

Re: [DISCUSS] Apache Kafka 2.8.0 release

2021-01-14 Thread John Roesler 
Hi David,

Thanks for the heads-up; it's added.

-John

On Thu, 2021-01-14 at 08:43 +0100, David Jacot wrote:
> Hi John,
> 
> KIP-700 just got accepted. Can we add it to the release plan?
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-700%3A+Add+Describe+Cluster+API
> 
> Thanks,
> David
> 
> On Wed, Jan 13, 2021 at 11:22 PM John Roesler  wrote:
> 
> > Thanks, Gary! Sorry for the oversight.
> > -John
> > 
> > On Wed, 2021-01-13 at 21:25 +, Gary Russell wrote:
> > > Can you add a link to the summary page [1]?
> > > 
> > > I always start there.
> > > 
> > > Thanks
> > > 
> > > [1]:
> > https://cwiki.apache.org/confluence/display/KAFKA/Future+release+plan
> > > Future release plan - Apache Kafka - Apache Software Foundation<
> > https://cwiki.apache.org/confluence/display/KAFKA/Future+release+plan>
> > > Release Plan 0.10.0; Release Plan 0.10.1; Release Plan 0.10.2.0; Release
> > Plan 0.10.2.2; Release Plan 0.11.0.0; Release Plan 0.11.0.3; Release Plan
> > 1.0.0 (2017 Oct.)
> > > cwiki.apache.org
> > > 
> > > 
> > > From: John Roesler 
> > > Sent: Wednesday, January 13, 2021 4:11 PM
> > > To: dev@kafka.apache.org 
> > > Subject: Re: [DISCUSS] Apache Kafka 2.8.0 release
> > > 
> > > Hello again, all,
> > > 
> > > I have published a release plan at
> > > 
> > https://nam04.safelinks.protection.outlook.com/?url=https%3A%2F%2Fcwiki.apache.org%2Fconfluence%2Fpages%2Fviewpage.action%3FpageId%3D173081737&data=04%7C01%7Cgrussell%40vmware.com%7C6bb299de16bf4730c73608d8b8079404%7Cb39138ca3cee4b4aa4d6cd83d9dd62f0%7C0%7C0%7C637461689989420036%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C1000&sdata=8RfiDJZRr%2BZ1S46I5ZrHRyNOEKiBzjHYlxD4AnAb8p8%3D&reserved=0
> > > 
> > > I have included all the KIPs that are currently approved,
> > > but I am happy to make adjustments as necessary.
> > > 
> > > The KIP freeze is Jan 27th.
> > > 
> > > Please let me know if you have any objections.
> > > 
> > > Thanks,
> > > -John
> > > 
> > > On Wed, 2021-01-06 at 23:30 -0600, John Roesler wrote:
> > > > Hello All,
> > > > 
> > > > I'd like to volunteer to be the release manager for our next
> > > > feature release, 2.8.0. If there are no objections, I'll
> > > > send out the release plan soon.
> > > > 
> > > > Thanks,
> > > > John Roesler
> > > > 
> > > 
> > > 
> > 
> > 
> >

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

2021-01-14 Thread Apache Jenkins Server 
See 


Changes:

[github] MINOR: replace NotLeaderForPartitionException with 
NotLeaderOrFollowerException (#9885)

[github] MINOR: Updating files with release 2.6.1 (#9844)


--
[...truncated 3.64 MB...]
OutputVerifierTest > shouldNotAllowNullProducerRecordForCompareKeyValue() 
STARTED

OutputVerifierTest > shouldNotAllowNullProducerRecordForCompareKeyValue() PASSED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullReversForCompareKeyValueWithProducerRecord()
 STARTED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullReversForCompareKeyValueWithProducerRecord()
 PASSED

OutputVerifierTest > 
shouldPassIfKeyAndValueAndTimestampIsEqualForCompareKeyValueTimestamp() STARTED

OutputVerifierTest > 
shouldPassIfKeyAndValueAndTimestampIsEqualForCompareKeyValueTimestamp() PASSED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullForCompareKeyValueTimestampWithProducerRecord()
 STARTED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullForCompareKeyValueTimestampWithProducerRecord()
 PASSED

OutputVerifierTest > 
shouldFailIfKeyIsDifferentWithNullReversForCompareKeyValueWithProducerRecord() 
STARTED

OutputVerifierTest > 
shouldFailIfKeyIsDifferentWithNullReversForCompareKeyValueWithProducerRecord() 
PASSED

OutputVerifierTest > 
shouldPassIfKeyAndValueIsEqualWithNullForCompareKeyValueWithProducerRecord() 
STARTED

OutputVerifierTest > 
shouldPassIfKeyAndValueIsEqualWithNullForCompareKeyValueWithProducerRecord() 
PASSED

OutputVerifierTest > 
shouldFailIfKeyIsDifferentWithNullForCompareKeyValueTimestampWithProducerRecord()
 STARTED

OutputVerifierTest > 
shouldFailIfKeyIsDifferentWithNullForCompareKeyValueTimestampWithProducerRecord()
 PASSED

OutputVerifierTest > shouldFailIfValueIsDifferentForCompareKeyValueTimestamp() 
STARTED

OutputVerifierTest > shouldFailIfValueIsDifferentForCompareKeyValueTimestamp() 
PASSED

OutputVerifierTest > 
shouldPassIfValueAndTimestampIsEqualForCompareValueTimestampWithProducerRecord()
 STARTED

OutputVerifierTest > 
shouldPassIfValueAndTimestampIsEqualForCompareValueTimestampWithProducerRecord()
 PASSED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullReversForCompareKeyValueTimestamp() STARTED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullReversForCompareKeyValueTimestamp() PASSED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullReverseForCompareValueTimestampWithProducerRecord()
 STARTED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullReverseForCompareValueTimestampWithProducerRecord()
 PASSED

KeyValueStoreFacadeTest > shouldReturnIsOpen() STARTED

KeyValueStoreFacadeTest > shouldReturnIsOpen() PASSED

KeyValueStoreFacadeTest > shouldDeleteAndReturnPlainValue() STARTED

KeyValueStoreFacadeTest > shouldDeleteAndReturnPlainValue() PASSED

KeyValueStoreFacadeTest > shouldReturnName() STARTED

KeyValueStoreFacadeTest > shouldReturnName() PASSED

KeyValueStoreFacadeTest > shouldPutWithUnknownTimestamp() STARTED

KeyValueStoreFacadeTest > shouldPutWithUnknownTimestamp() PASSED

KeyValueStoreFacadeTest > shouldPutAllWithUnknownTimestamp() STARTED

KeyValueStoreFacadeTest > shouldPutAllWithUnknownTimestamp() PASSED

KeyValueStoreFacadeTest > shouldReturnIsPersistent() STARTED

KeyValueStoreFacadeTest > shouldReturnIsPersistent() PASSED

KeyValueStoreFacadeTest > shouldForwardDeprecatedInit() STARTED

KeyValueStoreFacadeTest > shouldForwardDeprecatedInit() PASSED

KeyValueStoreFacadeTest > shouldPutIfAbsentWithUnknownTimestamp() STARTED

KeyValueStoreFacadeTest > shouldPutIfAbsentWithUnknownTimestamp() PASSED

KeyValueStoreFacadeTest > shouldForwardClose() STARTED

KeyValueStoreFacadeTest > shouldForwardClose() PASSED

KeyValueStoreFacadeTest > shouldForwardFlush() STARTED

KeyValueStoreFacadeTest > shouldForwardFlush() PASSED

KeyValueStoreFacadeTest > shouldForwardInit() STARTED

KeyValueStoreFacadeTest > shouldForwardInit() PASSED

> Task :streams:upgrade-system-tests-0100:compileJava NO-SOURCE
> Task :streams:upgrade-system-tests-0100:processResources NO-SOURCE
> Task :streams:upgrade-system-tests-0100:classes UP-TO-DATE
> Task :streams:upgrade-system-tests-0100:checkstyleMain NO-SOURCE
> Task :streams:upgrade-system-tests-0100:compileTestJava
> Task :streams:upgrade-system-tests-0100:processTestResources NO-SOURCE
> Task :streams:upgrade-system-tests-0100:testClasses
> Task :streams:upgrade-system-tests-0100:checkstyleTest
> Task :streams:upgrade-system-tests-0100:spotbugsMain NO-SOURCE
> Task :streams:upgrade-system-tests-0100:test
> Task :streams:upgrade-system-tests-0101:compileJava NO-SOURCE
> Task :streams:upgrade-system-tests-0101:processResources NO-SOURCE
> Task :streams:upgrade-system-tests-0101:classes UP-TO-DATE
> Task :streams:upgrade-system-tests-0101:checkstyleMain NO-SOURCE
> Task :streams:upgrade-system-tests-0101:compileTestJava
> Task :streams:upgrade-syst

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

2021-01-14 Thread Apache Jenkins Server 
See 


Changes:

[github] MINOR: replace NotLeaderForPartitionException with 
NotLeaderOrFollowerException (#9885)

[github] MINOR: Updating files with release 2.6.1 (#9844)

[github] MINOR: Make JUnit 5 the default for new projects (#9882)


--
[...truncated 3.67 MB...]

TestTopicsTest > testKeyValueListDuration() PASSED

TestTopicsTest > testInputToString() STARTED

TestTopicsTest > testInputToString() PASSED

TestTopicsTest > testTimestamp() STARTED

TestTopicsTest > testTimestamp() PASSED

TestTopicsTest > testWithHeaders() STARTED

TestTopicsTest > testWithHeaders() PASSED

TestTopicsTest > testKeyValue() STARTED

TestTopicsTest > testKeyValue() PASSED

TestTopicsTest > shouldNotAllowToCreateTopicWithNullTopicName() STARTED

TestTopicsTest > shouldNotAllowToCreateTopicWithNullTopicName() PASSED

TopologyTestDriverEosTest > shouldReturnCorrectPersistentStoreTypeOnly() PASSED

TopologyTestDriverEosTest > shouldRespectTaskIdling() STARTED

TopologyTestDriverEosTest > shouldRespectTaskIdling() PASSED

TopologyTestDriverEosTest > shouldUseSourceSpecificDeserializers() STARTED

TopologyTestDriverEosTest > shouldUseSourceSpecificDeserializers() PASSED

TopologyTestDriverEosTest > shouldReturnAllStores() STARTED

TopologyTestDriverEosTest > shouldReturnAllStores() PASSED

TopologyTestDriverEosTest > shouldNotCreateStateDirectoryForStatelessTopology() 
STARTED

TopologyTestDriverEosTest > shouldNotCreateStateDirectoryForStatelessTopology() 
PASSED

TopologyTestDriverEosTest > 
shouldApplyGlobalUpdatesCorrectlyInRecursiveTopologies() STARTED

TopologyTestDriverEosTest > 
shouldApplyGlobalUpdatesCorrectlyInRecursiveTopologies() PASSED

TopologyTestDriverEosTest > shouldReturnAllStoresNames() STARTED

TopologyTestDriverEosTest > shouldReturnAllStoresNames() PASSED

TopologyTestDriverEosTest > 
shouldPassRecordHeadersIntoSerializersAndDeserializers() STARTED

TopologyTestDriverEosTest > 
shouldPassRecordHeadersIntoSerializersAndDeserializers() PASSED

TopologyTestDriverEosTest > shouldProcessConsumerRecordList() STARTED

TopologyTestDriverEosTest > shouldProcessConsumerRecordList() PASSED

TopologyTestDriverEosTest > shouldUseSinkSpecificSerializers() STARTED

TopologyTestDriverEosTest > shouldUseSinkSpecificSerializers() PASSED

TopologyTestDriverEosTest > shouldFlushStoreForFirstInput() STARTED

TopologyTestDriverEosTest > shouldFlushStoreForFirstInput() PASSED

TopologyTestDriverEosTest > shouldProcessFromSourceThatMatchPattern() STARTED

TopologyTestDriverEosTest > shouldProcessFromSourceThatMatchPattern() PASSED

TopologyTestDriverEosTest > shouldCaptureSinkTopicNamesIfWrittenInto() STARTED

TopologyTestDriverEosTest > shouldCaptureSinkTopicNamesIfWrittenInto() PASSED

TopologyTestDriverEosTest > shouldUpdateStoreForNewKey() STARTED

TopologyTestDriverEosTest > shouldUpdateStoreForNewKey() PASSED

TopologyTestDriverEosTest > shouldSendRecordViaCorrectSourceTopicDeprecated() 
STARTED

TopologyTestDriverEosTest > shouldSendRecordViaCorrectSourceTopicDeprecated() 
PASSED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTime() STARTED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTime() PASSED

TopologyTestDriverEosTest > shouldSetRecordMetadata() STARTED

TopologyTestDriverEosTest > shouldSetRecordMetadata() PASSED

TopologyTestDriverEosTest > shouldNotUpdateStoreForLargerValue() STARTED

TopologyTestDriverEosTest > shouldNotUpdateStoreForLargerValue() PASSED

TopologyTestDriverEosTest > shouldReturnCorrectInMemoryStoreTypeOnly() STARTED

TopologyTestDriverEosTest > shouldReturnCorrectInMemoryStoreTypeOnly() PASSED

TopologyTestDriverEosTest > shouldThrowForMissingTime() STARTED

TopologyTestDriverEosTest > shouldThrowForMissingTime() PASSED

TopologyTestDriverEosTest > shouldCaptureInternalTopicNamesIfWrittenInto() 
STARTED

TopologyTestDriverEosTest > shouldCaptureInternalTopicNamesIfWrittenInto() 
PASSED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTimeDeprecated() STARTED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTimeDeprecated() PASSED

TopologyTestDriverEosTest > shouldProcessRecordForTopic() STARTED

TopologyTestDriverEosTest > shouldProcessRecordForTopic() PASSED

TopologyTestDriverEosTest > shouldForwardRecordsFromSubtopologyToSubtopology() 
STARTED

TopologyTestDriverEosTest > shouldForwardRecordsFromSubtopologyToSubtopology() 
PASSED

TopologyTestDriverEosTest > shouldNotUpdateStoreForSmallerValue() STARTED

TopologyTestDriverEosTest > shouldNotUpdateStoreForSmallerValue() PASSED

TopologyTestDriverEosTest > shouldCreateStateDirectoryForStatefulTopology() 
STARTED

TopologyTestDriverEosTest > shouldCreateStateDirectoryForStatefulTopology() 
PASSED

TopologyTestDriverEosTest > shouldNotRequireParameters() STARTED

TopologyTestDriverEosTest > shouldNotRequireParameters() PASSED

TopologyTestDriverEosTest > shouldPunctuateIfWallClock

[jira] [Created] (KAFKA-12204) Implement DescribeCluster API on the broker

2021-01-14 Thread David Jacot (Jira) 
David Jacot created KAFKA-12204:
---

 Summary: Implement DescribeCluster API on the broker
 Key: KAFKA-12204
 URL: https://issues.apache.org/jira/browse/KAFKA-12204
 Project: Kafka
  Issue Type: Sub-task
Reporter: David Jacot
Assignee: David Jacot






--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Created] (KAFKA-12205) Delete snapshots if it's end offset is less than the log start offset

2021-01-14 Thread Jose Armando Garcia Sancio (Jira) 
Jose Armando Garcia Sancio created KAFKA-12205:
--

 Summary: Delete snapshots if it's end offset is less than the log 
start offset
 Key: KAFKA-12205
 URL: https://issues.apache.org/jira/browse/KAFKA-12205
 Project: Kafka
  Issue Type: Sub-task
  Components: replication
Reporter: Jose Armando Garcia Sancio






--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Created] (KAFKA-12206) o.a.k.common.Uuid should implement Comparable

2021-01-14 Thread Colin McCabe (Jira) 
Colin McCabe created KAFKA-12206:


 Summary: o.a.k.common.Uuid should implement Comparable 
 Key: KAFKA-12206
 URL: https://issues.apache.org/jira/browse/KAFKA-12206
 Project: Kafka
  Issue Type: Improvement
Reporter: Colin McCabe






--
This message was sent by Atlassian Jira
(v8.3.4#803005)

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

2021-01-14 Thread Apache Jenkins Server 
See 


Changes:

[github] MINOR: Fix typo in `shouldUseJUnit5` in build.gradle (#9893)

[github] KAFKA-10304: Refactor MM2 integration tests (#9224)


--
[...truncated 3.65 MB...]
TopologyTestDriverEosTest > 
shouldThrowIfInMemoryBuiltInStoreIsAccessedWithUntypedMethod() PASSED

TopologyTestDriverEosTest > shouldProcessFromSourcesThatMatchMultiplePattern() 
STARTED

TopologyTestDriverEosTest > shouldProcessFromSourcesThatMatchMultiplePattern() 
PASSED

TopologyTestDriverEosTest > shouldPopulateGlobalStore() STARTED

TopologyTestDriverEosTest > shouldPopulateGlobalStore() PASSED

TopologyTestDriverEosTest > 
shouldThrowIfPersistentBuiltInStoreIsAccessedWithUntypedMethod() STARTED

TopologyTestDriverEosTest > 
shouldThrowIfPersistentBuiltInStoreIsAccessedWithUntypedMethod() PASSED

TopologyTestDriverEosTest > 
shouldAllowPrePopulatingStatesStoresWithCachingEnabled() STARTED

TopologyTestDriverEosTest > 
shouldAllowPrePopulatingStatesStoresWithCachingEnabled() PASSED

TopologyTestDriverEosTest > shouldReturnCorrectPersistentStoreTypeOnly() STARTED

TopologyTestDriverEosTest > shouldReturnCorrectPersistentStoreTypeOnly() PASSED

TopologyTestDriverEosTest > shouldRespectTaskIdling() STARTED

TopologyTestDriverEosTest > shouldRespectTaskIdling() PASSED

TopologyTestDriverEosTest > shouldUseSourceSpecificDeserializers() STARTED

TopologyTestDriverEosTest > shouldUseSourceSpecificDeserializers() PASSED

TopologyTestDriverEosTest > shouldReturnAllStores() STARTED

TopologyTestDriverEosTest > shouldReturnAllStores() PASSED

TopologyTestDriverEosTest > shouldNotCreateStateDirectoryForStatelessTopology() 
STARTED

TopologyTestDriverEosTest > shouldNotCreateStateDirectoryForStatelessTopology() 
PASSED

TopologyTestDriverEosTest > 
shouldApplyGlobalUpdatesCorrectlyInRecursiveTopologies() STARTED

TopologyTestDriverEosTest > 
shouldApplyGlobalUpdatesCorrectlyInRecursiveTopologies() PASSED

TopologyTestDriverEosTest > shouldReturnAllStoresNames() STARTED

TopologyTestDriverEosTest > shouldReturnAllStoresNames() PASSED

TopologyTestDriverEosTest > 
shouldPassRecordHeadersIntoSerializersAndDeserializers() STARTED

TopologyTestDriverEosTest > 
shouldPassRecordHeadersIntoSerializersAndDeserializers() PASSED

TopologyTestDriverEosTest > shouldProcessConsumerRecordList() STARTED

TopologyTestDriverEosTest > shouldProcessConsumerRecordList() PASSED

TopologyTestDriverEosTest > shouldUseSinkSpecificSerializers() STARTED

TopologyTestDriverEosTest > shouldUseSinkSpecificSerializers() PASSED

TopologyTestDriverEosTest > shouldFlushStoreForFirstInput() STARTED

TopologyTestDriverEosTest > shouldFlushStoreForFirstInput() PASSED

TopologyTestDriverEosTest > shouldProcessFromSourceThatMatchPattern() STARTED

TopologyTestDriverEosTest > shouldProcessFromSourceThatMatchPattern() PASSED

TopologyTestDriverEosTest > shouldCaptureSinkTopicNamesIfWrittenInto() STARTED

TopologyTestDriverEosTest > shouldCaptureSinkTopicNamesIfWrittenInto() PASSED

TopologyTestDriverEosTest > shouldUpdateStoreForNewKey() STARTED

TopologyTestDriverEosTest > shouldUpdateStoreForNewKey() PASSED

TopologyTestDriverEosTest > shouldSendRecordViaCorrectSourceTopicDeprecated() 
STARTED

TopologyTestDriverEosTest > shouldSendRecordViaCorrectSourceTopicDeprecated() 
PASSED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTime() STARTED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTime() PASSED

TopologyTestDriverEosTest > shouldSetRecordMetadata() STARTED

TopologyTestDriverEosTest > shouldSetRecordMetadata() PASSED

TopologyTestDriverEosTest > shouldNotUpdateStoreForLargerValue() STARTED

TopologyTestDriverEosTest > shouldNotUpdateStoreForLargerValue() PASSED

TopologyTestDriverEosTest > shouldReturnCorrectInMemoryStoreTypeOnly() STARTED

TopologyTestDriverEosTest > shouldReturnCorrectInMemoryStoreTypeOnly() PASSED

TopologyTestDriverEosTest > shouldThrowForMissingTime() STARTED

TopologyTestDriverEosTest > shouldThrowForMissingTime() PASSED

TopologyTestDriverEosTest > shouldCaptureInternalTopicNamesIfWrittenInto() 
STARTED

TopologyTestDriverEosTest > shouldCaptureInternalTopicNamesIfWrittenInto() 
PASSED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTimeDeprecated() STARTED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTimeDeprecated() PASSED

TopologyTestDriverEosTest > shouldProcessRecordForTopic() STARTED

TopologyTestDriverEosTest > shouldProcessRecordForTopic() PASSED

TopologyTestDriverEosTest > shouldForwardRecordsFromSubtopologyToSubtopology() 
STARTED

TopologyTestDriverEosTest > shouldForwardRecordsFromSubtopologyToSubtopology() 
PASSED

TopologyTestDriverEosTest > shouldNotUpdateStoreForSmallerValue() STARTED

TopologyTestDriverEosTest > shouldNotUpdateStoreForSmallerValue() PASSED

TopologyTestDriverEosTest > shouldCreateStateDirectoryForStatefulTopology() 
STARTED

TopologyTestDriverEo

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

2021-01-14 Thread Apache Jenkins Server 
See 


Changes:

[github] MINOR: Make JUnit 5 the default for new projects (#9882)

[github] MINOR: Fix typo in `shouldUseJUnit5` in build.gradle (#9893)

[github] KAFKA-10304: Refactor MM2 integration tests (#9224)


--
[...truncated 3.67 MB...]

TestTopicsTest > testNonUsedOutputTopic() STARTED

TestTopicsTest > testNonUsedOutputTopic() PASSED

TestTopicsTest > testEmptyTopic() STARTED

TestTopicsTest > testEmptyTopic() PASSED

TestTopicsTest > testStartTimestamp() STARTED

TestTopicsTest > testStartTimestamp() PASSED

TestTopicsTest > testNegativeAdvance() STARTED

TestTopicsTest > testNegativeAdvance() PASSED

TestTopicsTest > shouldNotAllowToCreateWithNullDriver() STARTED

TestTopicsTest > shouldNotAllowToCreateWithNullDriver() PASSED

TestTopicsTest > testDuration() STARTED

TestTopicsTest > testDuration() PASSED

TestTopicsTest > testOutputToString() STARTED

TestTopicsTest > testOutputToString() PASSED

TestTopicsTest > testValue() STARTED

TestTopicsTest > testValue() PASSED

TestTopicsTest > testTimestampAutoAdvance() STARTED

TestTopicsTest > testTimestampAutoAdvance() PASSED

TestTopicsTest > testOutputWrongSerde() STARTED

TestTopicsTest > testOutputWrongSerde() PASSED

TestTopicsTest > shouldNotAllowToCreateOutputTopicWithNullTopicName() STARTED

TestTopicsTest > shouldNotAllowToCreateOutputTopicWithNullTopicName() PASSED

TestTopicsTest > testWrongSerde() STARTED

TestTopicsTest > testWrongSerde() PASSED

TestTopicsTest > testKeyValuesToMapWithNull() STARTED

TestTopicsTest > testKeyValuesToMapWithNull() PASSED

TestTopicsTest > testNonExistingOutputTopic() STARTED

TestTopicsTest > testNonExistingOutputTopic() PASSED

TestTopicsTest > testMultipleTopics() STARTED

TestTopicsTest > testMultipleTopics() PASSED

TestTopicsTest > testKeyValueList() STARTED

TestTopicsTest > testKeyValueList() PASSED

TestTopicsTest > shouldNotAllowToCreateOutputWithNullDriver() STARTED

TestTopicsTest > shouldNotAllowToCreateOutputWithNullDriver() PASSED

TestTopicsTest > testValueList() STARTED

TestTopicsTest > testValueList() PASSED

TestTopicsTest > testRecordList() STARTED

TestTopicsTest > testRecordList() PASSED

TestTopicsTest > testNonExistingInputTopic() STARTED

TestTopicsTest > testNonExistingInputTopic() PASSED

TestTopicsTest > testKeyValuesToMap() STARTED

TestTopicsTest > testKeyValuesToMap() PASSED

TestTopicsTest > testRecordsToList() STARTED

TestTopicsTest > testRecordsToList() PASSED

TestTopicsTest > testKeyValueListDuration() STARTED

TestTopicsTest > testKeyValueListDuration() PASSED

TestTopicsTest > testInputToString() STARTED

TestTopicsTest > testInputToString() PASSED

TestTopicsTest > testTimestamp() STARTED

TestTopicsTest > testTimestamp() PASSED

TestTopicsTest > testWithHeaders() STARTED

TestTopicsTest > testWithHeaders() PASSED

TestTopicsTest > testKeyValue() STARTED

TestTopicsTest > testKeyValue() PASSED

TestTopicsTest > shouldNotAllowToCreateTopicWithNullTopicName() STARTED

TestTopicsTest > shouldNotAllowToCreateTopicWithNullTopicName() PASSED

> Task :streams:upgrade-system-tests-10:spotbugsMain NO-SOURCE
> Task :streams:upgrade-system-tests-10:test
> Task :streams:upgrade-system-tests-11:compileJava NO-SOURCE
> Task :streams:upgrade-system-tests-11:processResources NO-SOURCE
> Task :streams:upgrade-system-tests-11:classes UP-TO-DATE
> Task :streams:upgrade-system-tests-11:checkstyleMain NO-SOURCE
> Task :streams:upgrade-system-tests-11:compileTestJava
> Task :streams:upgrade-system-tests-11:processTestResources NO-SOURCE
> Task :streams:upgrade-system-tests-11:testClasses
> Task :streams:upgrade-system-tests-11:checkstyleTest
> Task :streams:upgrade-system-tests-11:spotbugsMain NO-SOURCE
> Task :streams:upgrade-system-tests-11:test
> Task :streams:upgrade-system-tests-20:compileJava NO-SOURCE
> Task :streams:upgrade-system-tests-20:processResources NO-SOURCE
> Task :streams:upgrade-system-tests-20:classes UP-TO-DATE
> Task :streams:upgrade-system-tests-20:checkstyleMain NO-SOURCE
> Task :streams:upgrade-system-tests-20:compileTestJava
> Task :streams:upgrade-system-tests-20:processTestResources NO-SOURCE
> Task :streams:upgrade-system-tests-20:testClasses
> Task :streams:upgrade-system-tests-20:checkstyleTest
> Task :streams:upgrade-system-tests-20:spotbugsMain NO-SOURCE
> Task :streams:upgrade-system-tests-20:test
> Task :streams:upgrade-system-tests-21:compileJava NO-SOURCE
> Task :streams:upgrade-system-tests-21:processResources NO-SOURCE
> Task :streams:upgrade-system-tests-21:classes UP-TO-DATE
> Task :streams:upgrade-system-tests-21:checkstyleMain NO-SOURCE
> Task :streams:upgrade-system-tests-21:compileTestJava
> Task :streams:upgrade-system-tests-21:processTestResources NO-SOURCE
> Task :streams:upgrade-system-tests-21:testClasses
> Task :streams:upgrade-system-tests-21:checkstyleTest
> Task :streams:upgrade-system-tests-21:sp

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

2021-01-14 Thread Apache Jenkins Server 
See 


Changes:

[github] MINOR: Make JUnit 5 the default for new projects (#9882)

[github] MINOR: Fix typo in `shouldUseJUnit5` in build.gradle (#9893)

[github] KAFKA-10304: Refactor MM2 integration tests (#9224)


--
[...truncated 3.63 MB...]
TopologyTestDriverAtLeastOnceTest > shouldInitProcessor() PASSED

TopologyTestDriverAtLeastOnceTest > shouldThrowForUnknownTopic() STARTED

TopologyTestDriverAtLeastOnceTest > shouldThrowForUnknownTopic() PASSED

TopologyTestDriverAtLeastOnceTest > shouldPunctuateOnStreamsTime() STARTED

TopologyTestDriverAtLeastOnceTest > shouldPunctuateOnStreamsTime() PASSED

TopologyTestDriverAtLeastOnceTest > shouldCaptureGlobalTopicNameIfWrittenInto() 
STARTED

TopologyTestDriverAtLeastOnceTest > shouldCaptureGlobalTopicNameIfWrittenInto() 
PASSED

TopologyTestDriverAtLeastOnceTest > 
shouldThrowIfInMemoryBuiltInStoreIsAccessedWithUntypedMethod() STARTED

TopologyTestDriverAtLeastOnceTest > 
shouldThrowIfInMemoryBuiltInStoreIsAccessedWithUntypedMethod() PASSED

TopologyTestDriverAtLeastOnceTest > 
shouldProcessFromSourcesThatMatchMultiplePattern() STARTED

TopologyTestDriverAtLeastOnceTest > 
shouldProcessFromSourcesThatMatchMultiplePattern() PASSED

TopologyTestDriverAtLeastOnceTest > shouldPopulateGlobalStore() STARTED

TopologyTestDriverAtLeastOnceTest > shouldPopulateGlobalStore() PASSED

TopologyTestDriverAtLeastOnceTest > 
shouldThrowIfPersistentBuiltInStoreIsAccessedWithUntypedMethod() STARTED

TopologyTestDriverAtLeastOnceTest > 
shouldThrowIfPersistentBuiltInStoreIsAccessedWithUntypedMethod() PASSED

TopologyTestDriverAtLeastOnceTest > 
shouldAllowPrePopulatingStatesStoresWithCachingEnabled() STARTED

TopologyTestDriverAtLeastOnceTest > 
shouldAllowPrePopulatingStatesStoresWithCachingEnabled() PASSED

TopologyTestDriverAtLeastOnceTest > 
shouldReturnCorrectPersistentStoreTypeOnly() STARTED

TopologyTestDriverAtLeastOnceTest > 
shouldReturnCorrectPersistentStoreTypeOnly() PASSED

TopologyTestDriverAtLeastOnceTest > shouldRespectTaskIdling() STARTED

TopologyTestDriverAtLeastOnceTest > shouldRespectTaskIdling() PASSED

TopologyTestDriverAtLeastOnceTest > shouldUseSourceSpecificDeserializers() 
STARTED

TopologyTestDriverAtLeastOnceTest > shouldUseSourceSpecificDeserializers() 
PASSED

TopologyTestDriverAtLeastOnceTest > shouldReturnAllStores() STARTED

TopologyTestDriverAtLeastOnceTest > shouldReturnAllStores() PASSED

TopologyTestDriverAtLeastOnceTest > 
shouldNotCreateStateDirectoryForStatelessTopology() STARTED

TopologyTestDriverAtLeastOnceTest > 
shouldNotCreateStateDirectoryForStatelessTopology() PASSED

TopologyTestDriverAtLeastOnceTest > 
shouldApplyGlobalUpdatesCorrectlyInRecursiveTopologies() STARTED

TopologyTestDriverAtLeastOnceTest > 
shouldApplyGlobalUpdatesCorrectlyInRecursiveTopologies() PASSED

TopologyTestDriverAtLeastOnceTest > shouldReturnAllStoresNames() STARTED

TopologyTestDriverAtLeastOnceTest > shouldReturnAllStoresNames() PASSED

TopologyTestDriverAtLeastOnceTest > 
shouldPassRecordHeadersIntoSerializersAndDeserializers() STARTED

TopologyTestDriverAtLeastOnceTest > 
shouldPassRecordHeadersIntoSerializersAndDeserializers() PASSED

TopologyTestDriverAtLeastOnceTest > shouldProcessConsumerRecordList() STARTED

TopologyTestDriverAtLeastOnceTest > shouldProcessConsumerRecordList() PASSED

TopologyTestDriverAtLeastOnceTest > shouldUseSinkSpecificSerializers() STARTED

TopologyTestDriverAtLeastOnceTest > shouldUseSinkSpecificSerializers() PASSED

TopologyTestDriverAtLeastOnceTest > shouldFlushStoreForFirstInput() STARTED

TopologyTestDriverAtLeastOnceTest > shouldFlushStoreForFirstInput() PASSED

TopologyTestDriverAtLeastOnceTest > shouldProcessFromSourceThatMatchPattern() 
STARTED

TopologyTestDriverAtLeastOnceTest > shouldProcessFromSourceThatMatchPattern() 
PASSED

TopologyTestDriverAtLeastOnceTest > shouldCaptureSinkTopicNamesIfWrittenInto() 
STARTED

TopologyTestDriverAtLeastOnceTest > shouldCaptureSinkTopicNamesIfWrittenInto() 
PASSED

TopologyTestDriverAtLeastOnceTest > shouldUpdateStoreForNewKey() STARTED

TopologyTestDriverAtLeastOnceTest > shouldUpdateStoreForNewKey() PASSED

TopologyTestDriverAtLeastOnceTest > 
shouldSendRecordViaCorrectSourceTopicDeprecated() STARTED

TopologyTestDriverAtLeastOnceTest > 
shouldSendRecordViaCorrectSourceTopicDeprecated() PASSED

TopologyTestDriverAtLeastOnceTest > shouldPunctuateOnWallClockTime() STARTED

TopologyTestDriverAtLeastOnceTest > shouldPunctuateOnWallClockTime() PASSED

TopologyTestDriverAtLeastOnceTest > shouldSetRecordMetadata() STARTED

TopologyTestDriverAtLeastOnceTest > shouldSetRecordMetadata() PASSED

TopologyTestDriverAtLeastOnceTest > shouldNotUpdateStoreForLargerValue() STARTED

TopologyTestDriverAtLeastOnceTest > shouldNotUpdateStoreForLargerValue() PASSED

TopologyTestDriverAtLeastOnceTest > shouldReturnCorrectInMemoryStoreTypeOnly() 
STARTED

Topolo

[jira] [Created] (KAFKA-12207) Do not maintain list of latest producer append information

2021-01-14 Thread Jason Gustafson (Jira) 
Jason Gustafson created KAFKA-12207:
---

 Summary: Do not maintain list of latest producer append 
information 
 Key: KAFKA-12207
 URL: https://issues.apache.org/jira/browse/KAFKA-12207
 Project: Kafka
  Issue Type: Bug
Reporter: Jason Gustafson


For each producerId writing to each partition, we maintain a list of the 5 most 
recent appended sequence numbers and the corresponding offsets in the log. If a 
producer fails to receive a successful response and retries the Produce 
request, then we can still return the offset of the successful append, which is 
returned to the user inside `RecordMetadata`. (Note that the limit of 5 most 
recent appends is where we derive the limit on the max number of inflight 
requests that the producer is allowed when idempotence is enabled.)

This is only a "best-effort" attempt to return the offset of the append. For 
example, we do not populate the full list of recent appends when the log is 
reloaded. Only the latest sequence/offset are reloaded from the snapshot. If we 
receive a duplicate and we do not have the offset, then the broker currently 
handles this by returning OUT_OF_ORDER_SEQUENCE.

In fact, we have a separate error DUPLICATE_SEQUENCE_NUMBER which was intended 
to handle this case and the producer already checks for it. If the producer 
sees this error in the response, then the `send` is considered successful, but 
the producer returns -1 as both the offset and timestamp inside 
`RecordMetadata`.

The reason we never implemented this on the broker is probably because we allow 
the sequence numbers of the producer to wrap around after reaching 
Int.MaxValue. What we considered in the past is fixing a number like 1000 and 
requiring that the sequence be within that range to be considered a duplicate. 
A better solution going forward is to let the producer bump the epoch when the 
sequence hits Int.MaxValue, but we still have to allow sequence numbers to wrap 
for compatibility.

Given the loose guarantees that we already have here, I'm considering whether 
the additional bookkeeping and the required memory are worth preserving. As an 
alternative, we could consider the following:

1. The broker will only maintain the latest sequence/offset for each producerId
2. We will return DUPLICATE_SEQUENCE_NUMBER for any sequence that is within 
1000 of the latest sequence (accounting for overflow). 
3. Instead of wrapping around sequence numbers, the producer will bump the 
epoch if possible. It's worth noting that the idempotent producer can freely 
bump the epoch, so the only time we should ever need to wrap the sequence is 
for the transactional producer when it is used on a broker which does not 
support the `InitProducerId` version which allows epoch bumps.
4. We can remove the restriction on `max.in.flight.requests.per.connection` and 
document that if the offset is required in `RecordMetadata`, then the user must 
set this to 1. Internally, if connecting to an old broker which does not 
support epoch bumps, then we can restrict the number of inflight requests to 5.

The benefit in the end is that we can reduce the memory usage for producer 
state and the complexity to manage that state. It also gives us a path to 
removing the annoying config restriction and a better policy for sequence 
overflow.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Re: [DISCUSS] KIP-697: Stricter parsing of addresses in configs

2021-01-14 Thread Gwen Shapira 
Sorry for being late, I just saw this. I have a concern about the
compatibility story:

1. Do we know how common use of protocol is? While this is an
improvement, the benefits are a bit small (IMO) and if this will break
a large number of installations (or will make the upgrade to 3.0 more
painful and therefore less likely to happen) - maybe it is't worth it.
2. Should we add a PR to 2.8 that will print deprecation warnings if
protocol is used? This way people will at least know what is coming.

Gwen

On Mon, Jan 4, 2021 at 1:21 AM Tom Bentley  wrote:
>
> Hi,
>
> If there are no comments about this minor change in the next day or two I
> will start a vote.
>
> Kind regards,
>
> Tom
>
> On Wed, Dec 9, 2020 at 6:10 PM Tom Bentley  wrote:
>
> > Hi,
> >
> > I'd like to start a discussion on a small KIP which proposes stricter
> > parsing of host:port addresses in various configs for Kafka 3.0:
> >
> >
> > https://cwiki.apache.org/confluence/display/KAFKA/KIP-697%3A+Stricter+parsing+of+addresses+in+configs
> >
> > I'd be grateful for any feedback people may have.
> >
> > Kind regards,
> >
> > Tom
> >



-- 
Gwen Shapira
Engineering Manager | Confluent
650.450.2760 | @gwenshap
Follow us: Twitter | blog

[jira] [Created] (KAFKA-12208) Rename AdminManager to ZkAdminManager

2021-01-14 Thread Colin McCabe (Jira) 
Colin McCabe created KAFKA-12208:


 Summary: Rename AdminManager to ZkAdminManager
 Key: KAFKA-12208
 URL: https://issues.apache.org/jira/browse/KAFKA-12208
 Project: Kafka
  Issue Type: Improvement
Reporter: Colin McCabe






--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Resolved] (KAFKA-12183) Add the KIP-631 metadata record definitions

2021-01-14 Thread Colin McCabe (Jira) 


 [ 
https://issues.apache.org/jira/browse/KAFKA-12183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Colin McCabe resolved KAFKA-12183.
--
Fix Version/s: 2.8.0
   Resolution: Fixed

> Add the KIP-631 metadata record definitions
> ---
>
> Key: KAFKA-12183
> URL: https://issues.apache.org/jira/browse/KAFKA-12183
> Project: Kafka
>  Issue Type: Improvement
>Reporter: Colin McCabe
>Assignee: Colin McCabe
>Priority: Major
>  Labels: kip-500
> Fix For: 2.8.0
>
>
> Add the KIP-631 metadata record definitions



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Created] (KAFKA-12209) Add the timeline data structures for the KIP-631 controller

2021-01-14 Thread Colin McCabe (Jira) 
Colin McCabe created KAFKA-12209:


 Summary: Add the timeline data structures for the KIP-631 
controller
 Key: KAFKA-12209
 URL: https://issues.apache.org/jira/browse/KAFKA-12209
 Project: Kafka
  Issue Type: Improvement
Reporter: Colin McCabe






--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Resolved] (KAFKA-10896) TimeoutException when Producer try to send message to Kafka Broker

2021-01-14 Thread Nguyen Cong Hieu (Jira) 


 [ 
https://issues.apache.org/jira/browse/KAFKA-10896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Nguyen Cong Hieu resolved KAFKA-10896.
--
Resolution: Not A Bug

> TimeoutException when Producer try to send message to Kafka Broker
> --
>
> Key: KAFKA-10896
> URL: https://issues.apache.org/jira/browse/KAFKA-10896
> Project: Kafka
>  Issue Type: Bug
>  Components: clients, config
>Affects Versions: 2.6.0
>Reporter: Nguyen Cong Hieu
>Priority: Major
> Attachments: console_consumer.png, console_producer.png, 
> producerconfig.png, producercreate.png, serverconfig.png, 
> timeout_exception.png
>
>
> Dear All,
>  
> As I tried to setup new Kafka environment, even all work normally when I use 
> consumer and producer binaries that shipped with Kafka source together. 
>  
> However, when I ran small java application that create producer to send 
> message of a topic to broker, but it has timeout exception with the message 
> "Caused by: org.apache.kafka.common.errors.TimeoutException: Topic otp not 
> present in metadata after 6 ms."
>  
> I checked some confluence pages related to Kafka but could not resolved yet.
>  
> Please help me to resolve this as well ? and please see my file attachments 
> for more details about broker information and sample source code.
> Best regards.
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

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

2021-01-14 Thread Apache Jenkins Server 
See 


Changes:

[github] KAFKA-12183: Add the KIP-631 metadata record definitions (#9876)

[github] MINOR: fix typo in TimeIndex (#9834)


--
[...truncated 3.66 MB...]
TopologyTestDriverAtLeastOnceTest > shouldFlushStoreForFirstInput() PASSED

TopologyTestDriverAtLeastOnceTest > shouldProcessFromSourceThatMatchPattern() 
STARTED

TopologyTestDriverAtLeastOnceTest > shouldProcessFromSourceThatMatchPattern() 
PASSED

TopologyTestDriverAtLeastOnceTest > shouldCaptureSinkTopicNamesIfWrittenInto() 
STARTED

TopologyTestDriverAtLeastOnceTest > shouldCaptureSinkTopicNamesIfWrittenInto() 
PASSED

TopologyTestDriverAtLeastOnceTest > shouldUpdateStoreForNewKey() STARTED

TopologyTestDriverAtLeastOnceTest > shouldUpdateStoreForNewKey() PASSED

TopologyTestDriverAtLeastOnceTest > 
shouldSendRecordViaCorrectSourceTopicDeprecated() STARTED

TopologyTestDriverAtLeastOnceTest > 
shouldSendRecordViaCorrectSourceTopicDeprecated() PASSED

TopologyTestDriverAtLeastOnceTest > shouldPunctuateOnWallClockTime() STARTED

TopologyTestDriverAtLeastOnceTest > shouldPunctuateOnWallClockTime() PASSED

TopologyTestDriverAtLeastOnceTest > shouldSetRecordMetadata() STARTED

TopologyTestDriverAtLeastOnceTest > shouldSetRecordMetadata() PASSED

TopologyTestDriverAtLeastOnceTest > shouldNotUpdateStoreForLargerValue() STARTED

TopologyTestDriverAtLeastOnceTest > shouldNotUpdateStoreForLargerValue() PASSED

TopologyTestDriverAtLeastOnceTest > shouldReturnCorrectInMemoryStoreTypeOnly() 
STARTED

TopologyTestDriverAtLeastOnceTest > shouldReturnCorrectInMemoryStoreTypeOnly() 
PASSED

TopologyTestDriverAtLeastOnceTest > shouldThrowForMissingTime() STARTED

TopologyTestDriverAtLeastOnceTest > shouldThrowForMissingTime() PASSED

TopologyTestDriverAtLeastOnceTest > 
shouldCaptureInternalTopicNamesIfWrittenInto() STARTED

TopologyTestDriverAtLeastOnceTest > 
shouldCaptureInternalTopicNamesIfWrittenInto() PASSED

TopologyTestDriverAtLeastOnceTest > shouldPunctuateOnWallClockTimeDeprecated() 
STARTED

TopologyTestDriverAtLeastOnceTest > shouldPunctuateOnWallClockTimeDeprecated() 
PASSED

TopologyTestDriverAtLeastOnceTest > shouldProcessRecordForTopic() STARTED

TopologyTestDriverAtLeastOnceTest > shouldProcessRecordForTopic() PASSED

TopologyTestDriverAtLeastOnceTest > 
shouldForwardRecordsFromSubtopologyToSubtopology() STARTED

TopologyTestDriverAtLeastOnceTest > 
shouldForwardRecordsFromSubtopologyToSubtopology() PASSED

TopologyTestDriverAtLeastOnceTest > shouldNotUpdateStoreForSmallerValue() 
STARTED

TopologyTestDriverAtLeastOnceTest > shouldNotUpdateStoreForSmallerValue() PASSED

TopologyTestDriverAtLeastOnceTest > 
shouldCreateStateDirectoryForStatefulTopology() STARTED

TopologyTestDriverAtLeastOnceTest > 
shouldCreateStateDirectoryForStatefulTopology() PASSED

TopologyTestDriverAtLeastOnceTest > shouldNotRequireParameters() STARTED

TopologyTestDriverAtLeastOnceTest > shouldNotRequireParameters() PASSED

TopologyTestDriverAtLeastOnceTest > shouldPunctuateIfWallClockTimeAdvances() 
STARTED

TopologyTestDriverAtLeastOnceTest > shouldPunctuateIfWallClockTimeAdvances() 
PASSED

MockTimeTest > shouldGetNanosAsMillis() STARTED

MockTimeTest > shouldGetNanosAsMillis() PASSED

MockTimeTest > shouldSetStartTime() STARTED

MockTimeTest > shouldSetStartTime() PASSED

MockTimeTest > shouldNotAllowNegativeSleep() STARTED

MockTimeTest > shouldNotAllowNegativeSleep() PASSED

MockTimeTest > shouldAdvanceTimeOnSleep() STARTED

MockTimeTest > shouldAdvanceTimeOnSleep() PASSED

KeyValueStoreFacadeTest > shouldReturnIsOpen() STARTED

KeyValueStoreFacadeTest > shouldReturnIsOpen() PASSED

KeyValueStoreFacadeTest > shouldDeleteAndReturnPlainValue() STARTED

KeyValueStoreFacadeTest > shouldDeleteAndReturnPlainValue() PASSED

KeyValueStoreFacadeTest > shouldReturnName() STARTED

KeyValueStoreFacadeTest > shouldReturnName() PASSED

KeyValueStoreFacadeTest > shouldPutWithUnknownTimestamp() STARTED

KeyValueStoreFacadeTest > shouldPutWithUnknownTimestamp() PASSED

KeyValueStoreFacadeTest > shouldPutAllWithUnknownTimestamp() STARTED

KeyValueStoreFacadeTest > shouldPutAllWithUnknownTimestamp() PASSED

KeyValueStoreFacadeTest > shouldReturnIsPersistent() STARTED

KeyValueStoreFacadeTest > shouldReturnIsPersistent() PASSED

KeyValueStoreFacadeTest > shouldForwardDeprecatedInit() STARTED

KeyValueStoreFacadeTest > shouldForwardDeprecatedInit() PASSED

KeyValueStoreFacadeTest > shouldPutIfAbsentWithUnknownTimestamp() STARTED

KeyValueStoreFacadeTest > shouldPutIfAbsentWithUnknownTimestamp() PASSED

KeyValueStoreFacadeTest > shouldForwardClose() STARTED

KeyValueStoreFacadeTest > shouldForwardClose() PASSED

KeyValueStoreFacadeTest > shouldForwardFlush() STARTED

KeyValueStoreFacadeTest > shouldForwardFlush() PASSED

KeyValueStoreFacadeTest > shouldForwardInit() STARTED

KeyValueStoreFacadeTest > shouldForwardInit() PASSED

> Task :streams:u

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

2021-01-14 Thread Apache Jenkins Server 
See 


Changes:

[github] KAFKA-12183: Add the KIP-631 metadata record definitions (#9876)

[github] MINOR: fix typo in TimeIndex (#9834)


--
[...truncated 3.65 MB...]
TopologyTestDriverEosTest > 
shouldThrowIfInMemoryBuiltInStoreIsAccessedWithUntypedMethod() PASSED

TopologyTestDriverEosTest > shouldProcessFromSourcesThatMatchMultiplePattern() 
STARTED

TopologyTestDriverEosTest > shouldProcessFromSourcesThatMatchMultiplePattern() 
PASSED

TopologyTestDriverEosTest > shouldPopulateGlobalStore() STARTED

TopologyTestDriverEosTest > shouldPopulateGlobalStore() PASSED

TopologyTestDriverEosTest > 
shouldThrowIfPersistentBuiltInStoreIsAccessedWithUntypedMethod() STARTED

TopologyTestDriverEosTest > 
shouldThrowIfPersistentBuiltInStoreIsAccessedWithUntypedMethod() PASSED

TopologyTestDriverEosTest > 
shouldAllowPrePopulatingStatesStoresWithCachingEnabled() STARTED

TopologyTestDriverEosTest > 
shouldAllowPrePopulatingStatesStoresWithCachingEnabled() PASSED

TopologyTestDriverEosTest > shouldReturnCorrectPersistentStoreTypeOnly() STARTED

TopologyTestDriverEosTest > shouldReturnCorrectPersistentStoreTypeOnly() PASSED

TopologyTestDriverEosTest > shouldRespectTaskIdling() STARTED

TopologyTestDriverEosTest > shouldRespectTaskIdling() PASSED

TopologyTestDriverEosTest > shouldUseSourceSpecificDeserializers() STARTED

TopologyTestDriverEosTest > shouldUseSourceSpecificDeserializers() PASSED

TopologyTestDriverEosTest > shouldReturnAllStores() STARTED

TopologyTestDriverEosTest > shouldReturnAllStores() PASSED

TopologyTestDriverEosTest > shouldNotCreateStateDirectoryForStatelessTopology() 
STARTED

TopologyTestDriverEosTest > shouldNotCreateStateDirectoryForStatelessTopology() 
PASSED

TopologyTestDriverEosTest > 
shouldApplyGlobalUpdatesCorrectlyInRecursiveTopologies() STARTED

TopologyTestDriverEosTest > 
shouldApplyGlobalUpdatesCorrectlyInRecursiveTopologies() PASSED

TopologyTestDriverEosTest > shouldReturnAllStoresNames() STARTED

TopologyTestDriverEosTest > shouldReturnAllStoresNames() PASSED

TopologyTestDriverEosTest > 
shouldPassRecordHeadersIntoSerializersAndDeserializers() STARTED

TopologyTestDriverEosTest > 
shouldPassRecordHeadersIntoSerializersAndDeserializers() PASSED

TopologyTestDriverEosTest > shouldProcessConsumerRecordList() STARTED

TopologyTestDriverEosTest > shouldProcessConsumerRecordList() PASSED

TopologyTestDriverEosTest > shouldUseSinkSpecificSerializers() STARTED

TopologyTestDriverEosTest > shouldUseSinkSpecificSerializers() PASSED

TopologyTestDriverEosTest > shouldFlushStoreForFirstInput() STARTED

TopologyTestDriverEosTest > shouldFlushStoreForFirstInput() PASSED

TopologyTestDriverEosTest > shouldProcessFromSourceThatMatchPattern() STARTED

TopologyTestDriverEosTest > shouldProcessFromSourceThatMatchPattern() PASSED

TopologyTestDriverEosTest > shouldCaptureSinkTopicNamesIfWrittenInto() STARTED

TopologyTestDriverEosTest > shouldCaptureSinkTopicNamesIfWrittenInto() PASSED

TopologyTestDriverEosTest > shouldUpdateStoreForNewKey() STARTED

TopologyTestDriverEosTest > shouldUpdateStoreForNewKey() PASSED

TopologyTestDriverEosTest > shouldSendRecordViaCorrectSourceTopicDeprecated() 
STARTED

TopologyTestDriverEosTest > shouldSendRecordViaCorrectSourceTopicDeprecated() 
PASSED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTime() STARTED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTime() PASSED

TopologyTestDriverEosTest > shouldSetRecordMetadata() STARTED

TopologyTestDriverEosTest > shouldSetRecordMetadata() PASSED

TopologyTestDriverEosTest > shouldNotUpdateStoreForLargerValue() STARTED

TopologyTestDriverEosTest > shouldNotUpdateStoreForLargerValue() PASSED

TopologyTestDriverEosTest > shouldReturnCorrectInMemoryStoreTypeOnly() STARTED

TopologyTestDriverEosTest > shouldReturnCorrectInMemoryStoreTypeOnly() PASSED

TopologyTestDriverEosTest > shouldThrowForMissingTime() STARTED

TopologyTestDriverEosTest > shouldThrowForMissingTime() PASSED

TopologyTestDriverEosTest > shouldCaptureInternalTopicNamesIfWrittenInto() 
STARTED

TopologyTestDriverEosTest > shouldCaptureInternalTopicNamesIfWrittenInto() 
PASSED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTimeDeprecated() STARTED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTimeDeprecated() PASSED

TopologyTestDriverEosTest > shouldProcessRecordForTopic() STARTED

TopologyTestDriverEosTest > shouldProcessRecordForTopic() PASSED

TopologyTestDriverEosTest > shouldForwardRecordsFromSubtopologyToSubtopology() 
STARTED

TopologyTestDriverEosTest > shouldForwardRecordsFromSubtopologyToSubtopology() 
PASSED

TopologyTestDriverEosTest > shouldNotUpdateStoreForSmallerValue() STARTED

TopologyTestDriverEosTest > shouldNotUpdateStoreForSmallerValue() PASSED

TopologyTestDriverEosTest > shouldCreateStateDirectoryForStatefulTopology() 
STARTED

TopologyTestDriverEosTest > sho