Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #77

2022-09-14 Thread Apache Jenkins Server 
See 


Changes:


--
[...truncated 573659 lines...]
[2022-09-15T05:11:21.809Z] Exception: java.lang.AssertionError thrown from the 
UncaughtExceptionHandler in thread 
"appId_StreamsUncaughtExceptionHandlerIntegrationTestnull-ec813e79-31aa-4d2b-88bb-a67fde43e765-StreamThread-2"
[2022-09-15T05:11:24.456Z] 
[2022-09-15T05:11:24.456Z] 
org.apache.kafka.streams.integration.StreamsUncaughtExceptionHandlerIntegrationTest
 > shouldReplaceThreads PASSED
[2022-09-15T05:11:24.456Z] 
[2022-09-15T05:11:24.456Z] 
org.apache.kafka.streams.integration.StreamsUncaughtExceptionHandlerIntegrationTest
 > shouldShutdownThreadUsingOldHandler STARTED
[2022-09-15T05:11:29.100Z] 
[2022-09-15T05:11:29.100Z] 
org.apache.kafka.streams.integration.StreamsUncaughtExceptionHandlerIntegrationTest
 > shouldShutdownThreadUsingOldHandler PASSED
[2022-09-15T05:11:29.100Z] 
[2022-09-15T05:11:29.100Z] 
org.apache.kafka.streams.integration.StreamsUncaughtExceptionHandlerIntegrationTest
 > shouldShutDownClientIfGlobalStreamThreadWantsToReplaceThread STARTED
[2022-09-15T05:11:30.862Z] 
[2022-09-15T05:11:30.862Z] Exception: java.lang.AssertionError thrown from the 
UncaughtExceptionHandler in thread 
"appId_StreamsUncaughtExceptionHandlerIntegrationTestnull-63b3307d-96ca-46fe-9231-19441e8edc7f-GlobalStreamThread"
[2022-09-15T05:11:31.807Z] 
[2022-09-15T05:11:31.807Z] 
org.apache.kafka.streams.integration.StreamsUncaughtExceptionHandlerIntegrationTest
 > shouldShutDownClientIfGlobalStreamThreadWantsToReplaceThread PASSED
[2022-09-15T05:11:31.807Z] 
[2022-09-15T05:11:31.807Z] 
org.apache.kafka.streams.integration.StreamsUncaughtExceptionHandlerIntegrationTest
 > shouldReplaceSingleThread STARTED
[2022-09-15T05:11:32.751Z] 
[2022-09-15T05:11:32.751Z] Exception: java.lang.AssertionError thrown from the 
UncaughtExceptionHandler in thread 
"appId_StreamsUncaughtExceptionHandlerIntegrationTestnull-b0351f89-d00d-419b-8895-0fffa019e8a4-StreamThread-1"
[2022-09-15T05:11:33.869Z] 
[2022-09-15T05:11:33.869Z] 
org.apache.kafka.streams.integration.StreamsUncaughtExceptionHandlerIntegrationTest
 > shouldReplaceSingleThread PASSED
[2022-09-15T05:11:33.869Z] 
[2022-09-15T05:11:33.869Z] 
org.apache.kafka.streams.integration.StreamsUncaughtExceptionHandlerIntegrationTest
 > shouldShutdownMultipleThreadApplication STARTED
[2022-09-15T05:11:45.742Z] 
[2022-09-15T05:11:45.742Z] 
org.apache.kafka.streams.integration.StreamsUncaughtExceptionHandlerIntegrationTest
 > shouldShutdownMultipleThreadApplication PASSED
[2022-09-15T05:11:45.742Z] 
[2022-09-15T05:11:45.742Z] 
org.apache.kafka.streams.integration.StreamsUncaughtExceptionHandlerIntegrationTest
 > shouldShutdownClient STARTED
[2022-09-15T05:11:46.687Z] 
[2022-09-15T05:11:46.687Z] 
org.apache.kafka.streams.integration.StreamsUncaughtExceptionHandlerIntegrationTest
 > shouldShutdownClient PASSED
[2022-09-15T05:11:46.687Z] 
[2022-09-15T05:11:46.687Z] 
org.apache.kafka.streams.integration.StreamsUncaughtExceptionHandlerIntegrationTest
 > shouldShutdownSingleThreadApplication STARTED
[2022-09-15T05:11:55.301Z] 
[2022-09-15T05:11:55.301Z] 
org.apache.kafka.streams.integration.StreamsUncaughtExceptionHandlerIntegrationTest
 > shouldShutdownSingleThreadApplication PASSED
[2022-09-15T05:11:55.301Z] 
[2022-09-15T05:11:55.301Z] 
org.apache.kafka.streams.integration.StreamsUncaughtExceptionHandlerIntegrationTest
 > shouldEmitSameRecordAfterFailover STARTED
[2022-09-15T05:11:59.075Z] 
[2022-09-15T05:11:59.075Z] 
org.apache.kafka.streams.integration.StreamsUncaughtExceptionHandlerIntegrationTest
 > shouldEmitSameRecordAfterFailover PASSED
[2022-09-15T05:12:00.843Z] 
[2022-09-15T05:12:00.843Z] 
org.apache.kafka.streams.integration.SuppressionDurabilityIntegrationTest > 
shouldRecoverBufferAfterShutdown[at_least_once] STARTED
[2022-09-15T05:12:58.375Z] 
[2022-09-15T05:12:58.375Z] 
org.apache.kafka.streams.integration.SuppressionDurabilityIntegrationTest > 
shouldRecoverBufferAfterShutdown[at_least_once] PASSED
[2022-09-15T05:12:58.375Z] 
[2022-09-15T05:12:58.375Z] 
org.apache.kafka.streams.integration.SuppressionDurabilityIntegrationTest > 
shouldRecoverBufferAfterShutdown[exactly_once] STARTED
[2022-09-15T05:13:47.423Z] 
[2022-09-15T05:13:47.423Z] 
org.apache.kafka.streams.integration.SuppressionDurabilityIntegrationTest > 
shouldRecoverBufferAfterShutdown[exactly_once] PASSED
[2022-09-15T05:13:47.423Z] 
[2022-09-15T05:13:47.423Z] 
org.apache.kafka.streams.integration.SuppressionDurabilityIntegrationTest > 
shouldRecoverBufferAfterShutdown[exactly_once_v2] STARTED
[2022-09-15T05:14:44.817Z] 
[2022-09-15T05:14:44.817Z] 
org.apache.kafka.streams.integration.SuppressionDurabilityIntegrationTest > 
shouldRecoverBufferAfterShutdown[exactly_once_v2] PASSED
[2022-09-15T05:14:44.817Z] 
[2022-09-15T05:14:44.817Z] 
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > 
testLeftInner[caching enabled = true]

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #1228

2022-09-14 Thread Apache Jenkins Server 
See 


Changes:


--
[...truncated 505514 lines...]
[2022-09-15T02:57:32.296Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorManyThreadsPerClient STARTED
[2022-09-15T02:57:33.319Z] 
[2022-09-15T02:57:33.319Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorManyThreadsPerClient PASSED
[2022-09-15T02:57:33.319Z] 
[2022-09-15T02:57:33.319Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorLargePartitionCount STARTED
[2022-09-15T02:58:12.883Z] 
[2022-09-15T02:58:12.883Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorLargePartitionCount PASSED
[2022-09-15T02:58:12.883Z] 
[2022-09-15T02:58:12.883Z] StreamsAssignmentScaleTest > 
testStickyTaskAssignorLargePartitionCount STARTED
[2022-09-15T02:58:52.544Z] 
[2022-09-15T02:58:52.544Z] StreamsAssignmentScaleTest > 
testStickyTaskAssignorLargePartitionCount PASSED
[2022-09-15T02:58:52.544Z] 
[2022-09-15T02:58:52.544Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorManyStandbys STARTED
[2022-09-15T02:58:57.620Z] 
[2022-09-15T02:58:57.620Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorManyStandbys PASSED
[2022-09-15T02:58:57.620Z] 
[2022-09-15T02:58:57.620Z] StreamsAssignmentScaleTest > 
testHighAvailabilityTaskAssignorManyStandbys STARTED
[2022-09-15T02:59:44.364Z] 
[2022-09-15T02:59:44.364Z] StreamsAssignmentScaleTest > 
testHighAvailabilityTaskAssignorManyStandbys PASSED
[2022-09-15T02:59:44.364Z] 
[2022-09-15T02:59:44.364Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorLargeNumConsumers STARTED
[2022-09-15T02:59:44.364Z] 
[2022-09-15T02:59:44.364Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorLargeNumConsumers PASSED
[2022-09-15T02:59:44.364Z] 
[2022-09-15T02:59:44.364Z] StreamsAssignmentScaleTest > 
testStickyTaskAssignorLargeNumConsumers STARTED
[2022-09-15T02:59:46.659Z] 
[2022-09-15T02:59:46.659Z] StreamsAssignmentScaleTest > 
testStickyTaskAssignorLargeNumConsumers PASSED
[2022-09-15T02:59:46.659Z] 
[2022-09-15T02:59:46.659Z] AdjustStreamThreadCountTest > 
testConcurrentlyAccessThreads() STARTED
[2022-09-15T02:59:49.065Z] 
[2022-09-15T02:59:49.065Z] AdjustStreamThreadCountTest > 
testConcurrentlyAccessThreads() PASSED
[2022-09-15T02:59:49.065Z] 
[2022-09-15T02:59:49.065Z] AdjustStreamThreadCountTest > 
shouldResizeCacheAfterThreadReplacement() STARTED
[2022-09-15T02:59:54.065Z] 
[2022-09-15T02:59:54.065Z] AdjustStreamThreadCountTest > 
shouldResizeCacheAfterThreadReplacement() PASSED
[2022-09-15T02:59:54.065Z] 
[2022-09-15T02:59:54.065Z] AdjustStreamThreadCountTest > 
shouldAddAndRemoveThreadsMultipleTimes() STARTED
[2022-09-15T02:59:59.945Z] 
[2022-09-15T02:59:59.945Z] AdjustStreamThreadCountTest > 
shouldAddAndRemoveThreadsMultipleTimes() PASSED
[2022-09-15T02:59:59.945Z] 
[2022-09-15T02:59:59.945Z] AdjustStreamThreadCountTest > 
shouldnNotRemoveStreamThreadWithinTimeout() STARTED
[2022-09-15T03:00:00.993Z] 
[2022-09-15T03:00:00.993Z] AdjustStreamThreadCountTest > 
shouldnNotRemoveStreamThreadWithinTimeout() PASSED
[2022-09-15T03:00:00.993Z] 
[2022-09-15T03:00:00.993Z] AdjustStreamThreadCountTest > 
shouldAddAndRemoveStreamThreadsWhileKeepingNamesCorrect() STARTED
[2022-09-15T03:00:20.157Z] 
[2022-09-15T03:00:20.157Z] AdjustStreamThreadCountTest > 
shouldAddAndRemoveStreamThreadsWhileKeepingNamesCorrect() PASSED
[2022-09-15T03:00:20.157Z] 
[2022-09-15T03:00:20.157Z] AdjustStreamThreadCountTest > 
shouldAddStreamThread() STARTED
[2022-09-15T03:00:24.828Z] 
[2022-09-15T03:00:24.828Z] AdjustStreamThreadCountTest > 
shouldAddStreamThread() PASSED
[2022-09-15T03:00:24.828Z] 
[2022-09-15T03:00:24.828Z] AdjustStreamThreadCountTest > 
shouldRemoveStreamThreadWithStaticMembership() STARTED
[2022-09-15T03:00:29.178Z] 
[2022-09-15T03:00:29.178Z] AdjustStreamThreadCountTest > 
shouldRemoveStreamThreadWithStaticMembership() PASSED
[2022-09-15T03:00:29.178Z] 
[2022-09-15T03:00:29.178Z] AdjustStreamThreadCountTest > 
shouldRemoveStreamThread() STARTED
[2022-09-15T03:00:33.529Z] 
[2022-09-15T03:00:33.529Z] AdjustStreamThreadCountTest > 
shouldRemoveStreamThread() PASSED
[2022-09-15T03:00:33.529Z] 
[2022-09-15T03:00:33.529Z] AdjustStreamThreadCountTest > 
shouldResizeCacheAfterThreadRemovalTimesOut() STARTED
[2022-09-15T03:00:34.616Z] 
[2022-09-15T03:00:34.616Z] AdjustStreamThreadCountTest > 
shouldResizeCacheAfterThreadRemovalTimesOut() PASSED
[2022-09-15T03:00:37.875Z] 
[2022-09-15T03:00:37.875Z] FineGrainedAutoResetIntegrationTest > 
shouldOnlyReadRecordsWhereEarliestSpecifiedWithNoCommittedOffsetsWithGlobalAutoOffsetResetLatest()
 STARTED
[2022-09-15T03:00:38.962Z] 
[2022-09-15T03:00:38.962Z] FineGrainedAutoResetIntegrationTest > 
shouldOnlyReadRecordsWhereEarliestSpecifiedWithNoCommittedOffsetsWithGlobalAutoOffsetResetLatest()
 PASSED
[2022-09-15T03:00:38.962Z] 
[2022-09-15T03:00:38.962Z] FineGrainedAutoResetIntegrationTest >

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #76

2022-09-14 Thread Apache Jenkins Server 
See 


Changes:


--
[...truncated 573255 lines...]
[2022-09-15T01:57:57.541Z] 
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > 
testInnerOuter[caching enabled = false] PASSED
[2022-09-15T01:57:57.541Z] 
[2022-09-15T01:57:57.541Z] 
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > 
testInnerLeft[caching enabled = false] STARTED
[2022-09-15T01:58:03.476Z] 
[2022-09-15T01:58:03.476Z] 
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > 
testInnerLeft[caching enabled = false] PASSED
[2022-09-15T01:58:03.476Z] 
[2022-09-15T01:58:03.476Z] 
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > 
testOuterInner[caching enabled = false] STARTED
[2022-09-15T01:58:08.823Z] 
[2022-09-15T01:58:08.823Z] 
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > 
testOuter[caching enabled = false] PASSED
[2022-09-15T01:58:08.823Z] 
[2022-09-15T01:58:08.823Z] 
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > 
testLeft[caching enabled = false] STARTED
[2022-09-15T01:58:09.390Z] 
[2022-09-15T01:58:09.390Z] 
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > 
testOuterInner[caching enabled = false] PASSED
[2022-09-15T01:58:09.390Z] 
[2022-09-15T01:58:09.390Z] 
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > 
testOuterOuter[caching enabled = false] STARTED
[2022-09-15T01:58:19.604Z] 
[2022-09-15T01:58:19.604Z] 
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > 
testOuterOuter[caching enabled = false] PASSED
[2022-09-15T01:58:20.781Z] 
[2022-09-15T01:58:20.781Z] 
org.apache.kafka.streams.integration.TaskMetadataIntegrationTest > 
shouldReportCorrectEndOffsetInformation STARTED
[2022-09-15T01:58:21.849Z] 
[2022-09-15T01:58:21.849Z] 
org.apache.kafka.streams.integration.TaskMetadataIntegrationTest > 
shouldReportCorrectEndOffsetInformation PASSED
[2022-09-15T01:58:21.849Z] 
[2022-09-15T01:58:21.849Z] 
org.apache.kafka.streams.integration.TaskMetadataIntegrationTest > 
shouldReportCorrectCommittedOffsetInformation STARTED
[2022-09-15T01:58:24.032Z] 
[2022-09-15T01:58:24.032Z] 
org.apache.kafka.streams.integration.TaskMetadataIntegrationTest > 
shouldReportCorrectCommittedOffsetInformation PASSED
[2022-09-15T01:58:24.937Z] 
[2022-09-15T01:58:24.937Z] 
org.apache.kafka.streams.processor.internals.HandlingSourceTopicDeletionIntegrationTest
 > shouldThrowErrorAfterSourceTopicDeleted STARTED
[2022-09-15T01:58:28.031Z] 
[2022-09-15T01:58:28.031Z] 
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > 
testLeft[caching enabled = false] PASSED
[2022-09-15T01:58:28.031Z] 
[2022-09-15T01:58:28.031Z] 
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > 
testInnerInner[caching enabled = false] STARTED
[2022-09-15T01:58:31.577Z] 
[2022-09-15T01:58:31.577Z] 
org.apache.kafka.streams.processor.internals.HandlingSourceTopicDeletionIntegrationTest
 > shouldThrowErrorAfterSourceTopicDeleted PASSED
[2022-09-15T01:58:34.444Z] 
[2022-09-15T01:58:34.444Z] 
org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > 
testHighAvailabilityTaskAssignorLargeNumConsumers STARTED
[2022-09-15T01:58:46.176Z] 
[2022-09-15T01:58:46.177Z] 
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > 
testInnerInner[caching enabled = false] PASSED
[2022-09-15T01:58:46.177Z] 
[2022-09-15T01:58:46.177Z] 
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > 
testInnerOuter[caching enabled = false] STARTED
[2022-09-15T01:58:55.397Z] 
[2022-09-15T01:58:55.397Z] 
org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > 
testHighAvailabilityTaskAssignorLargeNumConsumers PASSED
[2022-09-15T01:58:55.397Z] 
[2022-09-15T01:58:55.397Z] 
org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > 
testHighAvailabilityTaskAssignorLargePartitionCount STARTED
[2022-09-15T01:58:55.397Z] 
[2022-09-15T01:58:55.397Z] 
org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > 
testHighAvailabilityTaskAssignorLargePartitionCount PASSED
[2022-09-15T01:58:55.397Z] 
[2022-09-15T01:58:55.397Z] 
org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > 
testHighAvailabilityTaskAssignorManyThreadsPerClient STARTED
[2022-09-15T01:58:56.323Z] 
[2022-09-15T01:58:56.323Z] 
org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > 
testHighAvailabilityTaskAssignorManyThreadsPerClient PASSED
[2022-09-15T01:58:56.323Z] 
[2022-09-15T01:58:56.323Z] 
org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > 
testStickyTaskAssignorManyStandbys STARTED
[2022-09-15T01:59:03.947Z] 
[2022-09-15T01:59:03.947Z] 
org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > 
testStickyTaskAssignorManyStandbys PASSED
[2022-09-15T01:59:03.947Z]

[jira] [Resolved] (KAFKA-14156) Built-in partitioner may create suboptimal batches with large linger.ms

2022-09-14 Thread Jun Rao (Jira) 


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

Jun Rao resolved KAFKA-14156.
-
  Assignee: Artem Livshits
Resolution: Fixed

Merged the PR to 3.3 and trunk.

> Built-in partitioner may create suboptimal batches with large linger.ms
> ---
>
> Key: KAFKA-14156
> URL: https://issues.apache.org/jira/browse/KAFKA-14156
> Project: Kafka
>  Issue Type: Bug
>  Components: producer 
>Affects Versions: 3.3.0
>Reporter: Artem Livshits
>Assignee: Artem Livshits
>Priority: Blocker
> Fix For: 3.3.0
>
>
> The new built-in "sticky" partitioner switches partitions based on the amount 
> of bytes produced to a partition.  It doesn't use batch creation as a switch 
> trigger.  The previous "sticky" DefaultPartitioner switched partition when a 
> new batch was created and with small linger.ms (default is 0) could result in 
> sending larger batches to slower brokers potentially overloading them.  See 
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-794%3A+Strictly+Uniform+Sticky+Partitioner
>  for more detail.
> However, the with large linger.ms, the new built-in partitioner may create 
> suboptimal batches.  Let's consider an example, suppose linger.ms=500, 
> batch.size=16KB (default) and we produce 24KB / sec, i.e. every 500ms we 
> produce 12KB worth of data.  The new built-in partitioner would switch 
> partition on every 16KB, so we could get into the following batching pattern:
>  * produce 12KB to one partition in 500ms, hit linger, send 12KB batch
>  * produce 4KB more to the same partition, now we've produced 16KB of data, 
> switch partition
>  * produce 12KB to the second partition in 500ms, hit linger, send 12KB batch
>  * in the mean time the 4KB produced to the first partition would hit linger 
> as well, sending 4KB batch
>  * produce 4KB more to the second partition, now we've produced 16KB of data 
> to the second partition, switch to 3rd partition
> so in this scenario the new built-in partitioner produces a mix of 12KB and 
> 4KB batches, while the previous DefaultPartitioner would produce only 12KB 
> batches -- it switches on new batch creation, so there is no "mid-linger" 
> leftover batches.
> To avoid creation of batch fragmentation on partition switch, we can wait 
> until the batch is ready before switching the partition, i.e. the condition 
> to switch to a new partition would be "produced batch.size bytes" AND "batch 
> is not lingering".  This may potentially introduce some non-uniformity into 
> data distribution, but unlike the previous DefaultPartitioner, the 
> non-uniformity would not be based on broker performance and won't 
> re-introduce the bad pattern of sending more data to slower brokers.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Created] (KAFKA-14234) /admin/delete_topics is not in the list of zookeeper watchers

2022-09-14 Thread Yan Xue (Jira) 
Yan Xue created KAFKA-14234:
---

 Summary: /admin/delete_topics is not in the list of zookeeper 
watchers
 Key: KAFKA-14234
 URL: https://issues.apache.org/jira/browse/KAFKA-14234
 Project: Kafka
  Issue Type: Bug
  Components: controller
Affects Versions: 3.2.1
Reporter: Yan Xue


I deployed the Kafka cluster on Kuberentes and am trying to figure out how 
topic deletion works. I know Kafka controller has the topic deletion manager 
which watches the node change in the zookeeper. Whenever a topic is deleted, 
the manager is triggered. I expected to see that the {{/admin/delete_topics}} 
is in the watcher list. However, I didn't find it. Sample output:

root@kafka-broker-2:/opt/kafka# echo wchc | nc ZOOKEEPER_IP 2181
0x20010021139
    /admin/preferred_replica_election
    /brokers/ids/0
    /brokers/ids/1
    /brokers/ids/2
    /brokers/topics/__consumer_offsets
    /brokers/ids/3
    /brokers/ids/4
    /controller
    /admin/reassign_partitions
    /brokers/topics/test-test
    /feature
0x200100211390001
    /controller
    /feature
0x1631f9
    /controller
    /feature



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #75

2022-09-14 Thread Apache Jenkins Server 
See 


Changes:


--
[...truncated 574039 lines...]
[2022-09-14T21:36:37.786Z] > Task :connect:api:javadocJar
[2022-09-14T21:36:37.786Z] > Task 
:connect:json:publishMavenJavaPublicationToMavenLocal
[2022-09-14T21:36:37.786Z] > Task :connect:json:publishToMavenLocal
[2022-09-14T21:36:37.786Z] > Task :connect:api:compileTestJava UP-TO-DATE
[2022-09-14T21:36:37.786Z] > Task :connect:api:testClasses UP-TO-DATE
[2022-09-14T21:36:37.786Z] > Task :connect:api:testJar
[2022-09-14T21:36:37.786Z] > Task :connect:api:testSrcJar
[2022-09-14T21:36:37.786Z] > Task 
:connect:api:publishMavenJavaPublicationToMavenLocal
[2022-09-14T21:36:37.786Z] > Task :connect:api:publishToMavenLocal
[2022-09-14T21:36:39.570Z] 
[2022-09-14T21:36:39.570Z] > Task :streams:javadoc
[2022-09-14T21:36:39.570Z] 
/home/jenkins/workspace/Kafka_kafka_3.3@2/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java:890:
 warning - Tag @link: reference not found: DefaultPartitioner
[2022-09-14T21:36:39.570Z] 
/home/jenkins/workspace/Kafka_kafka_3.3@2/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java:919:
 warning - Tag @link: reference not found: DefaultPartitioner
[2022-09-14T21:36:39.570Z] 
/home/jenkins/workspace/Kafka_kafka_3.3@2/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java:939:
 warning - Tag @link: reference not found: DefaultPartitioner
[2022-09-14T21:36:39.570Z] 
/home/jenkins/workspace/Kafka_kafka_3.3@2/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java:854:
 warning - Tag @link: reference not found: DefaultPartitioner
[2022-09-14T21:36:39.571Z] 
/home/jenkins/workspace/Kafka_kafka_3.3@2/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java:890:
 warning - Tag @link: reference not found: DefaultPartitioner
[2022-09-14T21:36:39.571Z] 
/home/jenkins/workspace/Kafka_kafka_3.3@2/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java:919:
 warning - Tag @link: reference not found: DefaultPartitioner
[2022-09-14T21:36:39.571Z] 
/home/jenkins/workspace/Kafka_kafka_3.3@2/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java:939:
 warning - Tag @link: reference not found: DefaultPartitioner
[2022-09-14T21:36:39.571Z] 
/home/jenkins/workspace/Kafka_kafka_3.3@2/streams/src/main/java/org/apache/kafka/streams/kstream/Produced.java:84:
 warning - Tag @link: reference not found: DefaultPartitioner
[2022-09-14T21:36:39.571Z] 
/home/jenkins/workspace/Kafka_kafka_3.3@2/streams/src/main/java/org/apache/kafka/streams/kstream/Produced.java:136:
 warning - Tag @link: reference not found: DefaultPartitioner
[2022-09-14T21:36:39.571Z] 
/home/jenkins/workspace/Kafka_kafka_3.3@2/streams/src/main/java/org/apache/kafka/streams/kstream/Produced.java:147:
 warning - Tag @link: reference not found: DefaultPartitioner
[2022-09-14T21:36:39.571Z] 
/home/jenkins/workspace/Kafka_kafka_3.3@2/streams/src/main/java/org/apache/kafka/streams/kstream/Repartitioned.java:101:
 warning - Tag @link: reference not found: DefaultPartitioner
[2022-09-14T21:36:39.571Z] 
/home/jenkins/workspace/Kafka_kafka_3.3@2/streams/src/main/java/org/apache/kafka/streams/kstream/Repartitioned.java:167:
 warning - Tag @link: reference not found: DefaultPartitioner
[2022-09-14T21:36:39.571Z] 
/home/jenkins/workspace/Kafka_kafka_3.3@2/streams/src/main/java/org/apache/kafka/streams/TopologyConfig.java:58:
 warning - Tag @link: missing '#': "org.apache.kafka.streams.StreamsBuilder()"
[2022-09-14T21:36:39.571Z] 
/home/jenkins/workspace/Kafka_kafka_3.3@2/streams/src/main/java/org/apache/kafka/streams/TopologyConfig.java:58:
 warning - Tag @link: can't find org.apache.kafka.streams.StreamsBuilder() in 
org.apache.kafka.streams.TopologyConfig
[2022-09-14T21:36:39.571Z] 
/home/jenkins/workspace/Kafka_kafka_3.3@2/streams/src/main/java/org/apache/kafka/streams/TopologyDescription.java:38:
 warning - Tag @link: reference not found: ProcessorContext#forward(Object, 
Object) forwards
[2022-09-14T21:36:40.525Z] 
/home/jenkins/workspace/Kafka_kafka_3.3@2/streams/src/main/java/org/apache/kafka/streams/query/Position.java:44:
 warning - Tag @link: can't find query(Query,
[2022-09-14T21:36:40.525Z]  PositionBound, boolean) in 
org.apache.kafka.streams.processor.StateStore
[2022-09-14T21:36:40.525Z] 
/home/jenkins/workspace/Kafka_kafka_3.3@2/streams/src/main/java/org/apache/kafka/streams/query/QueryResult.java:44:
 warning - Tag @link: can't find query(Query, PositionBound, boolean) in 
org.apache.kafka.streams.processor.StateStore
[2022-09-14T21:36:40.525Z] 
/home/jenkins/workspace/Kafka_kafka_3.3@2/streams/src/main/java/org/apache/kafka/streams/query/QueryResult.java:36:
 warning - Tag @link: can't find query(Query, PositionBound, boolean) in 
org.apache.kafka.streams.processor.StateStore
[2022-09-14T21:36:40.525Z]

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #1227

2022-09-14 Thread Apache Jenkins Server 
See 


Changes:


--
[...truncated 505219 lines...]
[2022-09-14T21:14:49.047Z] 
[2022-09-14T21:14:49.047Z] StreamsAssignmentScaleTest > 
testHighAvailabilityTaskAssignorManyThreadsPerClient PASSED
[2022-09-14T21:14:49.047Z] 
[2022-09-14T21:14:49.047Z] StreamsAssignmentScaleTest > 
testStickyTaskAssignorManyStandbys STARTED
[2022-09-14T21:15:01.897Z] 
[2022-09-14T21:15:01.897Z] StreamsAssignmentScaleTest > 
testStickyTaskAssignorManyStandbys PASSED
[2022-09-14T21:15:01.897Z] 
[2022-09-14T21:15:01.897Z] StreamsAssignmentScaleTest > 
testStickyTaskAssignorManyThreadsPerClient STARTED
[2022-09-14T21:15:01.897Z] 
[2022-09-14T21:15:01.897Z] StreamsAssignmentScaleTest > 
testStickyTaskAssignorManyThreadsPerClient PASSED
[2022-09-14T21:15:01.897Z] 
[2022-09-14T21:15:01.897Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorManyThreadsPerClient STARTED
[2022-09-14T21:15:02.821Z] 
[2022-09-14T21:15:02.821Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorManyThreadsPerClient PASSED
[2022-09-14T21:15:02.821Z] 
[2022-09-14T21:15:02.821Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorLargePartitionCount STARTED
[2022-09-14T21:15:52.422Z] 
[2022-09-14T21:15:52.423Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorLargePartitionCount PASSED
[2022-09-14T21:15:52.423Z] 
[2022-09-14T21:15:52.423Z] StreamsAssignmentScaleTest > 
testStickyTaskAssignorLargePartitionCount STARTED
[2022-09-14T21:16:41.962Z] 
[2022-09-14T21:16:41.962Z] StreamsAssignmentScaleTest > 
testStickyTaskAssignorLargePartitionCount PASSED
[2022-09-14T21:16:41.962Z] 
[2022-09-14T21:16:41.962Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorManyStandbys STARTED
[2022-09-14T21:16:45.917Z] 
[2022-09-14T21:16:45.917Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorManyStandbys PASSED
[2022-09-14T21:16:45.917Z] 
[2022-09-14T21:16:45.917Z] StreamsAssignmentScaleTest > 
testHighAvailabilityTaskAssignorManyStandbys STARTED
[2022-09-14T21:17:22.954Z] 
[2022-09-14T21:17:22.954Z] StreamsAssignmentScaleTest > 
testHighAvailabilityTaskAssignorManyStandbys PASSED
[2022-09-14T21:17:22.954Z] 
[2022-09-14T21:17:22.954Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorLargeNumConsumers STARTED
[2022-09-14T21:17:22.954Z] 
[2022-09-14T21:17:22.954Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorLargeNumConsumers PASSED
[2022-09-14T21:17:22.954Z] 
[2022-09-14T21:17:22.954Z] StreamsAssignmentScaleTest > 
testStickyTaskAssignorLargeNumConsumers STARTED
[2022-09-14T21:17:24.918Z] 
[2022-09-14T21:17:24.918Z] StreamsAssignmentScaleTest > 
testStickyTaskAssignorLargeNumConsumers PASSED
[2022-09-14T21:17:25.854Z] 
[2022-09-14T21:17:25.854Z] AdjustStreamThreadCountTest > 
testConcurrentlyAccessThreads() STARTED
[2022-09-14T21:17:28.970Z] 
[2022-09-14T21:17:28.970Z] AdjustStreamThreadCountTest > 
testConcurrentlyAccessThreads() PASSED
[2022-09-14T21:17:28.970Z] 
[2022-09-14T21:17:28.970Z] AdjustStreamThreadCountTest > 
shouldResizeCacheAfterThreadReplacement() STARTED
[2022-09-14T21:17:33.917Z] 
[2022-09-14T21:17:33.917Z] AdjustStreamThreadCountTest > 
shouldResizeCacheAfterThreadReplacement() PASSED
[2022-09-14T21:17:33.917Z] 
[2022-09-14T21:17:33.917Z] AdjustStreamThreadCountTest > 
shouldAddAndRemoveThreadsMultipleTimes() STARTED
[2022-09-14T21:17:40.082Z] 
[2022-09-14T21:17:40.082Z] AdjustStreamThreadCountTest > 
shouldAddAndRemoveThreadsMultipleTimes() PASSED
[2022-09-14T21:17:40.082Z] 
[2022-09-14T21:17:40.082Z] AdjustStreamThreadCountTest > 
shouldnNotRemoveStreamThreadWithinTimeout() STARTED
[2022-09-14T21:17:41.017Z] 
[2022-09-14T21:17:41.017Z] AdjustStreamThreadCountTest > 
shouldnNotRemoveStreamThreadWithinTimeout() PASSED
[2022-09-14T21:17:41.017Z] 
[2022-09-14T21:17:41.017Z] AdjustStreamThreadCountTest > 
shouldAddAndRemoveStreamThreadsWhileKeepingNamesCorrect() STARTED
[2022-09-14T21:18:04.416Z] 
[2022-09-14T21:18:04.416Z] AdjustStreamThreadCountTest > 
shouldAddAndRemoveStreamThreadsWhileKeepingNamesCorrect() PASSED
[2022-09-14T21:18:04.416Z] 
[2022-09-14T21:18:04.416Z] AdjustStreamThreadCountTest > 
shouldAddStreamThread() STARTED
[2022-09-14T21:18:06.188Z] 
[2022-09-14T21:18:06.188Z] AdjustStreamThreadCountTest > 
shouldAddStreamThread() PASSED
[2022-09-14T21:18:06.188Z] 
[2022-09-14T21:18:06.188Z] AdjustStreamThreadCountTest > 
shouldRemoveStreamThreadWithStaticMembership() STARTED
[2022-09-14T21:18:10.968Z] 
[2022-09-14T21:18:10.968Z] AdjustStreamThreadCountTest > 
shouldRemoveStreamThreadWithStaticMembership() PASSED
[2022-09-14T21:18:10.968Z] 
[2022-09-14T21:18:10.968Z] AdjustStreamThreadCountTest > 
shouldRemoveStreamThread() STARTED
[2022-09-14T21:18:16.091Z] 
[2022-09-14T21:18:16.091Z] AdjustStreamThreadCountTest > 
shouldRemoveStreamThread() PASSED
[2022-09-14T21:18:16.091Z] 
[2022-09-14T21:18:16.091Z] AdjustStreamThreadCountTest >

Re: [VOTE] KIP-848: The Next Generation of the Consumer Rebalance Protocol

2022-09-14 Thread Guozhang Wang 
Thanks David,

There are a few minor comments pending in the discussion thread, and one is
about whether we should merge PreparePartitionAssignment with HB. But I
think the KIP itself is in pretty good shape now. Thanks!


Guozhang

On Fri, Sep 9, 2022 at 1:32 AM David Jacot 
wrote:

> Hi all,
>
> Thank you all for the very positive discussion about KIP-848. It looks
> like folks are very positive about it overall.
>
> I would like to start a vote on KIP-848, which introduces a brand new
> consumer rebalance protocol.
>
> The KIP is here: https://cwiki.apache.org/confluence/x/HhD1D.
>
> Best,
> David
>


-- 
-- Guozhang

[GitHub] [kafka-site] HilmiEgemenCiritoglu opened a new pull request, #441: Correct the year of release date for 2.7.1 in downloads.html

2022-09-14 Thread GitBox 


HilmiEgemenCiritoglu opened a new pull request, #441:
URL: https://github.com/apache/kafka-site/pull/441

   This is a super tiny thing, but could be misleading. I believe the release 
date year is not correct given 2.7.0 released later than 2.7.1 is a 
contradiction.  I also download the build to verify this, I can see the files 
are created in April 2021.


-- 
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.

To unsubscribe, e-mail: dev-unsubscr...@kafka.apache.org

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

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #1226

2022-09-14 Thread Apache Jenkins Server 
See 


Changes:


--
[...truncated 505374 lines...]
[2022-09-14T18:29:33.335Z] 
[2022-09-14T18:29:33.335Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorManyThreadsPerClient PASSED
[2022-09-14T18:29:33.335Z] 
[2022-09-14T18:29:33.335Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorLargePartitionCount STARTED
[2022-09-14T18:30:07.418Z] 
[2022-09-14T18:30:07.418Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorLargePartitionCount PASSED
[2022-09-14T18:30:07.418Z] 
[2022-09-14T18:30:07.418Z] StreamsAssignmentScaleTest > 
testStickyTaskAssignorLargePartitionCount STARTED
[2022-09-14T18:30:29.573Z] 
[2022-09-14T18:30:29.573Z] StreamsAssignmentScaleTest > 
testStickyTaskAssignorLargePartitionCount PASSED
[2022-09-14T18:30:29.573Z] 
[2022-09-14T18:30:29.573Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorManyStandbys STARTED
[2022-09-14T18:30:36.739Z] 
[2022-09-14T18:30:36.739Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorManyStandbys PASSED
[2022-09-14T18:30:36.739Z] 
[2022-09-14T18:30:36.739Z] StreamsAssignmentScaleTest > 
testHighAvailabilityTaskAssignorManyStandbys STARTED
[2022-09-14T18:31:03.813Z] 
[2022-09-14T18:31:03.813Z] StreamsAssignmentScaleTest > 
testHighAvailabilityTaskAssignorManyStandbys PASSED
[2022-09-14T18:31:03.813Z] 
[2022-09-14T18:31:03.813Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorLargeNumConsumers STARTED
[2022-09-14T18:31:05.588Z] 
[2022-09-14T18:31:05.588Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorLargeNumConsumers PASSED
[2022-09-14T18:31:05.588Z] 
[2022-09-14T18:31:05.588Z] StreamsAssignmentScaleTest > 
testStickyTaskAssignorLargeNumConsumers STARTED
[2022-09-14T18:31:07.363Z] 
[2022-09-14T18:31:07.363Z] StreamsAssignmentScaleTest > 
testStickyTaskAssignorLargeNumConsumers PASSED
[2022-09-14T18:31:07.363Z] 
[2022-09-14T18:31:07.363Z] AdjustStreamThreadCountTest > 
testConcurrentlyAccessThreads() STARTED
[2022-09-14T18:31:21.326Z] 
[2022-09-14T18:31:21.326Z] AdjustStreamThreadCountTest > 
testConcurrentlyAccessThreads() PASSED
[2022-09-14T18:31:21.326Z] 
[2022-09-14T18:31:21.326Z] AdjustStreamThreadCountTest > 
shouldResizeCacheAfterThreadReplacement() STARTED
[2022-09-14T18:31:24.749Z] 
[2022-09-14T18:31:24.750Z] AdjustStreamThreadCountTest > 
shouldResizeCacheAfterThreadReplacement() PASSED
[2022-09-14T18:31:24.750Z] 
[2022-09-14T18:31:24.750Z] AdjustStreamThreadCountTest > 
shouldAddAndRemoveThreadsMultipleTimes() STARTED
[2022-09-14T18:31:30.303Z] 
[2022-09-14T18:31:30.303Z] AdjustStreamThreadCountTest > 
shouldAddAndRemoveThreadsMultipleTimes() PASSED
[2022-09-14T18:31:30.303Z] 
[2022-09-14T18:31:30.303Z] AdjustStreamThreadCountTest > 
shouldnNotRemoveStreamThreadWithinTimeout() STARTED
[2022-09-14T18:31:31.523Z] 
[2022-09-14T18:31:31.523Z] AdjustStreamThreadCountTest > 
shouldnNotRemoveStreamThreadWithinTimeout() PASSED
[2022-09-14T18:31:31.523Z] 
[2022-09-14T18:31:31.523Z] AdjustStreamThreadCountTest > 
shouldAddAndRemoveStreamThreadsWhileKeepingNamesCorrect() STARTED
[2022-09-14T18:31:51.965Z] 
[2022-09-14T18:31:51.965Z] AdjustStreamThreadCountTest > 
shouldAddAndRemoveStreamThreadsWhileKeepingNamesCorrect() PASSED
[2022-09-14T18:31:51.965Z] 
[2022-09-14T18:31:51.965Z] AdjustStreamThreadCountTest > 
shouldAddStreamThread() STARTED
[2022-09-14T18:31:55.188Z] 
[2022-09-14T18:31:55.188Z] AdjustStreamThreadCountTest > 
shouldAddStreamThread() PASSED
[2022-09-14T18:31:55.188Z] 
[2022-09-14T18:31:55.188Z] AdjustStreamThreadCountTest > 
shouldRemoveStreamThreadWithStaticMembership() STARTED
[2022-09-14T18:31:59.745Z] 
[2022-09-14T18:31:59.745Z] AdjustStreamThreadCountTest > 
shouldRemoveStreamThreadWithStaticMembership() PASSED
[2022-09-14T18:31:59.745Z] 
[2022-09-14T18:31:59.745Z] AdjustStreamThreadCountTest > 
shouldRemoveStreamThread() STARTED
[2022-09-14T18:32:03.979Z] 
[2022-09-14T18:32:03.979Z] AdjustStreamThreadCountTest > 
shouldRemoveStreamThread() PASSED
[2022-09-14T18:32:03.979Z] 
[2022-09-14T18:32:03.979Z] AdjustStreamThreadCountTest > 
shouldResizeCacheAfterThreadRemovalTimesOut() STARTED
[2022-09-14T18:32:05.027Z] 
[2022-09-14T18:32:05.027Z] AdjustStreamThreadCountTest > 
shouldResizeCacheAfterThreadRemovalTimesOut() PASSED
[2022-09-14T18:32:07.977Z] 
[2022-09-14T18:32:07.977Z] FineGrainedAutoResetIntegrationTest > 
shouldOnlyReadRecordsWhereEarliestSpecifiedWithNoCommittedOffsetsWithGlobalAutoOffsetResetLatest()
 STARTED
[2022-09-14T18:32:08.926Z] 
[2022-09-14T18:32:08.926Z] FineGrainedAutoResetIntegrationTest > 
shouldOnlyReadRecordsWhereEarliestSpecifiedWithNoCommittedOffsetsWithGlobalAutoOffsetResetLatest()
 PASSED
[2022-09-14T18:32:08.926Z] 
[2022-09-14T18:32:08.926Z] FineGrainedAutoResetIntegrationTest > 
shouldThrowExceptionOverlappingPattern() STARTED
[2022-09-14T18:32:08.926Z] 
[2022-09-14T18:32:08.926Z] FineGrainedAutoResetIntegrationTest

Re: [VOTE] KIP-821: Connect Transforms support for nested structures

2022-09-14 Thread John Roesler 
Thanks, all!

I've reviewed the current state of the KIP, and I'm still +1 (binding).

Thanks,
-John

On Fri, Sep 2, 2022, at 12:03, Chris Egerton wrote:
> +1 (binding). Thanks Jorge, great stuff!
>
> We should probably verify with the people that have already cast +1 votes
> that they're still on board, since the design has shifted a bit since the
> last vote was casted.
>
> On 2022/06/28 20:42:14 Jorge Esteban Quilcate Otoya wrote:
>> Hi everyone,
>>
>> I'd like to bump this vote thread. Currently it's missing 1 +1 binding
> vote
>> to pass (2 +1 binding, 1 +1 non-binding).
>>
>> There has been additional discussions to consider array access and
>> deep-scan (similar to JsonPath) but hasn't been included as part of this
>> KIP.
>> The only minor change since the previous votes has been the change of
>> configuration name: from `field.style` to `field.syntax.version`.
>>
>> KIP:
>>
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-821%3A+Connect+Transforms+support+for+nested+structures
>>
>> Cheers,
>> Jorge.
>>
>> On Fri, 22 Apr 2022 at 00:01, Bill Bejeck  wrote:
>>
>> > Thanks for the KIP, Jorge.
>> >
>> > This looks like a great addition to Kafka Connect.
>> >
>> > +1(binding)
>> >
>> > -Bill
>> >
>> > On Thu, Apr 21, 2022 at 6:41 PM John Roesler  wrote:
>> >
>> > > Thanks for the KIP, Jorge!
>> > >
>> > > I’ve just looked over the KIP, and it looks good to me.
>> > >
>> > > I’m +1 (binding)
>> > >
>> > > Thanks,
>> > > John
>> > >
>> > > On Thu, Apr 21, 2022, at 09:10, Chris Egerton wrote:
>> > > > This is a worthwhile addition to the SMTs that ship out of the box
> with
>> > > > Kafka Connect. +1 non-binding
>> > > >
>> > > > On Thu, Apr 21, 2022, 09:51 Jorge Esteban Quilcate Otoya <
>> > > > quilcate.jo...@gmail.com> wrote:
>> > > >
>> > > >> Hi all,
>> > > >>
>> > > >> I'd like to start a vote on KIP-821:
>> > > >>
>> > > >>
>> > >
>> >
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-821%3A+Connect+Transforms+support+for+nested+structures
>> > > >>
>> > > >> Thanks,
>> > > >> Jorge
>> > > >>
>> > >
>> >
>>

[GitHub] [kafka-site] HilmiEgemenCiritoglu commented on pull request #440: Updated powered-by page for Criteo usage

2022-09-14 Thread GitBox 


HilmiEgemenCiritoglu commented on PR #440:
URL: https://github.com/apache/kafka-site/pull/440#issuecomment-1247056866

   Thanks @bbejeck for the prompt review!


-- 
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.

To unsubscribe, e-mail: dev-unsubscr...@kafka.apache.org

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

[GitHub] [kafka-site] bbejeck commented on pull request #440: Updated powered-by page for Criteo usage

2022-09-14 Thread GitBox 


bbejeck commented on PR #440:
URL: https://github.com/apache/kafka-site/pull/440#issuecomment-1247056337

   merged #440 into asf-site


-- 
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.

To unsubscribe, e-mail: dev-unsubscr...@kafka.apache.org

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

[GitHub] [kafka-site] bbejeck merged pull request #440: Updated powered-by page for Criteo usage

2022-09-14 Thread GitBox 


bbejeck merged PR #440:
URL: https://github.com/apache/kafka-site/pull/440


-- 
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.

To unsubscribe, e-mail: dev-unsubscr...@kafka.apache.org

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

[GitHub] [kafka-site] HilmiEgemenCiritoglu opened a new pull request, #440: Updated powered-by page for Criteo usage

2022-09-14 Thread GitBox 


HilmiEgemenCiritoglu opened a new pull request, #440:
URL: https://github.com/apache/kafka-site/pull/440

   Detail the usage of Kafka in Criteo for powered-by-page and update the logo.


-- 
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.

To unsubscribe, e-mail: dev-unsubscr...@kafka.apache.org

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

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #1225

2022-09-14 Thread Apache Jenkins Server 
See 


Changes:


--
[...truncated 505396 lines...]
[2022-09-14T15:39:49.912Z] > Task :connect:api:publishToMavenLocal
[2022-09-14T15:39:49.912Z] 
[2022-09-14T15:39:49.912Z] > Task :streams:javadoc
[2022-09-14T15:39:49.912Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/streams/src/main/java/org/apache/kafka/streams/processor/StreamPartitioner.java:50:
 warning - Tag @link: reference not found: 
org.apache.kafka.clients.producer.internals.DefaultPartitioner
[2022-09-14T15:39:49.912Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java:890:
 warning - Tag @link: reference not found: DefaultPartitioner
[2022-09-14T15:39:49.912Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java:919:
 warning - Tag @link: reference not found: DefaultPartitioner
[2022-09-14T15:39:49.912Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java:939:
 warning - Tag @link: reference not found: DefaultPartitioner
[2022-09-14T15:39:49.912Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java:854:
 warning - Tag @link: reference not found: DefaultPartitioner
[2022-09-14T15:39:49.912Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java:890:
 warning - Tag @link: reference not found: DefaultPartitioner
[2022-09-14T15:39:49.912Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java:919:
 warning - Tag @link: reference not found: DefaultPartitioner
[2022-09-14T15:39:49.912Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java:939:
 warning - Tag @link: reference not found: DefaultPartitioner
[2022-09-14T15:39:50.961Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/streams/src/main/java/org/apache/kafka/streams/kstream/Produced.java:84:
 warning - Tag @link: reference not found: DefaultPartitioner
[2022-09-14T15:39:50.961Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/streams/src/main/java/org/apache/kafka/streams/kstream/Produced.java:136:
 warning - Tag @link: reference not found: DefaultPartitioner
[2022-09-14T15:39:50.961Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/streams/src/main/java/org/apache/kafka/streams/kstream/Produced.java:147:
 warning - Tag @link: reference not found: DefaultPartitioner
[2022-09-14T15:39:50.961Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/streams/src/main/java/org/apache/kafka/streams/kstream/Repartitioned.java:101:
 warning - Tag @link: reference not found: DefaultPartitioner
[2022-09-14T15:39:50.961Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/streams/src/main/java/org/apache/kafka/streams/kstream/Repartitioned.java:167:
 warning - Tag @link: reference not found: DefaultPartitioner
[2022-09-14T15:39:52.189Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/streams/src/main/java/org/apache/kafka/streams/TopologyConfig.java:58:
 warning - Tag @link: missing '#': "org.apache.kafka.streams.StreamsBuilder()"
[2022-09-14T15:39:52.189Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/streams/src/main/java/org/apache/kafka/streams/TopologyConfig.java:58:
 warning - Tag @link: can't find org.apache.kafka.streams.StreamsBuilder() in 
org.apache.kafka.streams.TopologyConfig
[2022-09-14T15:39:52.189Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/streams/src/main/java/org/apache/kafka/streams/TopologyDescription.java:38:
 warning - Tag @link: reference not found: ProcessorContext#forward(Object, 
Object) forwards
[2022-09-14T15:39:52.189Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/streams/src/main/java/org/apache/kafka/streams/query/Position.java:44:
 warning - Tag @link: can't find query(Query,
[2022-09-14T15:39:52.189Z]  PositionBound, boolean) in 
org.apache.kafka.streams.processor.StateStore
[2022-09-14T15:39:52.189Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/streams/src/main/java/org/apache/kafka/streams/query/QueryResult.java:109:
 warning - Tag @link: reference not found: this#getResult()
[2022-09-14T15:39:52.189Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/streams/src/main/java/org/apache/kafka/streams/query/QueryResult.java:116:
 warning - Tag @link: reference not found: this#getFailureReason()
[2022-09-14T15:39:52.189Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/streams/src/main/java/org/apache/kafka/streams/query/QueryResult.java:116:
 warning - Tag @link: reference not found:

Re: [VOTE] Apache Kafka 3.3.0 RC1

2022-09-14 Thread Israel Ekpo 
Hello Jose,

I did not see a deadline for this release candidate.

It also sounded like this RC was just provisional and another one should be
expected soon.

Do you have the next release candidate available for us to review?



On Thu, Sep 1, 2022 at 2:37 PM José Armando García Sancio
 wrote:

> Hello Kafka users, developers and client-developers,
>
> This is the first candidate for the release of Apache Kafka 3.3.0.
> There are some issues that we still have to resolve before we can make
> a final release. Those issues are documented here:
>
> https://issues.apache.org/jira/issues/?jql=project%20%3D%20KAFKA%20AND%20fixVersion%20%3D%203.3.0%20AND%20status%20not%20in%20(resolved%2C%20closed)%20ORDER%20BY%20priority%20DESC%2C%20status%20DESC%2C%20updated%20DESC%20%20%20%20%20%20
>
> Even though there are known issues, I think there is value in testing
> this release candidate.
>
> Release notes for the 3.3.0 release:
> https://home.apache.org/~jsancio/kafka-3.3.0-rc1/RELEASE_NOTES.html
>
> Please download and test.
>
> Kafka's KEYS file containing PGP keys we use to sign the release:
> https://kafka.apache.org/KEYS
>
> * Release artifacts (source and binary):
> https://home.apache.org/~jsancio/kafka-3.3.0-rc1/
>
> * Maven artifacts:
> https://repository.apache.org/content/groups/staging/org/apache/kafka/
>
> * Javadoc:
> https://home.apache.org/~jsancio/kafka-3.3.0-rc1/javadoc/
>
> * The 3.3.0 tag:
> https://github.com/apache/kafka/releases/tag/3.3.0-rc1
>
> * Documentation:
> The documentation specifically for 3.3 didn't get updated. I am working on
> that.
>
> * Protocol:
> The protocol documentation for 3.3 did get updated. I am working on that.
>
> * Successful Jenkins builds for the 3.3 branch:
> Unit/integration tests:
> https://ci-builds.apache.org/job/Kafka/job/kafka/job/3.3/50/
>
> The system tests are flaky. I am working on getting a green build.
>
> Thanks,
> --
> -José
>

[GitHub] [kafka-site] bbejeck commented on pull request #431: Brain Station 23 adopted Kafka

2022-09-14 Thread GitBox 


bbejeck commented on PR #431:
URL: https://github.com/apache/kafka-site/pull/431#issuecomment-1246863230

   merged #431 into asf-site


-- 
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.

To unsubscribe, e-mail: dev-unsubscr...@kafka.apache.org

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

[GitHub] [kafka-site] bbejeck merged pull request #431: Brain Station 23 adopted Kafka

2022-09-14 Thread GitBox 


bbejeck merged PR #431:
URL: https://github.com/apache/kafka-site/pull/431


-- 
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.

To unsubscribe, e-mail: dev-unsubscr...@kafka.apache.org

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

[jira] [Created] (KAFKA-14233) Jenkins build failed with task ':core:unitTest' exit value 1

2022-09-14 Thread Luke Chen (Jira) 
Luke Chen created KAFKA-14233:
-

 Summary: Jenkins build failed with task ':core:unitTest' exit 
value 1
 Key: KAFKA-14233
 URL: https://issues.apache.org/jira/browse/KAFKA-14233
 Project: Kafka
  Issue Type: Test
Reporter: Luke Chen
Assignee: Luke Chen


Failed messages look like this:
{code:java}
FAILURE: Build failed with an exception.
[2022-09-14T09:51:52.190Z] 
[2022-09-14T09:51:52.190Z] * What went wrong:
[2022-09-14T09:51:52.190Z] Execution failed for task ':core:unitTest'.
[2022-09-14T09:51:52.190Z] > Process 'Gradle Test Executor 128' finished with 
non-zero exit value 1
[2022-09-14T09:51:52.190Z]   This problem might be caused by incorrect test 
process configuration.
[2022-09-14T09:51:52.190Z]   Please refer to the test execution section in the 
User Manual at 
https://docs.gradle.org/7.5.1/userguide/java_testing.html#sec:test_execution
[2022-09-14T09:51:52.190Z] 
[2022-09-14T09:51:52.190Z] * Try:
[2022-09-14T09:51:52.190Z] > Run with --stacktrace option to get the stack 
trace.
[2022-09-14T09:51:52.190Z] > Run with --info or --debug option to get more log 
output.
[2022-09-14T09:51:52.190Z] > Run with --scan to get full insights.
[2022-09-14T09:51:52.190Z] 
[2022-09-14T09:51:52.190Z] * Get more help at https://help.gradle.org
[2022-09-14T09:51:52.190Z] 
[2022-09-14T09:51:52.190Z] BUILD FAILED in 2h 36m 27s{code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #1224

2022-09-14 Thread Apache Jenkins Server 
See 


Changes:


--
[...truncated 504574 lines...]
[2022-09-14T09:57:04.008Z] 
[2022-09-14T09:57:04.008Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorLargePartitionCount STARTED
[2022-09-14T09:57:42.024Z] 
[2022-09-14T09:57:42.024Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorLargePartitionCount PASSED
[2022-09-14T09:57:42.024Z] 
[2022-09-14T09:57:42.024Z] StreamsAssignmentScaleTest > 
testStickyTaskAssignorLargePartitionCount STARTED
[2022-09-14T09:58:16.310Z] 
[2022-09-14T09:58:16.310Z] StreamsAssignmentScaleTest > 
testStickyTaskAssignorLargePartitionCount PASSED
[2022-09-14T09:58:16.310Z] 
[2022-09-14T09:58:16.310Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorManyStandbys STARTED
[2022-09-14T09:58:28.191Z] 
[2022-09-14T09:58:28.191Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorManyStandbys PASSED
[2022-09-14T09:58:28.191Z] 
[2022-09-14T09:58:28.191Z] StreamsAssignmentScaleTest > 
testHighAvailabilityTaskAssignorManyStandbys STARTED
[2022-09-14T09:59:02.191Z] 
[2022-09-14T09:59:02.191Z] StreamsAssignmentScaleTest > 
testHighAvailabilityTaskAssignorManyStandbys PASSED
[2022-09-14T09:59:02.191Z] 
[2022-09-14T09:59:02.191Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorLargeNumConsumers STARTED
[2022-09-14T09:59:04.961Z] 
[2022-09-14T09:59:04.961Z] StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorLargeNumConsumers PASSED
[2022-09-14T09:59:04.961Z] 
[2022-09-14T09:59:04.961Z] StreamsAssignmentScaleTest > 
testStickyTaskAssignorLargeNumConsumers STARTED
[2022-09-14T09:59:07.263Z] 
[2022-09-14T09:59:07.263Z] StreamsAssignmentScaleTest > 
testStickyTaskAssignorLargeNumConsumers PASSED
[2022-09-14T09:59:07.263Z] 
[2022-09-14T09:59:07.263Z] AdjustStreamThreadCountTest > 
testConcurrentlyAccessThreads() STARTED
[2022-09-14T09:59:11.199Z] 
[2022-09-14T09:59:11.199Z] AdjustStreamThreadCountTest > 
testConcurrentlyAccessThreads() PASSED
[2022-09-14T09:59:11.199Z] 
[2022-09-14T09:59:11.199Z] AdjustStreamThreadCountTest > 
shouldResizeCacheAfterThreadReplacement() STARTED
[2022-09-14T09:59:18.444Z] 
[2022-09-14T09:59:18.444Z] AdjustStreamThreadCountTest > 
shouldResizeCacheAfterThreadReplacement() PASSED
[2022-09-14T09:59:18.444Z] 
[2022-09-14T09:59:18.444Z] AdjustStreamThreadCountTest > 
shouldAddAndRemoveThreadsMultipleTimes() STARTED
[2022-09-14T09:59:32.513Z] 
[2022-09-14T09:59:32.513Z] AdjustStreamThreadCountTest > 
shouldAddAndRemoveThreadsMultipleTimes() PASSED
[2022-09-14T09:59:32.513Z] 
[2022-09-14T09:59:32.513Z] AdjustStreamThreadCountTest > 
shouldnNotRemoveStreamThreadWithinTimeout() STARTED
[2022-09-14T09:59:33.731Z] 
[2022-09-14T09:59:33.731Z] AdjustStreamThreadCountTest > 
shouldnNotRemoveStreamThreadWithinTimeout() PASSED
[2022-09-14T09:59:33.731Z] 
[2022-09-14T09:59:33.731Z] AdjustStreamThreadCountTest > 
shouldAddAndRemoveStreamThreadsWhileKeepingNamesCorrect() STARTED
[2022-09-14T09:59:55.840Z] 
[2022-09-14T09:59:55.840Z] AdjustStreamThreadCountTest > 
shouldAddAndRemoveStreamThreadsWhileKeepingNamesCorrect() PASSED
[2022-09-14T09:59:55.840Z] 
[2022-09-14T09:59:55.840Z] AdjustStreamThreadCountTest > 
shouldAddStreamThread() STARTED
[2022-09-14T10:00:04.193Z] 
[2022-09-14T10:00:04.193Z] AdjustStreamThreadCountTest > 
shouldAddStreamThread() PASSED
[2022-09-14T10:00:04.193Z] 
[2022-09-14T10:00:04.193Z] AdjustStreamThreadCountTest > 
shouldRemoveStreamThreadWithStaticMembership() STARTED
[2022-09-14T10:00:12.597Z] 
[2022-09-14T10:00:12.597Z] AdjustStreamThreadCountTest > 
shouldRemoveStreamThreadWithStaticMembership() PASSED
[2022-09-14T10:00:12.597Z] 
[2022-09-14T10:00:12.597Z] AdjustStreamThreadCountTest > 
shouldRemoveStreamThread() STARTED
[2022-09-14T10:00:17.982Z] 
[2022-09-14T10:00:17.982Z] AdjustStreamThreadCountTest > 
shouldRemoveStreamThread() PASSED
[2022-09-14T10:00:17.982Z] 
[2022-09-14T10:00:17.982Z] AdjustStreamThreadCountTest > 
shouldResizeCacheAfterThreadRemovalTimesOut() STARTED
[2022-09-14T10:00:21.106Z] 
[2022-09-14T10:00:21.106Z] AdjustStreamThreadCountTest > 
shouldResizeCacheAfterThreadRemovalTimesOut() PASSED
[2022-09-14T10:00:26.615Z] 
[2022-09-14T10:00:26.615Z] FineGrainedAutoResetIntegrationTest > 
shouldOnlyReadRecordsWhereEarliestSpecifiedWithNoCommittedOffsetsWithGlobalAutoOffsetResetLatest()
 STARTED
[2022-09-14T10:00:27.665Z] 
[2022-09-14T10:00:27.665Z] FineGrainedAutoResetIntegrationTest > 
shouldOnlyReadRecordsWhereEarliestSpecifiedWithNoCommittedOffsetsWithGlobalAutoOffsetResetLatest()
 PASSED
[2022-09-14T10:00:27.665Z] 
[2022-09-14T10:00:27.665Z] FineGrainedAutoResetIntegrationTest > 
shouldThrowExceptionOverlappingPattern() STARTED
[2022-09-14T10:00:27.665Z] 
[2022-09-14T10:00:27.665Z] FineGrainedAutoResetIntegrationTest > 
shouldThrowExceptionOverlappingPattern() PASSED
[2022-09-14T10:00:27.665Z] 
[2022-09-14T10:00:27.665Z] FineGrainedAutoResetIntegrationTest

[jira] [Resolved] (KAFKA-14220) "partition-count" not getting updated after revocation of partitions in case of Incremental Co-operative rebalancing.

2022-09-14 Thread Pritam Kumar (Jira) 


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

Pritam Kumar resolved KAFKA-14220.
--
  Reviewer:   (was: Chris Egerton)
Resolution: Abandoned

> "partition-count" not getting updated after revocation of partitions in case 
> of Incremental Co-operative rebalancing.
> -
>
> Key: KAFKA-14220
> URL: https://issues.apache.org/jira/browse/KAFKA-14220
> Project: Kafka
>  Issue Type: Bug
>Affects Versions: 3.0.1
>Reporter: Pritam Kumar
>Priority: Major
>
> Issue:
> 
In case of the revocation of partitions, the updation of "partition count" 
> metrics is being done before updating the new set of assignments. 
> "invokePartitionsRevoked" method of "onJoinComplete" function of 
> "ConsumerCoordinator" class is being called before the "

> subscriptions.assignFromSubscribed(assignedPartitions)" of the same class. As 
> a result of which the old assigned partition count is getting updated again 
> and again even after future rebalances.
> Demo:
> Suppose the current assignment is like:
> Assigned partitions: [partition-1, partition-2]
> Current owned partitions: []
> Added partitions (assigned - owned): [partition-1, partition-2]
> Revoked partitions (owned - assigned): []
> After that some other worker joined and part of that, as a result of which 
> “partition-2” has to be revoked.
> Assigned partitions: [partition-1]
> Current owned partitions: [partition-1, partition-2]
> Added partitions (assigned - owned): []
> Revoked partitions (owned - assigned): [partition-2]
> But as the "assignment" need to be updated with these new assignment via the 
> following logic:
> [kafka/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java|https://github.com/apache/kafka/blob/3d2ac7cdbe89cdabfd95db9971de31878afa5498/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java#L463]
> Line 463 in 
> [3d2ac7c|https://github.com/apache/kafka/commit/3d2ac7cdbe89cdabfd95db9971de31878afa5498]
> ||subscriptions.assignFromSubscribed(assignedPartitions);|
>  
> But before this only "{*}updatePartitionCount{*}()" is getting called via 
> "{*}invokePartitionsRevoked{*}":
>  
> [kafka/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java|https://github.com/apache/kafka/blob/3d2ac7cdbe89cdabfd95db9971de31878afa5498/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java#L443]
> Line 443 in 
> [3d2ac7c|https://github.com/apache/kafka/commit/3d2ac7cdbe89cdabfd95db9971de31878afa5498]
> ||firstException.compareAndSet(null, 
> invokePartitionsRevoked(revokedPartitions));|
>  
> Due to this when it is going to call for the "{*}assignedPartitions{*}" of 
> "{*}consumer{*}" via the following:
> [kafka/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java|https://github.com/apache/kafka/blob/3d2ac7cdbe89cdabfd95db9971de31878afa5498/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java#L892]
> Line 892 in 
> [3d2ac7c|https://github.com/apache/kafka/commit/3d2ac7cdbe89cdabfd95db9971de31878afa5498]
> ||public Set assignment() {|
>  
> the "{*}assignedPartitions{*}" is not yet updated.
> Solution:
As part of the bug fix to KAFKA-12622 introducing code changes to 
> update the partition count metrics after the the newly assigned partition are 
> registered.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)