Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.2 #96

[Apache Jenkins Server]

See 


Changes:


--
[...truncated 458669 lines...]
[2022-12-17T09:44:10.398Z] > Task :connect:api:jar UP-TO-DATE
[2022-12-17T09:44:10.398Z] > Task :connect:json:copyDependantLibs UP-TO-DATE
[2022-12-17T09:44:10.398Z] > Task :connect:json:jar UP-TO-DATE
[2022-12-17T09:44:11.328Z] > Task 
:connect:api:generateMetadataFileForMavenJavaPublication
[2022-12-17T09:44:11.328Z] > Task 
:connect:json:generateMetadataFileForMavenJavaPublication
[2022-12-17T09:44:11.328Z] > Task :connect:api:javadocJar
[2022-12-17T09:44:11.328Z] > Task :connect:api:compileTestJava UP-TO-DATE
[2022-12-17T09:44:11.328Z] > Task :connect:api:processTestResources NO-SOURCE
[2022-12-17T09:44:11.328Z] > Task :connect:api:testClasses UP-TO-DATE
[2022-12-17T09:44:11.328Z] > Task :connect:api:testJar
[2022-12-17T09:44:11.328Z] > Task 
:connect:json:publishMavenJavaPublicationToMavenLocal
[2022-12-17T09:44:11.328Z] > Task :connect:json:publishToMavenLocal
[2022-12-17T09:44:11.328Z] > Task :connect:api:testSrcJar
[2022-12-17T09:44:11.328Z] > Task 
:connect:api:publishMavenJavaPublicationToMavenLocal
[2022-12-17T09:44:11.328Z] > Task :connect:api:publishToMavenLocal
[2022-12-17T09:44:14.969Z] 
[2022-12-17T09:44:14.969Z] > Task :streams:javadoc
[2022-12-17T09:44:14.969Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_3.2/streams/src/main/java/org/apache/kafka/streams/TopologyConfig.java:58:
 warning - Tag @link: missing '#': "org.apache.kafka.streams.StreamsBuilder()"
[2022-12-17T09:44:14.969Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_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-12-17T09:44:14.969Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_3.2/streams/src/main/java/org/apache/kafka/streams/query/Position.java:44:
 warning - Tag @link: can't find query(Query,
[2022-12-17T09:44:14.969Z]  PositionBound, boolean) in 
org.apache.kafka.streams.processor.StateStore
[2022-12-17T09:44:15.904Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_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-12-17T09:44:15.904Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_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-12-17T09:44:15.904Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_3.2/streams/src/main/java/org/apache/kafka/streams/query/QueryResult.java:57:
 warning - Tag @link: can't find query(Query, PositionBound, boolean) in 
org.apache.kafka.streams.processor.StateStore
[2022-12-17T09:44:15.904Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_3.2/streams/src/main/java/org/apache/kafka/streams/query/QueryResult.java:74:
 warning - Tag @link: can't find query(Query, PositionBound, boolean) in 
org.apache.kafka.streams.processor.StateStore
[2022-12-17T09:44:15.904Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_3.2/streams/src/main/java/org/apache/kafka/streams/query/QueryResult.java:110:
 warning - Tag @link: reference not found: this#getResult()
[2022-12-17T09:44:15.904Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_3.2/streams/src/main/java/org/apache/kafka/streams/query/QueryResult.java:117:
 warning - Tag @link: reference not found: this#getFailureReason()
[2022-12-17T09:44:15.904Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_3.2/streams/src/main/java/org/apache/kafka/streams/query/QueryResult.java:117:
 warning - Tag @link: reference not found: this#getFailureMessage()
[2022-12-17T09:44:15.904Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_3.2/streams/src/main/java/org/apache/kafka/streams/query/QueryResult.java:155:
 warning - Tag @link: reference not found: this#isSuccess()
[2022-12-17T09:44:15.904Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_3.2/streams/src/main/java/org/apache/kafka/streams/query/QueryResult.java:155:
 warning - Tag @link: reference not found: this#isFailure()
[2022-12-17T09:44:15.904Z] 12 warnings
[2022-12-17T09:44:15.904Z] 
[2022-12-17T09:44:15.904Z] > Task :streams:javadocJar
[2022-12-17T09:44:15.904Z] 
[2022-12-17T09:44:15.904Z] > Task :clients:javadoc
[2022-12-17T09:44:15.904Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_3.2/clients/src/main/java/org/apache/kafka/common/security/oauthbearer/secured/OAuthBearerLoginCallbackHandler.java:147:
 warning - Tag @link: reference not found: 
[2022-12-17T09:44:16.885Z] 1 warning
[2022-12-17T09:44:17.815Z] 
[2022-12-17T09:44:17.815Z] > Task :clients:javadocJar
[2022-12-17T09:44:19.557Z] 
[2022-12-17T09:44:19.557Z] > Task :clients:srcJar
[2022-12-

Re: [ANNOUNCE] New committer: Viktor Somogyi-Vass

[Viktor Somogyi-Vass]

Thanks again everyone!

On Fri, Dec 16, 2022, 18:36 Bill Bejeck  wrote:

> Congratulations, Viktor!
>
> -Bill
>
> On Fri, Dec 16, 2022 at 12:32 PM Matthias J. Sax  wrote:
>
> > Congrats!
> >
> > On 12/15/22 7:10 AM, Rajini Sivaram wrote:
> > > Congratulations, Viktor!
> > >
> > > Regards,
> > >
> > > Rajini
> > >
> > >
> > > On Thu, Dec 15, 2022 at 11:41 AM Ron Dagostino 
> > wrote:
> > >
> > >> Congrats to you too, Victor!
> > >>
> > >> Ron
> > >>
> > >>> On Dec 15, 2022, at 4:59 AM, Viktor Somogyi-Vass <
> > >> viktor.somo...@cloudera.com.invalid> wrote:
> > >>>
> > >>> Thank you everyone! :)
> > >>>
> >  On Thu, Dec 15, 2022 at 10:22 AM Mickael Maison <
> > >> mickael.mai...@gmail.com>
> >  wrote:
> > 
> >  Congratulations Viktor!
> > 
> > > On Thu, Dec 15, 2022 at 10:06 AM Tamas Barnabas Egyed
> > >  wrote:
> > >
> > > Congratulations, Viktor!
> > 
> > >>
> > >
> >
>

[jira] [Created] (KAFKA-14520) TimeoutException Raised by KafkaConsumer Leads to: User provided listener org.apache.kafka.connect.runtime.WorkerSinkTask$HandleRebalance failed on invocation of onParti

[Waleed Fateem (Jira)]

Waleed Fateem created KAFKA-14520:
-

 Summary: TimeoutException Raised by KafkaConsumer Leads to: User 
provided listener 
org.apache.kafka.connect.runtime.WorkerSinkTask$HandleRebalance failed on 
invocation of onPartitionsAssigned
 Key: KAFKA-14520
 URL: https://issues.apache.org/jira/browse/KAFKA-14520
 Project: Kafka
  Issue Type: Bug
  Components: KafkaConnect
Affects Versions: 3.2.1
Reporter: Waleed Fateem


I'm on the fence on whether or not this should actually be considered a bug, 
but decided to open it as such from the perspective of a sink developer. Even 
though there's a sign of a potential issue on the Kafka broker's side, we're 
dependent on Kafka Connect to provide a level of robustness so we don't have to 
manually intervene to restart the connector.

We don't have access to the Kafka broker cluster, so we don't know what the 
underlying issue might be that caused the following error during a rebalance:
{code:java}
Nov 21, 2022 @ 06:09:44.234","org.apache.kafka.common.errors.TimeoutException: 
Timeout of 6ms expired before the position for partition topic-partition-2 
could be determined {code}
That leads to the following problem:

 

 
{code:java}
Nov 21, 2022 @ 06:09:44.234","2022-11-21 06:09:44,234 ERROR [Consumer 
clientId=connector-consumer-the-sink-1, groupId=connect-the-sink] User provided 
listener org.apache.kafka.connect.runtime.WorkerSinkTask$HandleRebalance failed 
on invocation of onPartitionsAssigned for partitions [] 
(org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) 
[task-thread-the-sink-1] 

{code}
The KafkaConsumer's position() method invoked in the WorkerSinkTask's 
HandleRebalance code causing that TimeoutException is 
[here|[https://github.com/apache/kafka/blob/3.2/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java#L697|https://github.com/apache/kafka/blob/3.2/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java#L697]:]]:

 
{code:java}
private class HandleRebalance implements ConsumerRebalanceListener {
@Override
public void onPartitionsAssigned(Collection partitions){
log.debug("{} Partitions assigned {}", WorkerSinkTask.this, 
partitions);
for (TopicPartition tp : partitions) {long pos = 
consumer.position(tp);lastCommittedOffsets.put(tp, new 
OffsetAndMetadata(pos));currentOffsets.put(tp, new 
OffsetAndMetadata(pos));log.debug("{} Assigned topic partition 
{} with offset {}", WorkerSinkTask.this, tp, pos);}{code}
Which is then considered an unrecoverable error 
[here|https://github.com/a0x8o/kafka/blob/master/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java#L210]:
{code:java}
Nov 21, 2022 @ 06:09:44.234","2022-11-21 06:09:44,234 ERROR 
WorkerSinkTask{id=the-sink-1} Task threw an uncaught and unrecoverable except 
ion. Task is being killed and will not recover until manually restarted 
(org.apache.kafka.connect.runtime.WorkerTask) [task-thread-the-sink-1] {code}
Do we expect that TimeoutException to cause the task to be killed, or should 
have this been handled ideally somehow in the WorkerSinkTask's HandleRebalance 
code?

 

 



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

[jira] [Resolved] (KAFKA-13369) Follower fetch protocol enhancements for tiered storage.

[Jun Rao (Jira)]

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

Jun Rao resolved KAFKA-13369.
-
Fix Version/s: 3.5.0
   Resolution: Fixed

merged the PR to trunk.

> Follower fetch protocol enhancements for tiered storage.
> 
>
> Key: KAFKA-13369
> URL: https://issues.apache.org/jira/browse/KAFKA-13369
> Project: Kafka
>  Issue Type: Sub-task
>Reporter: Satish Duggana
>Assignee: Satish Duggana
>Priority: Major
> Fix For: 3.5.0
>
>




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

Re: [DISCUSS] KIP-886 Add Client Producer and Consumer Builders

[John Roesler]

Hello Dan,

Thanks for the KIP!

I just saw the vote thread, took a look at the KIP, and had some questions. 
Sorry for the delay in reviewing.

It can be a hassle, but the KIP document should specify the exact public 
interfaces you are proposing. This helps to prevent a gap between what 
reviewers think they are approving and what actually gets shipped.

For example, it’s not clear to me whether you intend to add all the configs to 
the builders right now, or just the common ones.

My only other concern is how we can keep the builders up to date as configs are 
added or their descriptions are refactored. Keeping synonymous APIs consistent 
has been a problem with the Kafka Streams Scala API, for example.

I have two suggestions that might help: (1) propose to update all the JavaDocs 
of the existing Config classes to link to the equivalent builder methods, which 
will help remind people when they add new configs. (2) instead of writing new 
JavaDocs on the builder methods, link them back to the Config definitions. 
Linking in both directions will not only remind contributors to consider both 
classes, but it will also help inform users of their options and the 
relationship between them. 

Thanks again for the KIP!
-John

On Wed, Nov 16, 2022, at 16:50, Dan S wrote:
> Hello all,
>
> I've gotten great feedback from Knowles here, and from Luke Chen on the
> jira, so thanks to both so much. This is my first KIP, and I'm pretty new
> to contributing to kafka, so I'd like to learn a little bit more about the
> process and the way things usually work.
> Should I open a PR first? Should I simply wait for discussion comments or
> votes (I've gotten no votes yet)?
>
> Thanks so much,
>
> Dan
>
> On Fri, Nov 11, 2022 at 1:30 AM Knowles Atchison Jr 
> wrote:
>
>> This would be helpful. For our own client library wrappers we implemented
>> this functionality for any type with defaults for  and
>>  consumers/producers.
>>
>> On Thu, Nov 10, 2022, 6:35 PM Dan S  wrote:
>>
>> > Hello all,
>> >
>> > I think that adding builders for the producer and the consumer in kafka
>> > client would make it much easier for developers to instantiate new
>> > producers and consumers, especially if they are using an IDE with
>> > intellisense, and using the IDE to navigate to the documentation which
>> > could be added to the builder's withXYZ methods.
>> >
>> > Please let me know if you have any comments, questions, or suggestions!
>> >
>> >
>> >
>> https://cwiki.apache.org/confluence/display/KAFKA/KIP-886%3A+Add+Client+Producer+and+Consumer+Builders
>> >
>> > Thanks,
>> >
>> > Dan
>> >
>>

[jira] [Created] (KAFKA-14521) Replace BrokerCompressionCodec with BrokerCompressionType

[Ismael Juma (Jira)]

Ismael Juma created KAFKA-14521:
---

 Summary: Replace BrokerCompressionCodec with BrokerCompressionType
 Key: KAFKA-14521
 URL: https://issues.apache.org/jira/browse/KAFKA-14521
 Project: Kafka
  Issue Type: Sub-task
Reporter: Ismael Juma
Assignee: Ismael Juma


This a requirement to move `LogValidator` to the `storage` module.



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

[jira] [Created] (KAFKA-14522) Move RemoteIndexCache and ClassLoaderAwareRemoteStorageManager to the storage module

[Ismael Juma (Jira)]

Ismael Juma created KAFKA-14522:
---

 Summary: Move RemoteIndexCache and 
ClassLoaderAwareRemoteStorageManager to the storage module
 Key: KAFKA-14522
 URL: https://issues.apache.org/jira/browse/KAFKA-14522
 Project: Kafka
  Issue Type: Sub-task
Reporter: Ismael Juma






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

[jira] [Created] (KAFKA-14523) Move RemoteLogManager to the storage module

[Ismael Juma (Jira)]

Ismael Juma created KAFKA-14523:
---

 Summary: Move RemoteLogManager to the storage module
 Key: KAFKA-14523
 URL: https://issues.apache.org/jira/browse/KAFKA-14523
 Project: Kafka
  Issue Type: Sub-task
Reporter: Ismael Juma






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

Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #1444

[Apache Jenkins Server]

See 

[jira] [Created] (KAFKA-14524) Modularize `core` monolith

[Ismael Juma (Jira)]

Ismael Juma created KAFKA-14524:
---

 Summary: Modularize `core` monolith
 Key: KAFKA-14524
 URL: https://issues.apache.org/jira/browse/KAFKA-14524
 Project: Kafka
  Issue Type: Improvement
Reporter: Ismael Juma






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

[jira] [Created] (KAFKA-14525) Move CLI tools from `core` to `tools` module

[Ismael Juma (Jira)]

Ismael Juma created KAFKA-14525:
---

 Summary: Move CLI tools from `core` to `tools` module
 Key: KAFKA-14525
 URL: https://issues.apache.org/jira/browse/KAFKA-14525
 Project: Kafka
  Issue Type: Improvement
Reporter: Ismael Juma


More specifically, tools that don't require access to `core` classes and 
communicate via the kafka protocol (typically by using the client classes) 
should be moved to the `tools` module.

See KAFKA-14524 for more context.



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

[jira] [Created] (KAFKA-14526) Move `kafka.network` from `core` to separate module

[Ismael Juma (Jira)]

Ismael Juma created KAFKA-14526:
---

 Summary: Move `kafka.network` from `core` to separate module
 Key: KAFKA-14526
 URL: https://issues.apache.org/jira/browse/KAFKA-14526
 Project: Kafka
  Issue Type: Improvement
Reporter: Ismael Juma


Name to be decided, perhaps `server-network` or something along those lines.

More context in KAFKA-14524.



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

[jira] [Created] (KAFKA-14527) Move `kafka.security` to separate module

[Ismael Juma (Jira)]

Ismael Juma created KAFKA-14527:
---

 Summary: Move `kafka.security` to separate module
 Key: KAFKA-14527
 URL: https://issues.apache.org/jira/browse/KAFKA-14527
 Project: Kafka
  Issue Type: Improvement
Reporter: Ismael Juma


A possible module name would be `server-security`.



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

[jira] [Created] (KAFKA-14528) Move replication code from `core` to separate module

[Ismael Juma (Jira)]

Ismael Juma created KAFKA-14528:
---

 Summary: Move replication code from `core` to separate module
 Key: KAFKA-14528
 URL: https://issues.apache.org/jira/browse/KAFKA-14528
 Project: Kafka
  Issue Type: Improvement
Reporter: Ismael Juma


A potential module name could be `replication`. The relevant classes would be 
`ReplicaManager`, `*FetcherThread`, etc.

See KAFKA-14524 for more context.



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

Re: [ANNOUNCE] New Kafka PMC Member: Luke Chen

[Jakub Scholz]

Congrats Luke!

Jakub

On Fri, Dec 16, 2022 at 8:41 PM Jun Rao  wrote:

> Hi, Everyone,
>
> Luke Chen has been a Kafka committer since Feb. 9, 2022. He has been very
> instrumental to the community since becoming a committer. It's my pleasure
> to announce that Luke  is now a member of Kafka PMC.
>
> Congratulations Luke!
>
> Jun
> on behalf of Apache Kafka PMC
>

Re: [ANNOUNCE] New Kafka PMC Member: Luke Chen

[Sam Barker]

Congratulations Luke!

On Sat, 17 Dec 2022 at 08:41, Jun Rao  wrote:

> Hi, Everyone,
>
> Luke Chen has been a Kafka committer since Feb. 9, 2022. He has been very
> instrumental to the community since becoming a committer. It's my pleasure
> to announce that Luke  is now a member of Kafka PMC.
>
> Congratulations Luke!
>
> Jun
> on behalf of Apache Kafka PMC
>

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

[Apache Jenkins Server]

See 


Changes:


--
[...truncated 524414 lines...]
[2022-12-17T23:59:52.561Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 169 > KafkaZkClientTest > testLogDirEventNotificationsDeletion() PASSED
[2022-12-17T23:59:52.561Z] 
[2022-12-17T23:59:52.561Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 169 > KafkaZkClientTest > testGetLogConfigs() STARTED
[2022-12-17T23:59:52.561Z] 
[2022-12-17T23:59:52.561Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 169 > KafkaZkClientTest > testGetLogConfigs() PASSED
[2022-12-17T23:59:52.561Z] 
[2022-12-17T23:59:52.561Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 169 > KafkaZkClientTest > testBrokerSequenceIdMethods() STARTED
[2022-12-17T23:59:53.498Z] 
[2022-12-17T23:59:53.498Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 169 > KafkaZkClientTest > testBrokerSequenceIdMethods() PASSED
[2022-12-17T23:59:53.498Z] 
[2022-12-17T23:59:53.498Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 169 > KafkaZkClientTest > testAclMethods() STARTED
[2022-12-17T23:59:53.498Z] 
[2022-12-17T23:59:53.498Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 169 > KafkaZkClientTest > testAclMethods() PASSED
[2022-12-17T23:59:53.498Z] 
[2022-12-17T23:59:53.498Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 169 > KafkaZkClientTest > testCreateSequentialPersistentPath() STARTED
[2022-12-17T23:59:54.436Z] 
[2022-12-17T23:59:54.436Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 169 > KafkaZkClientTest > testCreateSequentialPersistentPath() PASSED
[2022-12-17T23:59:54.436Z] 
[2022-12-17T23:59:54.436Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 169 > KafkaZkClientTest > testConditionalUpdatePath() STARTED
[2022-12-17T23:59:54.436Z] 
[2022-12-17T23:59:54.436Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 169 > KafkaZkClientTest > testConditionalUpdatePath() PASSED
[2022-12-17T23:59:54.436Z] 
[2022-12-17T23:59:54.436Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 169 > KafkaZkClientTest > testGetAllTopicsInClusterTriggersWatch() 
STARTED
[2022-12-17T23:59:54.436Z] 
[2022-12-17T23:59:54.436Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 169 > KafkaZkClientTest > testGetAllTopicsInClusterTriggersWatch() 
PASSED
[2022-12-17T23:59:54.436Z] 
[2022-12-17T23:59:54.436Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 169 > KafkaZkClientTest > testDeleteTopicZNode() STARTED
[2022-12-17T23:59:55.373Z] 
[2022-12-17T23:59:55.373Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 169 > KafkaZkClientTest > testDeleteTopicZNode() PASSED
[2022-12-17T23:59:55.373Z] 
[2022-12-17T23:59:55.373Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 169 > KafkaZkClientTest > testDeletePath() STARTED
[2022-12-17T23:59:55.373Z] 
[2022-12-17T23:59:55.373Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 169 > KafkaZkClientTest > testDeletePath() PASSED
[2022-12-17T23:59:55.373Z] 
[2022-12-17T23:59:55.373Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 169 > KafkaZkClientTest > testGetBrokerMethods() STARTED
[2022-12-17T23:59:56.310Z] 
[2022-12-17T23:59:56.310Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 169 > KafkaZkClientTest > testGetBrokerMethods() PASSED
[2022-12-17T23:59:56.310Z] 
[2022-12-17T23:59:56.310Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 169 > KafkaZkClientTest > testJuteMaxBufffer() STARTED
[2022-12-17T23:59:56.310Z] 
[2022-12-17T23:59:56.310Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 169 > KafkaZkClientTest > testJuteMaxBufffer() PASSED
[2022-12-17T23:59:56.310Z] 
[2022-12-17T23:59:56.310Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 169 > KafkaZkClientTest > testCreateTokenChangeNotification() STARTED
[2022-12-17T23:59:56.310Z] 
[2022-12-17T23:59:56.310Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 169 > KafkaZkClientTest > testCreateTokenChangeNotification() PASSED
[2022-12-17T23:59:56.310Z] 
[2022-12-17T23:59:56.310Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 169 > KafkaZkClientTest > testGetTopicsAndPartitions() STARTED
[2022-12-17T23:59:57.247Z] 
[2022-12-17T23:59:57.247Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 169 > KafkaZkClientTest > testGetTopicsAndPartitions() PASSED
[2022-12-17T23:59:57.247Z] 
[2022-12-17T23:59:57.247Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 169 > KafkaZkClientTest > testChroot(boolean) > 
kafka.zk.KafkaZkClientTest.testChroot(boolean)[1] STARTED
[2022-12-17T23:59:58.180Z] 
[2022-12-17T23:59:58.180Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 169 > KafkaZkClientTest > testChroot(boolean) > 
kafka.zk.KafkaZk

Re: [ANNOUNCE] New Kafka PMC Member: Luke Chen

[Sagar]

Congratulations Luke! Very well deserved!

Sagar.

On Sun, 18 Dec 2022 at 6:41 AM, Sam Barker  wrote:

> Congratulations Luke!
>
> On Sat, 17 Dec 2022 at 08:41, Jun Rao  wrote:
>
> > Hi, Everyone,
> >
> > Luke Chen has been a Kafka committer since Feb. 9, 2022. He has been very
> > instrumental to the community since becoming a committer. It's my
> pleasure
> > to announce that Luke  is now a member of Kafka PMC.
> >
> > Congratulations Luke!
> >
> > Jun
> > on behalf of Apache Kafka PMC
> >
>