Re: [VOTE] KIP-752: Support --bootstrap-server in ReplicaVerificationTool

2021-06-10 Thread Dongjin Lee
Hi Ismael,

> I am not convinced this tool is actually useful, I haven't seen anyone
using it in years.

Sure, you may right indeed. The `ReplicaVerificationTool` may not be so
useful.[^0] However, I hope to propose another perspective.

As long as this tool is provided with a launcher script in a distribution,
its command-line parameters look so weird to the users since it breaks
consistency. It is even worse with KIP-499
[^1],
which tries to unify the command line parameters and deprecate old ones -
even the tools without launcher script (e.g., VerifiableLog4jAppender) now
uses `--bootstrap-server` parameter. This situation is rather odd, isn't it?

This improvement may not have a great value, but it may reduce awkwardness
from the user's viewpoint.

Best,
Dongjin

[^0]: With my personal experience, I used it to validate the replication
when working with a client so sensitive to replication missing, like a
Semiconductor manufacturing company.
[^1]: Somewhat strange, two omitted tools from KIP-499

all have their own launcher script.

On Thu, Jun 10, 2021 at 2:02 PM Ismael Juma  wrote:

> KAFKA-12600 was a general change, not related to this tool specifically. I
> am not convinced this tool is actually useful, I haven't seen anyone using
> it in years.
>
> Ismael
>
> On Wed, Jun 9, 2021 at 9:51 PM Dongjin Lee  wrote:
>
> > Hi Ismael,
> >
> > Before I submit this KIP, I reviewed some history. When KIP-499
> > <
> >
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-499+-+Unify+connection+name+flag+for+command+line+tool
> > >
> > tried to resolve the inconsistencies between the command line tools, two
> > tools were omitted, probably by mistake.
> >
> > - KAFKA-12878: Support --bootstrap-server kafka-streams-application-reset
> > 
> > - KAFKA-12899: Support --bootstrap-server in ReplicaVerificationTool
> >  (this one)
> >
> > And it seems like this tool is still working. The last update was
> > KAFKA-12600  by you,
> > which will also be included in this 3.0.0 release. It is why I determined
> > that this tool is worth updating.
> >
> > Thanks,
> > Dongjin
> >
> > On Thu, Jun 10, 2021 at 1:26 PM Ismael Juma  wrote:
> >
> > > Hi Dongjin,
> > >
> > > Does this tool still work? I recall that there were some doubts about
> it
> > > and that's why it wasn't updated previously.
> > >
> > > Ismael
> > >
> > > On Sat, Jun 5, 2021 at 2:38 PM Dongjin Lee  wrote:
> > >
> > > > Hi all,
> > > >
> > > > I'd like to call for a vote on KIP-752: Support --bootstrap-server in
> > > > ReplicaVerificationTool:
> > > >
> > > >
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-752%3A+Support+--bootstrap-server+in+ReplicaVerificationTool
> > > >
> > > > Best,
> > > > Dongjin
> > > >
> > > > --
> > > > *Dongjin Lee*
> > > >
> > > > *A hitchhiker in the mathematical world.*
> > > >
> > > >
> > > >
> > > > *github:  github.com/dongjinleekr
> > > > keybase:
> > > https://keybase.io/dongjinleekr
> > > > linkedin:
> > > kr.linkedin.com/in/dongjinleekr
> > > > speakerdeck:
> > > > speakerdeck.com/dongjin
> > > > *
> > > >
> > >
> >
> >
> > --
> > *Dongjin Lee*
> >
> > *A hitchhiker in the mathematical world.*
> >
> >
> >
> > *github:  github.com/dongjinleekr
> > keybase:
> https://keybase.io/dongjinleekr
> > linkedin:
> kr.linkedin.com/in/dongjinleekr
> > speakerdeck:
> > speakerdeck.com/dongjin
> > *
> >
>


-- 
*Dongjin Lee*

*A hitchhiker in the mathematical world.*



*github:  github.com/dongjinleekr
keybase: https://keybase.io/dongjinleekr
linkedin: kr.linkedin.com/in/dongjinleekr
speakerdeck: speakerdeck.com/dongjin
*


[jira] [Created] (KAFKA-12936) In-memory stores are always restored from scratch after dropping out of the group

2021-06-10 Thread A. Sophie Blee-Goldman (Jira)
A. Sophie Blee-Goldman created KAFKA-12936:
--

 Summary: In-memory stores are always restored from scratch after 
dropping out of the group
 Key: KAFKA-12936
 URL: https://issues.apache.org/jira/browse/KAFKA-12936
 Project: Kafka
  Issue Type: Bug
  Components: streams
Reporter: A. Sophie Blee-Goldman


Whenever an in-memory store is closed, the actual store contents are garbage 
collected and the state will need to be restored from scratch if the task is 
reassigned and re-initialized. We introduced the recycling feature to prevent 
this from occurring when a task is transitioned from standby to active (or vice 
versa), but it's still possible for the in-memory state to be unnecessarily 
wiped out in the case the member has dropped out of the group. In this case, 
the onPartitionsLost callback is invoked, which will close all active tasks as 
dirty before the member rejoins the group. This means that all these tasks will 
need to be restored from scratch if they are reassigned back to this consumer.



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


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

2021-06-10 Thread Apache Jenkins Server
See 


Changes:


--
[...truncated 478494 lines...]
[2021-06-11T02:31:03.790Z] > Task :clients:jar UP-TO-DATE
[2021-06-11T02:31:03.790Z] > Task :server-common:compileJava UP-TO-DATE
[2021-06-11T02:31:03.790Z] > Task :storage:api:compileJava UP-TO-DATE
[2021-06-11T02:31:03.790Z] > Task :connect:api:compileJava UP-TO-DATE
[2021-06-11T02:31:03.790Z] > Task :streams:compileJava UP-TO-DATE
[2021-06-11T02:31:03.790Z] > Task :connect:api:classes UP-TO-DATE
[2021-06-11T02:31:03.790Z] > Task :streams:classes UP-TO-DATE
[2021-06-11T02:31:03.790Z] > Task :streams:copyDependantLibs UP-TO-DATE
[2021-06-11T02:31:03.790Z] > Task :connect:json:compileJava UP-TO-DATE
[2021-06-11T02:31:03.790Z] > Task :connect:json:classes UP-TO-DATE
[2021-06-11T02:31:03.790Z] > Task :connect:json:javadoc SKIPPED
[2021-06-11T02:31:03.790Z] > Task :raft:compileJava UP-TO-DATE
[2021-06-11T02:31:03.790Z] > Task :streams:jar UP-TO-DATE
[2021-06-11T02:31:03.790Z] > Task :connect:json:javadocJar
[2021-06-11T02:31:03.790Z] > Task :storage:compileJava UP-TO-DATE
[2021-06-11T02:31:03.790Z] > Task :streams:test-utils:compileJava UP-TO-DATE
[2021-06-11T02:31:03.790Z] > Task :clients:compileTestJava UP-TO-DATE
[2021-06-11T02:31:03.790Z] > Task :clients:testClasses UP-TO-DATE
[2021-06-11T02:31:03.790Z] > Task :metadata:compileJava UP-TO-DATE
[2021-06-11T02:31:03.790Z] > Task :core:compileJava NO-SOURCE
[2021-06-11T02:31:03.790Z] > Task 
:streams:generateMetadataFileForMavenJavaPublication
[2021-06-11T02:31:03.790Z] > Task :connect:json:compileTestJava UP-TO-DATE
[2021-06-11T02:31:03.790Z] > Task :connect:json:testClasses UP-TO-DATE
[2021-06-11T02:31:03.790Z] > Task :connect:json:testJar
[2021-06-11T02:31:03.790Z] > Task :connect:json:testSrcJar
[2021-06-11T02:31:03.790Z] > Task 
:clients:generateMetadataFileForMavenJavaPublication
[2021-06-11T02:31:03.790Z] > Task :core:compileScala UP-TO-DATE
[2021-06-11T02:31:03.790Z] > Task :core:classes UP-TO-DATE
[2021-06-11T02:31:03.790Z] > Task :core:compileTestJava NO-SOURCE
[2021-06-11T02:31:04.739Z] > Task :core:compileTestScala UP-TO-DATE
[2021-06-11T02:31:04.739Z] > Task :core:testClasses UP-TO-DATE
[2021-06-11T02:31:09.404Z] > Task :connect:api:javadoc
[2021-06-11T02:31:09.404Z] > Task :connect:api:copyDependantLibs UP-TO-DATE
[2021-06-11T02:31:09.404Z] > Task :connect:api:jar UP-TO-DATE
[2021-06-11T02:31:09.404Z] > Task 
:connect:api:generateMetadataFileForMavenJavaPublication
[2021-06-11T02:31:09.404Z] > Task :connect:json:copyDependantLibs UP-TO-DATE
[2021-06-11T02:31:09.404Z] > Task :connect:json:jar UP-TO-DATE
[2021-06-11T02:31:09.404Z] > Task 
:connect:json:generateMetadataFileForMavenJavaPublication
[2021-06-11T02:31:09.404Z] > Task 
:connect:json:publishMavenJavaPublicationToMavenLocal
[2021-06-11T02:31:09.404Z] > Task :connect:json:publishToMavenLocal
[2021-06-11T02:31:09.404Z] > Task :connect:api:javadocJar
[2021-06-11T02:31:09.404Z] > Task :connect:api:compileTestJava UP-TO-DATE
[2021-06-11T02:31:09.404Z] > Task :connect:api:testClasses UP-TO-DATE
[2021-06-11T02:31:09.404Z] > Task :connect:api:testJar
[2021-06-11T02:31:09.404Z] > Task :connect:api:testSrcJar
[2021-06-11T02:31:09.404Z] > Task 
:connect:api:publishMavenJavaPublicationToMavenLocal
[2021-06-11T02:31:09.404Z] > Task :connect:api:publishToMavenLocal
[2021-06-11T02:31:11.361Z] > Task :streams:javadoc
[2021-06-11T02:31:12.310Z] > Task :streams:javadocJar
[2021-06-11T02:31:12.310Z] > Task :streams:compileTestJava UP-TO-DATE
[2021-06-11T02:31:12.310Z] > Task :streams:testClasses UP-TO-DATE
[2021-06-11T02:31:13.259Z] > Task :streams:testJar
[2021-06-11T02:31:13.259Z] > Task :streams:testSrcJar
[2021-06-11T02:31:13.259Z] > Task 
:streams:publishMavenJavaPublicationToMavenLocal
[2021-06-11T02:31:13.259Z] > Task :streams:publishToMavenLocal
[2021-06-11T02:31:14.207Z] > Task :clients:javadoc
[2021-06-11T02:31:15.154Z] > Task :clients:javadocJar
[2021-06-11T02:31:16.148Z] > Task :clients:testJar
[2021-06-11T02:31:17.104Z] > Task :clients:testSrcJar
[2021-06-11T02:31:17.104Z] > Task 
:clients:publishMavenJavaPublicationToMavenLocal
[2021-06-11T02:31:17.104Z] > Task :clients:publishToMavenLocal
[2021-06-11T02:31:17.104Z] 
[2021-06-11T02:31:17.104Z] Deprecated Gradle features were used in this build, 
making it incompatible with Gradle 8.0.
[2021-06-11T02:31:17.104Z] Use '--warning-mode all' to show the individual 
deprecation warnings.
[2021-06-11T02:31:17.104Z] See 
https://docs.gradle.org/7.0.2/userguide/command_line_interface.html#sec:command_line_warnings
[2021-06-11T02:31:17.104Z] 
[2021-06-11T02:31:17.105Z] Execution optimizations have been disabled for 2 
invalid unit(s) of work during this build to ensure correctness.
[2021-06-11T02:31:17.105Z] Please consult deprecation warnings for more details.
[2021-06-11T02:31:17.105Z] 
[2021-06-11T02:31:17.105Z] BUILD SUCCESSFUL in 37s
[2021-06-11T02:31:17.105Z] 71 actionable 

Re: [VOTE] KIP-726: Make the "cooperative-sticky, range" as the default assignor

2021-06-10 Thread Luke Chen
Hi,
Thanks for the discussion and votes. The KIP passed with:

3  binding votes:
Guozhang Wang
Sophie Blee-Goldman
Konstantine Karantasis

1 non-binding votes:
Dongjin Lee

Thank you.
Luke

On Thu, Jun 10, 2021 at 7:13 AM Konstantine Karantasis
 wrote:

> Thanks for the KIP Luke.
>
> +1 (binding)
>
> Konstantine
>
>
> On Wed, Jun 9, 2021 at 6:36 AM Luke Chen  wrote:
>
> > Hi all,
> > Bump this thread to see if there's anyone wants to vote or have
> questions.
> >
> > Thank you.
> > Luke
> >
> > Sophie Blee-Goldman  於 2021年6月8日 週二 上午4:40
> > 寫道:
> >
> > > +1 (binding)
> > >
> > > Thanks Luke
> > >
> > > On Mon, Jun 7, 2021 at 3:26 AM Luke Chen  wrote:
> > >
> > > > Hi Ismael,
> > > > Thanks for your comments. I updated the KIP for the "Compatibility,
> > > Upgrade
> > > > path" section.
> > > > Simply put, no special upgrade path is necessary.
> > > >
> > > > Thank you.
> > > > Luke
> > > >
> > > >
> > > > On Mon, Jun 7, 2021 at 4:16 PM Ismael Juma 
> wrote:
> > > >
> > > > > Hi Luke,
> > > > >
> > > > > The KIP is a bit unclear with regards to whether two rolling
> bounces
> > > are
> > > > > required or not. What exactly is being proposed?
> > > > >
> > > > > Ismael
> > > > >
> > > > > On Wed, Jun 2, 2021, 8:16 PM Luke Chen  wrote:
> > > > >
> > > > > > Hi all,
> > > > > > I'd like to call for a vote on KIP-726: Make the
> > "cooperative-sticky,
> > > > > > range" as the default assignor.
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=177048248
> > > > > >
> > > > > > This KIP is still waiting for the prerequisite stories to get
> > > > completed,
> > > > > > but it should be soon. Hopefully this can be put into V3.0 since
> > > > > > cooperative rebalancing is a major
> > > > > > improvement to the life of a consumer group (and its operator).
> > > > > >
> > > > > > The discussion thread can be found here:
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> https://lists.apache.org/thread.html/ref63417ea84a58c9068ea025b3ad38ca2cc340f5818ac07cd83452b7%40%3Cdev.kafka.apache.org%3E
> > > > > >
> > > > > > Thank you.
> > > > > > Luke
> > > > > >
> > > > >
> > > >
> > >
> >
>


Re: Request permission for KIP creation

2021-06-10 Thread Guozhang Wang
Hello Yi,

I've added you to the wiki space. Cheers,

Guozhang

On Thu, Jun 10, 2021 at 12:58 PM Yi Ding  wrote:

> Hi Team,
>
> Could you help grant me permission to create KIP on
>
> https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals
> ?
>
> My info is:
> Wiki ID: Yi Ding
> Email: yd...@confluent.io
>
> Thank you!
> Yi
>


-- 
-- Guozhang


[jira] [Resolved] (KAFKA-12934) Move some controller classes to the metadata package

2021-06-10 Thread Colin McCabe (Jira)


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

Colin McCabe resolved KAFKA-12934.
--
Fix Version/s: 3.0.0
 Reviewer: Jason Gustafson
   Resolution: Fixed

> Move some controller classes to the metadata package
> 
>
> Key: KAFKA-12934
> URL: https://issues.apache.org/jira/browse/KAFKA-12934
> Project: Kafka
>  Issue Type: Improvement
>  Components: controller
>Reporter: Colin McCabe
>Assignee: Colin McCabe
>Priority: Minor
>  Labels: kip-500
> Fix For: 3.0.0
>
>
> Move some controller classes to the metadata package so that they can be used 
> with broker snapshots.



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


[jira] [Created] (KAFKA-12935) Flaky Test RestoreIntegrationTest.shouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore

2021-06-10 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-12935:
---

 Summary: Flaky Test 
RestoreIntegrationTest.shouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore
 Key: KAFKA-12935
 URL: https://issues.apache.org/jira/browse/KAFKA-12935
 Project: Kafka
  Issue Type: Test
  Components: streams, unit tests
Reporter: Matthias J. Sax


{quote}java.lang.AssertionError: Expected: <0L> but: was <5005L> at 
org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20) at 
org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:6) at 
org.apache.kafka.streams.integration.RestoreIntegrationTest.shouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore(RestoreIntegrationTest.java:374)
{quote}



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


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

2021-06-10 Thread Apache Jenkins Server
See 


Changes:


--
[...truncated 476535 lines...]
[2021-06-10T23:06:56.092Z] > Task :clients:jar UP-TO-DATE
[2021-06-10T23:06:56.092Z] > Task :storage:api:compileJava UP-TO-DATE
[2021-06-10T23:06:56.092Z] > Task :server-common:compileJava UP-TO-DATE
[2021-06-10T23:06:56.092Z] > Task :connect:api:compileJava UP-TO-DATE
[2021-06-10T23:06:56.092Z] > Task :connect:api:classes UP-TO-DATE
[2021-06-10T23:06:56.092Z] > Task :streams:compileJava UP-TO-DATE
[2021-06-10T23:06:56.092Z] > Task :streams:classes UP-TO-DATE
[2021-06-10T23:06:56.092Z] > Task :storage:compileJava UP-TO-DATE
[2021-06-10T23:06:56.092Z] > Task :raft:compileJava UP-TO-DATE
[2021-06-10T23:06:56.092Z] > Task :connect:json:compileJava UP-TO-DATE
[2021-06-10T23:06:56.092Z] > Task :connect:json:classes UP-TO-DATE
[2021-06-10T23:06:56.092Z] > Task :connect:json:javadoc SKIPPED
[2021-06-10T23:06:56.092Z] > Task :connect:json:javadocJar
[2021-06-10T23:06:56.092Z] > Task :clients:compileTestJava UP-TO-DATE
[2021-06-10T23:06:56.092Z] > Task :clients:testClasses UP-TO-DATE
[2021-06-10T23:06:56.092Z] > Task :streams:test-utils:compileJava UP-TO-DATE
[2021-06-10T23:06:56.092Z] > Task :metadata:compileJava UP-TO-DATE
[2021-06-10T23:06:56.092Z] > Task :core:compileJava NO-SOURCE
[2021-06-10T23:06:56.092Z] > Task :connect:json:compileTestJava UP-TO-DATE
[2021-06-10T23:06:56.092Z] > Task :connect:json:testClasses UP-TO-DATE
[2021-06-10T23:06:56.092Z] > Task :connect:json:testJar
[2021-06-10T23:06:56.092Z] > Task :connect:json:testSrcJar
[2021-06-10T23:06:56.092Z] > Task 
:clients:generateMetadataFileForMavenJavaPublication
[2021-06-10T23:06:56.092Z] > Task :streams:copyDependantLibs
[2021-06-10T23:06:56.092Z] > Task :streams:jar UP-TO-DATE
[2021-06-10T23:06:56.092Z] > Task 
:streams:generateMetadataFileForMavenJavaPublication
[2021-06-10T23:07:00.348Z] > Task :connect:api:javadoc
[2021-06-10T23:07:00.348Z] > Task :connect:api:copyDependantLibs UP-TO-DATE
[2021-06-10T23:07:00.348Z] > Task :connect:api:jar UP-TO-DATE
[2021-06-10T23:07:00.348Z] > Task 
:connect:api:generateMetadataFileForMavenJavaPublication
[2021-06-10T23:07:01.368Z] > Task :connect:json:copyDependantLibs UP-TO-DATE
[2021-06-10T23:07:01.368Z] > Task :connect:json:jar UP-TO-DATE
[2021-06-10T23:07:01.368Z] > Task 
:connect:json:generateMetadataFileForMavenJavaPublication
[2021-06-10T23:07:01.368Z] > Task :connect:api:javadocJar
[2021-06-10T23:07:01.368Z] > Task 
:connect:json:publishMavenJavaPublicationToMavenLocal
[2021-06-10T23:07:01.368Z] > Task :connect:json:publishToMavenLocal
[2021-06-10T23:07:01.368Z] > Task :connect:api:compileTestJava UP-TO-DATE
[2021-06-10T23:07:01.368Z] > Task :connect:api:testClasses UP-TO-DATE
[2021-06-10T23:07:01.368Z] > Task :connect:api:testJar
[2021-06-10T23:07:01.368Z] > Task :connect:api:testSrcJar
[2021-06-10T23:07:01.368Z] > Task 
:connect:api:publishMavenJavaPublicationToMavenLocal
[2021-06-10T23:07:01.368Z] > Task :connect:api:publishToMavenLocal
[2021-06-10T23:07:03.409Z] > Task :streams:javadoc
[2021-06-10T23:07:03.409Z] > Task :streams:javadocJar
[2021-06-10T23:07:05.448Z] > Task :clients:javadoc
[2021-06-10T23:07:06.467Z] > Task :clients:javadocJar
[2021-06-10T23:07:06.467Z] > Task :clients:testJar
[2021-06-10T23:07:07.489Z] > Task :clients:testSrcJar
[2021-06-10T23:07:07.489Z] > Task 
:clients:publishMavenJavaPublicationToMavenLocal
[2021-06-10T23:07:07.489Z] > Task :clients:publishToMavenLocal
[2021-06-10T23:07:26.752Z] > Task :core:compileScala
[2021-06-10T23:08:28.956Z] > Task :core:classes
[2021-06-10T23:08:28.956Z] > Task :core:compileTestJava NO-SOURCE
[2021-06-10T23:08:58.062Z] > Task :core:compileTestScala
[2021-06-10T23:09:37.969Z] > Task :core:testClasses
[2021-06-10T23:10:08.004Z] > Task :streams:compileTestJava
[2021-06-10T23:11:00.881Z] > Task :streams:testClasses
[2021-06-10T23:11:00.881Z] > Task :streams:testJar
[2021-06-10T23:11:01.902Z] > Task :streams:testSrcJar
[2021-06-10T23:11:01.902Z] > Task 
:streams:publishMavenJavaPublicationToMavenLocal
[2021-06-10T23:11:01.902Z] > Task :streams:publishToMavenLocal
[2021-06-10T23:11:01.902Z] 
[2021-06-10T23:11:01.902Z] Deprecated Gradle features were used in this build, 
making it incompatible with Gradle 8.0.
[2021-06-10T23:11:01.902Z] Use '--warning-mode all' to show the individual 
deprecation warnings.
[2021-06-10T23:11:01.902Z] See 
https://docs.gradle.org/7.0.2/userguide/command_line_interface.html#sec:command_line_warnings
[2021-06-10T23:11:01.902Z] 
[2021-06-10T23:11:01.902Z] Execution optimizations have been disabled for 2 
invalid unit(s) of work during this build to ensure correctness.
[2021-06-10T23:11:01.902Z] Please consult deprecation warnings for more details.
[2021-06-10T23:11:01.902Z] 
[2021-06-10T23:11:01.902Z] BUILD SUCCESSFUL in 4m 23s
[2021-06-10T23:11:01.902Z] 71 actionable tasks: 37 executed, 34 up-to-date
[Pipeline] sh
[2021-06-10T23:11:05.310Z] + 

[jira] [Created] (KAFKA-12934) Move some controller classes to the metadata package

2021-06-10 Thread Colin McCabe (Jira)
Colin McCabe created KAFKA-12934:


 Summary: Move some controller classes to the metadata package
 Key: KAFKA-12934
 URL: https://issues.apache.org/jira/browse/KAFKA-12934
 Project: Kafka
  Issue Type: Improvement
Reporter: Colin McCabe
Assignee: Colin McCabe


Move some controller classes to the metadata package so that they can be used 
with broker snapshots.



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


Request permission for KIP creation

2021-06-10 Thread Yi Ding
Hi Team,

Could you help grant me permission to create KIP on
https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals
?

My info is:
Wiki ID: Yi Ding
Email: yd...@confluent.io

Thank you!
Yi


[jira] [Created] (KAFKA-12933) Flaky test ReassignPartitionsIntegrationTest.testReassignmentWithAlterIsrDisabled

2021-06-10 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-12933:
---

 Summary: Flaky test 
ReassignPartitionsIntegrationTest.testReassignmentWithAlterIsrDisabled
 Key: KAFKA-12933
 URL: https://issues.apache.org/jira/browse/KAFKA-12933
 Project: Kafka
  Issue Type: Test
  Components: admin
Reporter: Matthias J. Sax


{quote}org.opentest4j.AssertionFailedError: expected:  but was:  
at org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:55) at 
org.junit.jupiter.api.AssertTrue.assertTrue(AssertTrue.java:40) at 
org.junit.jupiter.api.AssertTrue.assertTrue(AssertTrue.java:35) at 
org.junit.jupiter.api.Assertions.assertTrue(Assertions.java:162) at 
kafka.admin.ReassignPartitionsIntegrationTest.executeAndVerifyReassignment(ReassignPartitionsIntegrationTest.scala:130)
 at 
kafka.admin.ReassignPartitionsIntegrationTest.testReassignmentWithAlterIsrDisabled(ReassignPartitionsIntegrationTest.scala:74){quote}



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


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

2021-06-10 Thread Apache Jenkins Server
See 


Changes:


--
[...truncated 406720 lines...]
[2021-06-10T18:47:34.894Z] 
[2021-06-10T18:47:34.894Z] AclAuthorizerTest > 
testThrowsOnAddPrefixedAclIfInterBrokerProtocolVersionTooLow() STARTED
[2021-06-10T18:47:34.894Z] 
[2021-06-10T18:47:34.894Z] AclAuthorizerTest > 
testThrowsOnAddPrefixedAclIfInterBrokerProtocolVersionTooLow() PASSED
[2021-06-10T18:47:34.894Z] 
[2021-06-10T18:47:34.894Z] AclAuthorizerTest > 
testAccessAllowedIfAllowAclExistsOnPrefixedResource() STARTED
[2021-06-10T18:47:35.901Z] 
[2021-06-10T18:47:35.901Z] AclAuthorizerTest > 
testAccessAllowedIfAllowAclExistsOnPrefixedResource() PASSED
[2021-06-10T18:47:35.901Z] 
[2021-06-10T18:47:35.901Z] AclAuthorizerTest > 
testAuthorizeByResourceTypeDenyTakesPrecedence() STARTED
[2021-06-10T18:47:35.902Z] 
[2021-06-10T18:47:35.902Z] AclAuthorizerTest > 
testAuthorizeByResourceTypeDenyTakesPrecedence() PASSED
[2021-06-10T18:47:35.902Z] 
[2021-06-10T18:47:35.902Z] AclAuthorizerTest > 
testHighConcurrencyModificationOfResourceAcls() STARTED
[2021-06-10T18:47:36.907Z] 
[2021-06-10T18:47:36.907Z] AclAuthorizerTest > 
testHighConcurrencyModificationOfResourceAcls() PASSED
[2021-06-10T18:47:36.907Z] 
[2021-06-10T18:47:36.907Z] AclAuthorizerTest > 
testAuthorizeByResourceTypeWithAllPrincipalAce() STARTED
[2021-06-10T18:47:37.913Z] 
[2021-06-10T18:47:37.913Z] AclAuthorizerTest > 
testAuthorizeByResourceTypeWithAllPrincipalAce() PASSED
[2021-06-10T18:47:37.913Z] 
[2021-06-10T18:47:37.913Z] AclAuthorizerTest > 
testAuthorizeWithEmptyResourceName() STARTED
[2021-06-10T18:47:37.913Z] 
[2021-06-10T18:47:37.913Z] AclAuthorizerTest > 
testAuthorizeWithEmptyResourceName() PASSED
[2021-06-10T18:47:37.913Z] 
[2021-06-10T18:47:37.913Z] AclAuthorizerTest > 
testAuthorizeThrowsOnNonLiteralResource() STARTED
[2021-06-10T18:47:38.952Z] 
[2021-06-10T18:47:38.954Z] AclAuthorizerTest > 
testAuthorizeThrowsOnNonLiteralResource() PASSED
[2021-06-10T18:47:38.954Z] 
[2021-06-10T18:47:38.954Z] AclAuthorizerTest > 
testDeleteAllAclOnPrefixedResource() STARTED
[2021-06-10T18:47:38.954Z] 
[2021-06-10T18:47:38.954Z] AclAuthorizerTest > 
testDeleteAllAclOnPrefixedResource() PASSED
[2021-06-10T18:47:38.954Z] 
[2021-06-10T18:47:38.954Z] AclAuthorizerTest > testAddAclsOnLiteralResource() 
STARTED
[2021-06-10T18:47:38.954Z] 
[2021-06-10T18:47:38.954Z] AclAuthorizerTest > testAddAclsOnLiteralResource() 
PASSED
[2021-06-10T18:47:38.954Z] 
[2021-06-10T18:47:38.954Z] AclAuthorizerTest > testGetAclsPrincipal() STARTED
[2021-06-10T18:47:39.925Z] 
[2021-06-10T18:47:39.925Z] AclAuthorizerTest > testGetAclsPrincipal() PASSED
[2021-06-10T18:47:39.925Z] 
[2021-06-10T18:47:39.925Z] AclAuthorizerTest > 
testWritesExtendedAclChangeEventIfInterBrokerProtocolNotSet() STARTED
[2021-06-10T18:47:40.931Z] 
[2021-06-10T18:47:40.931Z] AclAuthorizerTest > 
testWritesExtendedAclChangeEventIfInterBrokerProtocolNotSet() PASSED
[2021-06-10T18:47:40.931Z] 
[2021-06-10T18:47:40.931Z] AclAuthorizerTest > 
testAccessAllowedIfAllowAclExistsOnWildcardResource() STARTED
[2021-06-10T18:47:40.931Z] 
[2021-06-10T18:47:40.931Z] AclAuthorizerTest > 
testAccessAllowedIfAllowAclExistsOnWildcardResource() PASSED
[2021-06-10T18:47:40.931Z] 
[2021-06-10T18:47:40.931Z] AclAuthorizerTest > testLoadCache() STARTED
[2021-06-10T18:47:42.106Z] 
[2021-06-10T18:47:42.106Z] AclAuthorizerTest > testLoadCache() PASSED
[2021-06-10T18:47:42.106Z] 
[2021-06-10T18:47:42.106Z] ZkAuthorizationTest > testIsZkSecurityEnabled() 
STARTED
[2021-06-10T18:47:42.106Z] 
[2021-06-10T18:47:42.106Z] ZkAuthorizationTest > testIsZkSecurityEnabled() 
PASSED
[2021-06-10T18:47:42.106Z] 
[2021-06-10T18:47:42.106Z] ZkAuthorizationTest > testKafkaZkClient() STARTED
[2021-06-10T18:47:42.106Z] 
[2021-06-10T18:47:42.106Z] ZkAuthorizationTest > testKafkaZkClient() PASSED
[2021-06-10T18:47:42.106Z] 
[2021-06-10T18:47:42.106Z] ZkAuthorizationTest > testZkAntiMigration() STARTED
[2021-06-10T18:47:42.106Z] 
[2021-06-10T18:47:42.106Z] ZkAuthorizationTest > testZkAntiMigration() PASSED
[2021-06-10T18:47:42.106Z] 
[2021-06-10T18:47:42.106Z] ZkAuthorizationTest > testConsumerOffsetPathAcls() 
STARTED
[2021-06-10T18:47:42.106Z] 
[2021-06-10T18:47:42.106Z] ZkAuthorizationTest > testConsumerOffsetPathAcls() 
PASSED
[2021-06-10T18:47:42.106Z] 
[2021-06-10T18:47:42.106Z] ZkAuthorizationTest > testZkMigration() STARTED
[2021-06-10T18:47:43.296Z] 
[2021-06-10T18:47:43.296Z] ZkAuthorizationTest > testZkMigration() PASSED
[2021-06-10T18:47:43.296Z] 
[2021-06-10T18:47:43.296Z] ZkAuthorizationTest > testChroot() STARTED
[2021-06-10T18:47:43.296Z] 
[2021-06-10T18:47:43.296Z] ZkAuthorizationTest > testChroot() PASSED
[2021-06-10T18:47:43.296Z] 
[2021-06-10T18:47:43.296Z] ZkAuthorizationTest > testDelete() STARTED
[2021-06-10T18:47:43.296Z] 
[2021-06-10T18:47:43.296Z] ZkAuthorizationTest > testDelete() PASSED
[2021-06-10T18:47:43.296Z] 
[2021-06-10T18:47:43.296Z] 

Re: [VOTE] KIP-390: Support Compression Level (rebooted)

2021-06-10 Thread Konstantine Karantasis
Makes sense. Looks like a good improvement. Thanks for including the
evaluation in the proposal Dongjin.

+1 (binding)

Konstantine

On Wed, Jun 9, 2021 at 6:59 PM Dongjin Lee  wrote:

> Thanks Ismel, Tom and Ryanne,
>
> I am now updating the KIP about the further works. Sure, You won't be
> disappointed.
>
> As of Present:
>
> - binding: +2 (Ismael, Tom)
> - non-binding: +1 (Ryanne)
>
> Anyone else?
>
> Best,
> Dongjin
>
> On Thu, Jun 10, 2021 at 2:03 AM Tom Bentley  wrote:
>
> > Hi Dongjin,
> >
> > Thanks for the KIP, +1 (binding).
> >
> > Kind regards,
> >
> > Tom
> >
> > On Wed, Jun 9, 2021 at 5:16 PM Ismael Juma  wrote:
> >
> > > I'm +1 on the proposed change. As I stated in the discuss thread, I
> don't
> > > think we should rule out the buffer size config, but we could list that
> > as
> > > future work vs rejected alternatives.
> > >
> > > Ismael
> > >
> > > On Sat, Jun 5, 2021 at 2:37 PM Dongjin Lee  wrote:
> > >
> > > > Hi all,
> > > >
> > > > I'd like to open a voting thread for KIP-390: Support Compression
> Level
> > > > (rebooted):
> > > >
> > > >
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-390%3A+Support+Compression+Level
> > > >
> > > > Best,
> > > > Dongjin
> > > >
> > > > --
> > > > *Dongjin Lee*
> > > >
> > > > *A hitchhiker in the mathematical world.*
> > > >
> > > >
> > > >
> > > > *github:  github.com/dongjinleekr
> > > > keybase:
> > > https://keybase.io/dongjinleekr
> > > > linkedin:
> > > kr.linkedin.com/in/dongjinleekr
> > > > speakerdeck:
> > > > speakerdeck.com/dongjin
> > > > *
> > > >
> > >
> >
>
>
> --
> *Dongjin Lee*
>
> *A hitchhiker in the mathematical world.*
>
>
>
> *github:  github.com/dongjinleekr
> keybase: https://keybase.io/dongjinleekr
> linkedin: kr.linkedin.com/in/dongjinleekr
> speakerdeck:
> speakerdeck.com/dongjin
> *
>


[jira] [Created] (KAFKA-12932) Interfaces for SnapshotReader and SnapshotWriter

2021-06-10 Thread Jose Armando Garcia Sancio (Jira)
Jose Armando Garcia Sancio created KAFKA-12932:
--

 Summary: Interfaces for SnapshotReader and SnapshotWriter
 Key: KAFKA-12932
 URL: https://issues.apache.org/jira/browse/KAFKA-12932
 Project: Kafka
  Issue Type: Sub-task
Reporter: Jose Armando Garcia Sancio


Change the snapshot API so that SnapshotWriter and SnapshotReader are 
interfaces. Change the existing types SnapshotWriter and SnapshotReader to use 
a different name and to implement the interfaces introduced by this issue.



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


[jira] [Created] (KAFKA-12931) KIP-746: Revise KRaft Metadata Records

2021-06-10 Thread Colin McCabe (Jira)
Colin McCabe created KAFKA-12931:


 Summary: KIP-746: Revise KRaft Metadata Records
 Key: KAFKA-12931
 URL: https://issues.apache.org/jira/browse/KAFKA-12931
 Project: Kafka
  Issue Type: Improvement
  Components: kraft, controller
Reporter: Colin McCabe
Assignee: Colin McCabe






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


Re: [VOTE] KIP-745: Connect API to restart connector and tasks

2021-06-10 Thread Randall Hauch
The vote passes with three binding +1s (Konstantine, Tom, me), three
non-binding +1s (Ryanne, Kalpesh, Dongjin), and no -1 votes.

Thanks all for taking the time to review and vote!

Best regards,

Randall


On Thu, Jun 10, 2021 at 9:53 AM Tom Bentley  wrote:

> Hi Randall,
>
> Thanks for the KIP, +1 (binding).
>
> Kind regards,
>
> Tom
>
> On Thu, Jun 10, 2021 at 4:09 AM Dongjin Lee  wrote:
>
> > +1 (non-binding).
> >
> > As of present:
> >
> > - binding: +2 (Randall, Konstantine)
> > - non-binding: +3 (Ryanne, Kalpesh, Dongjin)
> >
> > We need one more +1 binding.
> >
> > Thanks,
> > Dongjin
> >
> > On Tue, Jun 8, 2021 at 6:31 AM Kalpesh Patel  >
> > wrote:
> >
> > > +1 (non-binding)
> > >
> > > Regards
> > > -Kalpesh
> > >
> > > On Mon, Jun 7, 2021 at 3:10 PM Ryanne Dolan 
> > wrote:
> > >
> > > > +1 (non-binding)
> > > >
> > > > Ryanne
> > > >
> > > > On Mon, Jun 7, 2021, 3:03 PM Konstantine Karantasis
> > > >  wrote:
> > > >
> > > > > Thanks Randall.
> > > > >
> > > > > +1 (binding)
> > > > >
> > > > > Konstantine
> > > > >
> > > > > On Mon, Jun 7, 2021 at 12:47 PM Randall Hauch 
> > > wrote:
> > > > >
> > > > > > Hello all,
> > > > > >
> > > > > > I would like to start a vote on KIP-745:
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-745%3A+Connect+API+to+restart+connector+and+tasks
> > > > > >
> > > > > > +1 (binding) from myself.
> > > > > >
> > > > > > Thanks, and best regards!
> > > > > >
> > > > > > Randall
> > > > > >
> > > > >
> > > >
> > >
> >
> >
> > --
> > *Dongjin Lee*
> >
> > *A hitchhiker in the mathematical world.*
> >
> >
> >
> > *github:  github.com/dongjinleekr
> > keybase:
> https://keybase.io/dongjinleekr
> > linkedin:
> kr.linkedin.com/in/dongjinleekr
> > speakerdeck:
> > speakerdeck.com/dongjin
> > *
> >
>


Re: [DISCUSS] KIP-716: Allow configuring the location of the offset-syncs topic with MirrorMaker2

2021-06-10 Thread Mickael Maison
Hi Tom,

Thanks for the feedback.

Yes unfortunately it's not possible to automatically detect such
misconfiguration. In practice, I expect an administrator to quickly
identify if no checkpoints are being emitted and notice the
offset-syncs topic is missing or that there's a copy in both cluster.

Yes that's right, there is no migration steps. Users will need to stop
their connectors, clear the offset-syncs topic and restart the
connectors with the new configuration.
I've updated the KIP with this explanation.

Thanks

On Thu, Apr 15, 2021 at 6:39 PM Tom Bentley  wrote:
>
> Hi Mickael,
>
> In Connect distributed mode the KIP says "it's necessary to set the config
> on both the Source and Checkpoint connectors". There's no way to detect
> this misconfiguration, because connect just sees two distinct connections.
> So if the user gets this wrong then the source connector would try to
> create it in the "wrong" cluster, the source task will populate it there,
> but the checkpoint task would look in the wrong cluster, and depending on
> how allow.auto.create.topics is configured it could create the topic by
> side effect. Thus am I right that such a misconfiguration could go
> undetected indefinitely?
>
> It would be good to add to the migration section how people would migrate
> from offsets sync topic in the source to the target cluster, or the
> reverse. I think it's just a matter of changing the configs and deleting
> the old offset-sync topic, right? But, assuming this wouldn't be covered in
> the docs, it would be helpful to document it somewhere.
>
> Thanks,
>
> Tom
>
> On Thu, Mar 18, 2021 at 3:51 PM Ryanne Dolan  wrote:
>
> > Looks good to me, I'll vote +1.
> >
> > Ryanne
> >
> > On Thu, Mar 18, 2021, 10:36 AM Mickael Maison 
> > wrote:
> >
> > > Hi,
> > >
> > > I've not seen any feedback on this KIP.
> > > As it's relatively straight forward, I'll open a vote in the next few
> > > days if I don't see anything.
> > >
> > > Thanks
> > >
> > > On Fri, Feb 26, 2021 at 6:20 PM Mickael Maison  > >
> > > wrote:
> > > >
> > > > Hi,
> > > >
> > > > I would like to start a discussion on KIP-716. This will allow
> > > > configuring where MirrorMaker2 creates the offset syncs topic.
> > > >
> > > >
> > >
> > https://cwiki.apache.org/confluence/display/KAFKA/KIP-716%3A+Allow+configuring+the+location+of+the+offset-syncs+topic+with+MirrorMaker2
> > > >
> > > > I look forward to your feedback
> > > > Thanks
> > >
> >


[VOTE] KIP-748: Add Broker Count Metrics

2021-06-10 Thread Ryan Dielhenn
Hello,

I would like to start a vote on KIP-748: Add Broker Count Metrics.

Here is the KIP:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-748:+Add+Broker+Count+Metrics

Here is the discussion thread:
https://lists.apache.org/thread.html/r308364dfbb3020e6151cef47237c28a4a540e187b8af84ddafec83af%40%3Cdev.kafka.apache.org%3E

Please take a look and vote if you have a chance.

Thank you,
Ryan


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

2021-06-10 Thread Apache Jenkins Server
See 


Changes:


--
[...truncated 474294 lines...]
[2021-06-10T16:21:10.308Z] MetricsTest > 
testBrokerTopicMetricsUnregisteredAfterDeletingTopic() STARTED
[2021-06-10T16:21:15.025Z] 
[2021-06-10T16:21:15.025Z] MetricsTest > 
testBrokerTopicMetricsUnregisteredAfterDeletingTopic() PASSED
[2021-06-10T16:21:15.025Z] 
[2021-06-10T16:21:15.025Z] MetricsTest > testYammerMetricsCountMetric() STARTED
[2021-06-10T16:21:17.066Z] 
[2021-06-10T16:21:17.066Z] MetricsTest > testYammerMetricsCountMetric() PASSED
[2021-06-10T16:21:17.066Z] 
[2021-06-10T16:21:17.066Z] MetricsTest > testClusterIdMetric() STARTED
[2021-06-10T16:21:20.729Z] 
[2021-06-10T16:21:20.729Z] MetricsTest > testClusterIdMetric() PASSED
[2021-06-10T16:21:20.729Z] 
[2021-06-10T16:21:20.729Z] MetricsTest > testControllerMetrics() STARTED
[2021-06-10T16:21:22.736Z] 
[2021-06-10T16:21:22.736Z] MetricsTest > testControllerMetrics() PASSED
[2021-06-10T16:21:22.736Z] 
[2021-06-10T16:21:22.736Z] MetricsTest > testWindowsStyleTagNames() STARTED
[2021-06-10T16:21:24.745Z] 
[2021-06-10T16:21:24.745Z] MetricsTest > testWindowsStyleTagNames() PASSED
[2021-06-10T16:21:24.745Z] 
[2021-06-10T16:21:24.745Z] MetricsTest > testBrokerStateMetric() STARTED
[2021-06-10T16:21:28.298Z] 
[2021-06-10T16:21:28.298Z] MetricsTest > testBrokerStateMetric() PASSED
[2021-06-10T16:21:28.298Z] 
[2021-06-10T16:21:28.298Z] MetricsTest > testBrokerTopicMetricsBytesInOut() 
STARTED
[2021-06-10T16:21:32.479Z] 
[2021-06-10T16:21:32.479Z] MetricsTest > testBrokerTopicMetricsBytesInOut() 
PASSED
[2021-06-10T16:21:32.479Z] 
[2021-06-10T16:21:32.479Z] MetricsTest > testJMXFilter() STARTED
[2021-06-10T16:21:35.102Z] 
[2021-06-10T16:21:35.102Z] MetricsTest > testJMXFilter() PASSED
[2021-06-10T16:21:36.225Z] 
[2021-06-10T16:21:36.225Z] DeleteTopicTest > testDeleteTopicWithCleaner() 
SKIPPED
[2021-06-10T16:21:36.225Z] 
[2021-06-10T16:21:36.225Z] 960 tests completed, 1 failed, 8 skipped
[2021-06-10T16:21:36.225Z] 
[2021-06-10T16:21:36.225Z] > Task :core:integrationTest FAILED
[2021-06-10T16:21:36.225Z] 
[2021-06-10T16:21:36.225Z] FAILURE: Build failed with an exception.
[2021-06-10T16:21:36.225Z] 
[2021-06-10T16:21:36.225Z] * What went wrong:
[2021-06-10T16:21:36.225Z] Execution failed for task ':core:integrationTest'.
[2021-06-10T16:21:36.225Z] > Process 'Gradle Test Executor 128' finished with 
non-zero exit value 1
[2021-06-10T16:21:36.225Z]   This problem might be caused by incorrect test 
process configuration.
[2021-06-10T16:21:36.225Z]   Please refer to the test execution section in the 
User Manual at 
https://docs.gradle.org/7.0.2/userguide/java_testing.html#sec:test_execution
[2021-06-10T16:21:36.225Z] 
[2021-06-10T16:21:36.225Z] * Try:
[2021-06-10T16:21:36.225Z] Run with --stacktrace option to get the stack trace. 
Run with --info or --debug option to get more log output. Run with --scan to 
get full insights.
[2021-06-10T16:21:36.225Z] 
[2021-06-10T16:21:36.225Z] * Get more help at https://help.gradle.org
[2021-06-10T16:21:36.225Z] 
[2021-06-10T16:21:36.225Z] Deprecated Gradle features were used in this build, 
making it incompatible with Gradle 8.0.
[2021-06-10T16:21:36.225Z] Use '--warning-mode all' to show the individual 
deprecation warnings.
[2021-06-10T16:21:36.225Z] See 
https://docs.gradle.org/7.0.2/userguide/command_line_interface.html#sec:command_line_warnings
[2021-06-10T16:21:36.225Z] 
[2021-06-10T16:21:36.225Z] BUILD FAILED in 2h 1m 41s
[2021-06-10T16:21:36.225Z] 196 actionable tasks: 105 executed, 91 up-to-date
[2021-06-10T16:21:36.225Z] 
[2021-06-10T16:21:36.225Z] See the profiling report at: 
file:///home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk/build/reports/profile/profile-2021-06-10-14-20-01.html
[2021-06-10T16:21:36.225Z] A fine-grained performance profile is available: use 
the --scan option.
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] // node
[Pipeline] }
[Pipeline] // timestamps
[Pipeline] }
[Pipeline] // timeout
[Pipeline] }
[Pipeline] // stage
[Pipeline] }
Failed in branch JDK 15 and Scala 2.12
[2021-06-10T16:21:37.343Z] 
[2021-06-10T16:21:37.343Z] TopicCommandIntegrationTest > testTopicDeletion() 
PASSED
[2021-06-10T16:21:37.343Z] 
[2021-06-10T16:21:37.344Z] TopicCommandIntegrationTest > 
testCreateWithDefaults() STARTED
[2021-06-10T16:21:39.974Z] 
[2021-06-10T16:21:39.974Z] TopicCommandIntegrationTest > 
testCreateWithDefaults() PASSED
[2021-06-10T16:21:39.974Z] 
[2021-06-10T16:21:39.974Z] TopicCommandIntegrationTest > 
testDescribeReportOverriddenConfigs() STARTED
[2021-06-10T16:21:44.851Z] 
[2021-06-10T16:21:44.851Z] TopicCommandIntegrationTest > 
testDescribeReportOverriddenConfigs() PASSED
[2021-06-10T16:21:44.851Z] 
[2021-06-10T16:21:44.851Z] TopicCommandIntegrationTest > 
testDescribeWhenTopicDoesntExist() STARTED
[2021-06-10T16:21:48.431Z] 

Re: [VOTE] KIP-618: Exactly-once support for source connectors

2021-06-10 Thread Chris Egerton
Hi all,

Firstly, thanks for the votes!

Secondly--Ismael, in response to your feedback, I have to admit I'm a
little in the dark here. Are you suggesting that there be a new Kafka API
for the act of fencing out a producer with a given transactional ID (or set
of transactional IDs)? If so, can you highlight the advantages of this new
API over the existing INIT_PRODUCER_ID API? At least as far as Connect is
concerned, we likely wouldn't be able to fully leverage any
newly-introduced Kafka APIs in the release that they first appear, since
we'd want to maintain compatibility with older broker versions. One could
argue that since this feature is entirely opt-in we could make it a
requirement for users to upgrade their Kafka clusters to 3.0 (or whatever
version supports this new API) in order to leverage it, but given the
effectiveness of the INIT_PRODUCER_ID API in servicing our needs, I'm not
sure that would be the right tradeoff. And as far as the distinction
between client- and broker-side (or rather, transaction coordinator-side)
logic goes, I'm having trouble envisioning anything--with or without a new
Kafka API--that would make the client-side logic simpler; the existing
proposal only involves a find coordinator request and then an init producer
request; is there a simpler way to handle things client-side that plays
nicely with established idioms for the admin and Kafka APIs?

I plan to leave the vote thread open as long as there are unresolved
comments from serious contributors such as Ismael, and close it as soon as
those are all taken care of.

Cheers,

Chris

On Thu, Jun 10, 2021 at 11:05 AM Ismael Juma  wrote:

> One concern I have is that we are not introducing a request for the fencing
> and implementing that logic in the admin client directly. I would prefer a
> request in the txn coordinator with the right semantics.
>
> Ismael
>
> On Thu, Jun 10, 2021, 7:46 AM Gwen Shapira 
> wrote:
>
> > I'm supportive of the feature and the interface details discussed in the
> > discussion thread. I just want to clarify that I'm voting for the last
> > version discussed in the thread - that includes two phase upgrade and no
> > breaking changes in 3.0.
> >
> > +1 (binding)
> >
> >
> > On Wed, Jun 9, 2021, 5:32 AM Chris Egerton 
> > wrote:
> >
> > > Hi all,
> > >
> > > Friendly reminder that the KIP freeze is today; please cast your votes
> if
> > > you'd like to see this feature introduced in time for 3.0.
> > >
> > > Cheers,
> > >
> > > Chris
> > >
> > > On Mon, Jun 7, 2021 at 1:49 AM Dongjin Lee  wrote:
> > >
> > > > +1 (non-binding).
> > > >
> > > > Thanks,
> > > > Dongjin
> > > >
> > > > On Fri, Jun 4, 2021 at 2:35 PM Ryanne Dolan 
> > > wrote:
> > > >
> > > > > +1 (non-binding)
> > > > >
> > > > > On Thu, Jun 3, 2021, 10:23 AM Chris Egerton
> > >  > > > >
> > > > > wrote:
> > > > >
> > > > > > Hi all,
> > > > > >
> > > > > > I'd like to call for a vote on KIP-618, which adds support for
> > > > > exactly-once
> > > > > > delivery guarantees for source connectors in the Kafka Connect
> > > > framework.
> > > > > >
> > > > > > I suspect there might be a little more discussion to be had but
> > with
> > > > the
> > > > > > KIP freeze deadline approaching, I wanted to give anyone
> following
> > > > along
> > > > > > the chance to cast a +1 as soon as they feel that we've gotten
> to a
> > > > > > reasonable state.
> > > > > >
> > > > > > The KIP:
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-618%3A+Exactly-Once+Support+for+Source+Connectors
> > > > > >
> > > > > > The discussion thread:
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> https://mail-archives.apache.org/mod_mbox/kafka-dev/202005.mbox/%3CCAMdOrUX-VK5OSB3OOdJNXW_YKEJH9FjQZ4eyzr2GXUhSeDnF3Q%40mail.gmail.com%3E
> > > > > >
> > > > > > Cheers,
> > > > > >
> > > > > > Chris
> > > > > >
> > > > >
> > > >
> > > >
> > > > --
> > > > *Dongjin Lee*
> > > >
> > > > *A hitchhiker in the mathematical world.*
> > > >
> > > >
> > > >
> > > > *github:  github.com/dongjinleekr
> > > > keybase:
> > > https://keybase.io/dongjinleekr
> > > > linkedin:
> > > kr.linkedin.com/in/dongjinleekr
> > > > speakerdeck:
> > > > speakerdeck.com/dongjin
> > > > *
> > > >
> > >
> >
>


Re: [VOTE] KIP-746: Revise KRaft Metadata Records

2021-06-10 Thread Colin McCabe
Hi all,

Thanks for the discussion and votes.

The vote passes with binding +1s from:
Jason Gustafson
Jun Rao
David Arthur

and a non-binding +1 from
Israel Ekpo

best,
Colin


On Wed, Jun 9, 2021, at 18:15, David Arthur wrote:
> Thanks, Colin, looks good to me. +1
> 
> On Wed, Jun 9, 2021 at 8:32 PM Israel Ekpo  wrote:
> 
> > Makes sense to me
> >
> > +1 (non-binding)
> >
> >
> > On Wed, Jun 9, 2021 at 7:05 PM Jun Rao  wrote:
> >
> > > Hi, Colin,
> > >
> > > Thanks for the KIP. +1 from me.
> > >
> > > Jun
> > >
> > > On Wed, Jun 9, 2021 at 9:36 AM Jason Gustafson
> >  > > >
> > > wrote:
> > >
> > > > +1 Thanks Colin!
> > > >
> > > > On Thu, Jun 3, 2021 at 4:30 PM Colin McCabe 
> > wrote:
> > > >
> > > > > Hi all,
> > > > >
> > > > > I'd like to call a vote for KIP-746: Revise KRaft Metadata Records.
> > > This
> > > > > is a minor KIP which revises the KRaft metadata records slightly for
> > > the
> > > > > upcoming 3.0 release.
> > > > >
> > > > > The KIP is at: https://cwiki.apache.org/confluence/x/34zOCg
> > > > >
> > > > > best,
> > > > > Colin
> > > > >
> > > >
> > >
> >
> 
> 
> -- 
> David Arthur
> 


Re: [VOTE] KIP-618: Exactly-once support for source connectors

2021-06-10 Thread Ismael Juma
One concern I have is that we are not introducing a request for the fencing
and implementing that logic in the admin client directly. I would prefer a
request in the txn coordinator with the right semantics.

Ismael

On Thu, Jun 10, 2021, 7:46 AM Gwen Shapira 
wrote:

> I'm supportive of the feature and the interface details discussed in the
> discussion thread. I just want to clarify that I'm voting for the last
> version discussed in the thread - that includes two phase upgrade and no
> breaking changes in 3.0.
>
> +1 (binding)
>
>
> On Wed, Jun 9, 2021, 5:32 AM Chris Egerton 
> wrote:
>
> > Hi all,
> >
> > Friendly reminder that the KIP freeze is today; please cast your votes if
> > you'd like to see this feature introduced in time for 3.0.
> >
> > Cheers,
> >
> > Chris
> >
> > On Mon, Jun 7, 2021 at 1:49 AM Dongjin Lee  wrote:
> >
> > > +1 (non-binding).
> > >
> > > Thanks,
> > > Dongjin
> > >
> > > On Fri, Jun 4, 2021 at 2:35 PM Ryanne Dolan 
> > wrote:
> > >
> > > > +1 (non-binding)
> > > >
> > > > On Thu, Jun 3, 2021, 10:23 AM Chris Egerton
> >  > > >
> > > > wrote:
> > > >
> > > > > Hi all,
> > > > >
> > > > > I'd like to call for a vote on KIP-618, which adds support for
> > > > exactly-once
> > > > > delivery guarantees for source connectors in the Kafka Connect
> > > framework.
> > > > >
> > > > > I suspect there might be a little more discussion to be had but
> with
> > > the
> > > > > KIP freeze deadline approaching, I wanted to give anyone following
> > > along
> > > > > the chance to cast a +1 as soon as they feel that we've gotten to a
> > > > > reasonable state.
> > > > >
> > > > > The KIP:
> > > > >
> > > > >
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-618%3A+Exactly-Once+Support+for+Source+Connectors
> > > > >
> > > > > The discussion thread:
> > > > >
> > > > >
> > > >
> > >
> >
> https://mail-archives.apache.org/mod_mbox/kafka-dev/202005.mbox/%3CCAMdOrUX-VK5OSB3OOdJNXW_YKEJH9FjQZ4eyzr2GXUhSeDnF3Q%40mail.gmail.com%3E
> > > > >
> > > > > Cheers,
> > > > >
> > > > > Chris
> > > > >
> > > >
> > >
> > >
> > > --
> > > *Dongjin Lee*
> > >
> > > *A hitchhiker in the mathematical world.*
> > >
> > >
> > >
> > > *github:  github.com/dongjinleekr
> > > keybase:
> > https://keybase.io/dongjinleekr
> > > linkedin:
> > kr.linkedin.com/in/dongjinleekr
> > > speakerdeck:
> > > speakerdeck.com/dongjin
> > > *
> > >
> >
>


Re: [VOTE] KIP-745: Connect API to restart connector and tasks

2021-06-10 Thread Tom Bentley
Hi Randall,

Thanks for the KIP, +1 (binding).

Kind regards,

Tom

On Thu, Jun 10, 2021 at 4:09 AM Dongjin Lee  wrote:

> +1 (non-binding).
>
> As of present:
>
> - binding: +2 (Randall, Konstantine)
> - non-binding: +3 (Ryanne, Kalpesh, Dongjin)
>
> We need one more +1 binding.
>
> Thanks,
> Dongjin
>
> On Tue, Jun 8, 2021 at 6:31 AM Kalpesh Patel 
> wrote:
>
> > +1 (non-binding)
> >
> > Regards
> > -Kalpesh
> >
> > On Mon, Jun 7, 2021 at 3:10 PM Ryanne Dolan 
> wrote:
> >
> > > +1 (non-binding)
> > >
> > > Ryanne
> > >
> > > On Mon, Jun 7, 2021, 3:03 PM Konstantine Karantasis
> > >  wrote:
> > >
> > > > Thanks Randall.
> > > >
> > > > +1 (binding)
> > > >
> > > > Konstantine
> > > >
> > > > On Mon, Jun 7, 2021 at 12:47 PM Randall Hauch 
> > wrote:
> > > >
> > > > > Hello all,
> > > > >
> > > > > I would like to start a vote on KIP-745:
> > > > >
> > > > >
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-745%3A+Connect+API+to+restart+connector+and+tasks
> > > > >
> > > > > +1 (binding) from myself.
> > > > >
> > > > > Thanks, and best regards!
> > > > >
> > > > > Randall
> > > > >
> > > >
> > >
> >
>
>
> --
> *Dongjin Lee*
>
> *A hitchhiker in the mathematical world.*
>
>
>
> *github:  github.com/dongjinleekr
> keybase: https://keybase.io/dongjinleekr
> linkedin: kr.linkedin.com/in/dongjinleekr
> speakerdeck:
> speakerdeck.com/dongjin
> *
>


Re: [VOTE] KIP-618: Exactly-once support for source connectors

2021-06-10 Thread Gwen Shapira
I'm supportive of the feature and the interface details discussed in the
discussion thread. I just want to clarify that I'm voting for the last
version discussed in the thread - that includes two phase upgrade and no
breaking changes in 3.0.

+1 (binding)


On Wed, Jun 9, 2021, 5:32 AM Chris Egerton 
wrote:

> Hi all,
>
> Friendly reminder that the KIP freeze is today; please cast your votes if
> you'd like to see this feature introduced in time for 3.0.
>
> Cheers,
>
> Chris
>
> On Mon, Jun 7, 2021 at 1:49 AM Dongjin Lee  wrote:
>
> > +1 (non-binding).
> >
> > Thanks,
> > Dongjin
> >
> > On Fri, Jun 4, 2021 at 2:35 PM Ryanne Dolan 
> wrote:
> >
> > > +1 (non-binding)
> > >
> > > On Thu, Jun 3, 2021, 10:23 AM Chris Egerton
>  > >
> > > wrote:
> > >
> > > > Hi all,
> > > >
> > > > I'd like to call for a vote on KIP-618, which adds support for
> > > exactly-once
> > > > delivery guarantees for source connectors in the Kafka Connect
> > framework.
> > > >
> > > > I suspect there might be a little more discussion to be had but with
> > the
> > > > KIP freeze deadline approaching, I wanted to give anyone following
> > along
> > > > the chance to cast a +1 as soon as they feel that we've gotten to a
> > > > reasonable state.
> > > >
> > > > The KIP:
> > > >
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-618%3A+Exactly-Once+Support+for+Source+Connectors
> > > >
> > > > The discussion thread:
> > > >
> > > >
> > >
> >
> https://mail-archives.apache.org/mod_mbox/kafka-dev/202005.mbox/%3CCAMdOrUX-VK5OSB3OOdJNXW_YKEJH9FjQZ4eyzr2GXUhSeDnF3Q%40mail.gmail.com%3E
> > > >
> > > > Cheers,
> > > >
> > > > Chris
> > > >
> > >
> >
> >
> > --
> > *Dongjin Lee*
> >
> > *A hitchhiker in the mathematical world.*
> >
> >
> >
> > *github:  github.com/dongjinleekr
> > keybase:
> https://keybase.io/dongjinleekr
> > linkedin:
> kr.linkedin.com/in/dongjinleekr
> > speakerdeck:
> > speakerdeck.com/dongjin
> > *
> >
>


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

2021-06-10 Thread Apache Jenkins Server
See 


Changes:


--
[...truncated 476764 lines...]
[2021-06-10T13:54:40.536Z] 
[2021-06-10T13:54:40.536Z] ZooKeeperClientTest > 
testZooKeeperStateChangeRateMetrics() PASSED
[2021-06-10T13:54:40.536Z] 
[2021-06-10T13:54:40.536Z] ZooKeeperClientTest > 
testZNodeChangeHandlerForDeletion() STARTED
[2021-06-10T13:54:41.391Z] 
[2021-06-10T13:54:41.391Z] ZooKeeperClientTest > 
testZNodeChangeHandlerForDeletion() PASSED
[2021-06-10T13:54:41.391Z] 
[2021-06-10T13:54:41.391Z] ZooKeeperClientTest > testGetAclNonExistentZNode() 
STARTED
[2021-06-10T13:54:41.391Z] 
[2021-06-10T13:54:41.391Z] ZooKeeperClientTest > testGetAclNonExistentZNode() 
PASSED
[2021-06-10T13:54:41.391Z] 
[2021-06-10T13:54:41.391Z] ZooKeeperClientTest > 
testStateChangeHandlerForAuthFailure() STARTED
[2021-06-10T13:54:42.585Z] 
[2021-06-10T13:54:42.585Z] ZooKeeperClientTest > 
testStateChangeHandlerForAuthFailure() PASSED
[2021-06-10T13:54:42.585Z] 
[2021-06-10T13:54:42.585Z] SaslPlainSslEndToEndAuthorizationTest > 
testNoConsumeWithoutDescribeAclViaAssign() PASSED
[2021-06-10T13:54:42.585Z] 
[2021-06-10T13:54:42.585Z] SaslPlainSslEndToEndAuthorizationTest > 
testNoGroupAcl() STARTED
[2021-06-10T13:54:53.527Z] 
[2021-06-10T13:54:53.527Z] SaslPlainSslEndToEndAuthorizationTest > 
testNoGroupAcl() PASSED
[2021-06-10T13:54:53.527Z] 
[2021-06-10T13:54:53.527Z] SaslPlainSslEndToEndAuthorizationTest > 
testNoProduceWithDescribeAcl() STARTED
[2021-06-10T13:55:04.533Z] 
[2021-06-10T13:55:04.533Z] SaslPlainSslEndToEndAuthorizationTest > 
testNoProduceWithDescribeAcl() PASSED
[2021-06-10T13:55:04.533Z] 
[2021-06-10T13:55:04.533Z] SaslPlainSslEndToEndAuthorizationTest > 
testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl() STARTED
[2021-06-10T13:55:18.895Z] 
[2021-06-10T13:55:18.895Z] SaslPlainSslEndToEndAuthorizationTest > 
testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl() PASSED
[2021-06-10T13:55:18.895Z] 
[2021-06-10T13:55:18.895Z] SaslPlainSslEndToEndAuthorizationTest > 
testProduceConsumeViaSubscribe() STARTED
[2021-06-10T13:55:29.474Z] 
[2021-06-10T13:55:29.474Z] SaslPlainSslEndToEndAuthorizationTest > 
testProduceConsumeViaSubscribe() PASSED
[2021-06-10T13:55:29.474Z] 
[2021-06-10T13:55:29.474Z] SaslPlainSslEndToEndAuthorizationTest > 
testTwoConsumersWithDifferentSaslCredentials() STARTED
[2021-06-10T13:55:39.034Z] 
[2021-06-10T13:55:39.034Z] SaslPlainSslEndToEndAuthorizationTest > 
testTwoConsumersWithDifferentSaslCredentials() PASSED
[2021-06-10T13:55:39.034Z] 
[2021-06-10T13:55:39.034Z] SaslPlainSslEndToEndAuthorizationTest > testAcls() 
STARTED
[2021-06-10T13:55:47.274Z] 
[2021-06-10T13:55:47.274Z] SaslPlainSslEndToEndAuthorizationTest > testAcls() 
PASSED
[2021-06-10T13:55:47.274Z] 
[2021-06-10T13:55:47.274Z] SaslSslAdminIntegrationTest > 
testCreateDeleteTopics() STARTED
[2021-06-10T13:56:41.191Z] 
[2021-06-10T13:56:41.191Z] SaslSslAdminIntegrationTest > 
testCreateDeleteTopics() PASSED
[2021-06-10T13:56:41.191Z] 
[2021-06-10T13:56:41.191Z] SaslSslAdminIntegrationTest > 
testAuthorizedOperations() STARTED
[2021-06-10T13:57:28.719Z] 
[2021-06-10T13:57:28.719Z] SaslSslAdminIntegrationTest > 
testAuthorizedOperations() PASSED
[2021-06-10T13:57:28.719Z] 
[2021-06-10T13:57:28.719Z] SaslSslAdminIntegrationTest > testAclDescribe() 
STARTED
[2021-06-10T13:58:08.694Z] 
[2021-06-10T13:58:08.694Z] SaslSslAdminIntegrationTest > testAclDescribe() 
PASSED
[2021-06-10T13:58:08.694Z] 
[2021-06-10T13:58:08.694Z] SaslSslAdminIntegrationTest > 
testLegacyAclOpsNeverAffectOrReturnPrefixed() STARTED
[2021-06-10T13:58:55.656Z] 
[2021-06-10T13:58:55.656Z] SaslSslAdminIntegrationTest > 
testLegacyAclOpsNeverAffectOrReturnPrefixed() PASSED
[2021-06-10T13:58:55.656Z] 
[2021-06-10T13:58:55.656Z] SaslSslAdminIntegrationTest > 
testCreateTopicsResponseMetadataAndConfig() STARTED
[2021-06-10T13:59:42.209Z] 
[2021-06-10T13:59:42.209Z] SaslSslAdminIntegrationTest > 
testCreateTopicsResponseMetadataAndConfig() PASSED
[2021-06-10T13:59:42.209Z] 
[2021-06-10T13:59:42.209Z] SaslSslAdminIntegrationTest > 
testAttemptToCreateInvalidAcls() STARTED
[2021-06-10T14:00:28.433Z] 
[2021-06-10T14:00:28.433Z] SaslSslAdminIntegrationTest > 
testAttemptToCreateInvalidAcls() PASSED
[2021-06-10T14:00:28.433Z] 
[2021-06-10T14:00:28.433Z] SaslSslAdminIntegrationTest > 
testAclAuthorizationDenied() STARTED
[2021-06-10T14:01:09.533Z] 
[2021-06-10T14:01:09.533Z] SaslSslAdminIntegrationTest > 
testAclAuthorizationDenied() PASSED
[2021-06-10T14:01:09.533Z] 
[2021-06-10T14:01:09.533Z] SaslSslAdminIntegrationTest > testAclOperations() 
STARTED
[2021-06-10T14:01:50.595Z] 
[2021-06-10T14:01:50.595Z] SaslSslAdminIntegrationTest > testAclOperations() 
PASSED
[2021-06-10T14:01:50.595Z] 
[2021-06-10T14:01:50.595Z] SaslSslAdminIntegrationTest > testAclOperations2() 
STARTED
[2021-06-10T14:02:33.474Z] 
[2021-06-10T14:02:33.474Z] SaslSslAdminIntegrationTest > testAclOperations2() 

[jira] [Created] (KAFKA-12930) Deprecate support for Scala 2.12 in Kafka 3.0

2021-06-10 Thread Ismael Juma (Jira)
Ismael Juma created KAFKA-12930:
---

 Summary: Deprecate support for Scala 2.12 in Kafka 3.0
 Key: KAFKA-12930
 URL: https://issues.apache.org/jira/browse/KAFKA-12930
 Project: Kafka
  Issue Type: Sub-task
Reporter: Ismael Juma
Assignee: Ismael Juma
 Fix For: 3.0.0






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


[jira] [Created] (KAFKA-12929) KIP-750: Deprecate Java 8 in Kafka 3.0

2021-06-10 Thread Ismael Juma (Jira)
Ismael Juma created KAFKA-12929:
---

 Summary: KIP-750: Deprecate Java 8 in Kafka 3.0
 Key: KAFKA-12929
 URL: https://issues.apache.org/jira/browse/KAFKA-12929
 Project: Kafka
  Issue Type: Sub-task
Reporter: Ismael Juma
Assignee: Ismael Juma
 Fix For: 3.0.0






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


Re: [VOTE] KIP-751: Drop support for Scala 2.12 in Kafka 4.0 (deprecate in 3.0)

2021-06-10 Thread Ismael Juma
Thanks everyone for the votes and discussion. The KIP passed with:

6 binding +1s:
1. Konstantine K
2. Bruno C
3. Mickael M
4. David J
5. Tom B
6. me

5 non-binding +1s:
1. Josep P
2. Satish D
3. Israel E
4. Luke C
5. Mathew D

Ismael

On Mon, Jun 7, 2021 at 6:48 AM Ismael Juma  wrote:

> Since the goal is to provide ample warning regarding the future removal of
> Scala 2.12 and the change we're proposing for 3.0 is simply a documentation
> update, I am starting the vote:
>
> https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=181308218
>
> If there are concerns or objections, feel free to point them out in this
> thread or the discuss thread.
>
> Ismael
>


Re: [VOTE] KIP-750: Drop support for Java 8 in Kafka 4.0 (deprecate in 3.0)

2021-06-10 Thread Ismael Juma
Thanks all for the discussion and votes. The KIP passed with:

8 +1 binding votes:
1. Konstantine K
2. Bruno C
3, Mickael M
4. Tom B
5. Colin M
6. David J
7. Rajini S
8. me

7 +1 non-binding votes:
1. Josep P
2. Dongjin L
3. Satish D
4. Ryanne D
5. Luke C
6. Matthew D
7. Israel E


On Mon, Jun 7, 2021 at 6:50 AM Ismael Juma  wrote:

> Since the goal is to provide ample warning regarding the future removal of
> Java 8 support and the change we're proposing for 3.0 is simply a
> documentation update, I am starting the vote:
>
> https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=181308223
>
> If there are concerns or objections, feel free to point them out in this
> thread or the discuss thread.
>
> Ismael
>


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

2021-06-10 Thread Apache Jenkins Server
See 


Changes:


--
[...truncated 472083 lines...]
[2021-06-10T11:36:49.318Z] 
[2021-06-10T11:36:49.318Z] ZooKeeperClientTest > 
testGetChildrenExistingZNodeWithChildren() PASSED
[2021-06-10T11:36:49.318Z] 
[2021-06-10T11:36:49.318Z] ZooKeeperClientTest > testSetDataExistingZNode() 
STARTED
[2021-06-10T11:36:49.318Z] 
[2021-06-10T11:36:49.318Z] ZooKeeperClientTest > testSetDataExistingZNode() 
PASSED
[2021-06-10T11:36:49.318Z] 
[2021-06-10T11:36:49.318Z] ZooKeeperClientTest > 
testZNodeChildChangeHandlerForChildChangeNotTriggered() STARTED
[2021-06-10T11:36:49.318Z] 
[2021-06-10T11:36:49.318Z] ZooKeeperClientTest > 
testZNodeChildChangeHandlerForChildChangeNotTriggered() PASSED
[2021-06-10T11:36:49.318Z] 
[2021-06-10T11:36:49.318Z] ZooKeeperClientTest > testMixedPipeline() STARTED
[2021-06-10T11:36:49.318Z] 
[2021-06-10T11:36:49.318Z] ZooKeeperClientTest > testMixedPipeline() PASSED
[2021-06-10T11:36:49.318Z] 
[2021-06-10T11:36:49.318Z] ZooKeeperClientTest > testGetDataExistingZNode() 
STARTED
[2021-06-10T11:36:49.318Z] 
[2021-06-10T11:36:49.318Z] ZooKeeperClientTest > testGetDataExistingZNode() 
PASSED
[2021-06-10T11:36:49.318Z] 
[2021-06-10T11:36:49.318Z] ZooKeeperClientTest > testDeleteExistingZNode() 
STARTED
[2021-06-10T11:36:50.351Z] 
[2021-06-10T11:36:50.351Z] ZooKeeperClientTest > testDeleteExistingZNode() 
PASSED
[2021-06-10T11:36:50.352Z] 
[2021-06-10T11:36:50.352Z] ZooKeeperClientTest > testSessionExpiry() STARTED
[2021-06-10T11:36:52.417Z] 
[2021-06-10T11:36:52.417Z] ZooKeeperClientTest > testSessionExpiry() PASSED
[2021-06-10T11:36:52.417Z] 
[2021-06-10T11:36:52.417Z] ZooKeeperClientTest > testSetDataNonExistentZNode() 
STARTED
[2021-06-10T11:36:52.417Z] 
[2021-06-10T11:36:52.417Z] ZooKeeperClientTest > testSetDataNonExistentZNode() 
PASSED
[2021-06-10T11:36:52.417Z] 
[2021-06-10T11:36:52.417Z] ZooKeeperClientTest > testConnectionViaNettyClient() 
STARTED
[2021-06-10T11:36:53.619Z] 
[2021-06-10T11:36:53.619Z] ZooKeeperClientTest > testConnectionViaNettyClient() 
PASSED
[2021-06-10T11:36:53.619Z] 
[2021-06-10T11:36:53.619Z] ZooKeeperClientTest > testDeleteNonExistentZNode() 
STARTED
[2021-06-10T11:36:53.619Z] 
[2021-06-10T11:36:53.619Z] ZooKeeperClientTest > testDeleteNonExistentZNode() 
PASSED
[2021-06-10T11:36:53.619Z] 
[2021-06-10T11:36:53.619Z] ZooKeeperClientTest > testExistsExistingZNode() 
STARTED
[2021-06-10T11:36:53.619Z] 
[2021-06-10T11:36:53.619Z] ZooKeeperClientTest > testExistsExistingZNode() 
PASSED
[2021-06-10T11:36:53.619Z] 
[2021-06-10T11:36:53.619Z] ZooKeeperClientTest > 
testZooKeeperStateChangeRateMetrics() STARTED
[2021-06-10T11:36:53.619Z] 
[2021-06-10T11:36:53.619Z] ZooKeeperClientTest > 
testZooKeeperStateChangeRateMetrics() PASSED
[2021-06-10T11:36:53.619Z] 
[2021-06-10T11:36:53.619Z] ZooKeeperClientTest > 
testZNodeChangeHandlerForDeletion() STARTED
[2021-06-10T11:36:54.935Z] 
[2021-06-10T11:36:54.935Z] ZooKeeperClientTest > 
testZNodeChangeHandlerForDeletion() PASSED
[2021-06-10T11:36:54.935Z] 
[2021-06-10T11:36:54.935Z] ZooKeeperClientTest > testGetAclNonExistentZNode() 
STARTED
[2021-06-10T11:36:54.935Z] 
[2021-06-10T11:36:54.935Z] ZooKeeperClientTest > testGetAclNonExistentZNode() 
PASSED
[2021-06-10T11:36:54.935Z] 
[2021-06-10T11:36:54.935Z] ZooKeeperClientTest > 
testStateChangeHandlerForAuthFailure() STARTED
[2021-06-10T11:36:54.935Z] 
[2021-06-10T11:36:54.935Z] ZooKeeperClientTest > 
testStateChangeHandlerForAuthFailure() PASSED
[2021-06-10T11:36:55.967Z] 
[2021-06-10T11:36:55.967Z] SaslSslAdminIntegrationTest > 
testCreateTopicsResponseMetadataAndConfig() PASSED
[2021-06-10T11:36:55.967Z] 
[2021-06-10T11:36:55.967Z] SaslSslAdminIntegrationTest > 
testAttemptToCreateInvalidAcls() STARTED
[2021-06-10T11:37:44.472Z] 
[2021-06-10T11:37:44.472Z] SaslSslAdminIntegrationTest > 
testAttemptToCreateInvalidAcls() PASSED
[2021-06-10T11:37:44.472Z] 
[2021-06-10T11:37:44.472Z] SaslSslAdminIntegrationTest > 
testAclAuthorizationDenied() STARTED
[2021-06-10T11:38:31.599Z] 
[2021-06-10T11:38:31.599Z] SaslSslAdminIntegrationTest > 
testAclAuthorizationDenied() PASSED
[2021-06-10T11:38:31.599Z] 
[2021-06-10T11:38:31.599Z] SaslSslAdminIntegrationTest > testAclOperations() 
STARTED
[2021-06-10T11:39:13.214Z] 
[2021-06-10T11:39:13.214Z] SaslSslAdminIntegrationTest > testAclOperations() 
PASSED
[2021-06-10T11:39:13.214Z] 
[2021-06-10T11:39:13.214Z] SaslSslAdminIntegrationTest > testAclOperations2() 
STARTED
[2021-06-10T11:40:07.638Z] 
[2021-06-10T11:40:07.638Z] SaslSslAdminIntegrationTest > testAclOperations2() 
PASSED
[2021-06-10T11:40:07.638Z] 
[2021-06-10T11:40:07.638Z] SaslSslAdminIntegrationTest > testAclDelete() STARTED
[2021-06-10T11:41:01.816Z] 
[2021-06-10T11:41:01.816Z] SaslSslAdminIntegrationTest > testAclDelete() PASSED
[2021-06-10T11:41:01.816Z] 
[2021-06-10T11:41:01.816Z] TransactionsTest > testBumpTransactionalEpoch() 
STARTED

Review of the pull-request

2021-06-10 Thread Maksim Yakunin
Hey, guys!

I opened my first pull-request about two weeks ago.
Could you have a look at it, please?
Here it is: https://github.com/apache/kafka/pull/10775

Many thanks in advance!

-- 

*Best regards, Maksim Iakunin.*

*Phone: +7 (915) 023-21-45**Email: yakun...@gmail.com *


Re: [VOTE] KIP-750: Drop support for Java 8 in Kafka 4.0 (deprecate in 3.0)

2021-06-10 Thread Rajini Sivaram
+1 (binding)

Thanks for the KIP, Ismael!

Regards,

Rajini


On Thu, Jun 10, 2021 at 8:07 AM David Jacot 
wrote:

> +1 (binding), thanks!
>
> On Thu, Jun 10, 2021 at 3:17 AM Colin McCabe  wrote:
>
> > +1 (binding).
> >
> > Looking forward to 4.0 (heh)
> >
> > best,
> > Colin
> >
> > On Wed, Jun 9, 2021, at 02:45, Tom Bentley wrote:
> > > Hi Ismael,
> > >
> > > Thanks for the KIP, +1 (binding).
> > >
> > > Cheers,
> > >
> > > Tom
> > >
> > > On Wed, Jun 9, 2021 at 10:04 AM Mickael Maison <
> mickael.mai...@gmail.com
> > >
> > > wrote:
> > >
> > > > +1 (binding)
> > > > Thanks
> > > >
> > > > On Wed, Jun 9, 2021 at 1:25 AM Israel Ekpo 
> > wrote:
> > > > >
> > > > > This is great!
> > > > >
> > > > > Thanks for the KIP
> > > > >
> > > > > +1 (non-binding)
> > > > >
> > > > >
> > > > > On Tue, Jun 8, 2021 at 3:13 AM Bruno Cadonna 
> > wrote:
> > > > >
> > > > > > Hi Ismael,
> > > > > >
> > > > > > Thank you for the KIP!
> > > > > >
> > > > > > +1 (binding)
> > > > > >
> > > > > > Best,
> > > > > > Bruno
> > > > > >
> > > > > > On 08.06.21 10:11, Matthew de Detrich wrote:
> > > > > > > +1 (non binding)
> > > > > > >
> > > > > > > On Tue, Jun 8, 2021 at 4:48 AM Luke Chen 
> > wrote:
> > > > > > >
> > > > > > >> Hi Ismael,
> > > > > > >> Thanks for the KIP.
> > > > > > >> +1 (non-binding)
> > > > > > >>
> > > > > > >> Thanks.
> > > > > > >> Luke
> > > > > > >>
> > > > > > >> On Tue, Jun 8, 2021 at 7:18 AM Konstantine Karantasis
> > > > > > >>  wrote:
> > > > > > >>
> > > > > > >>> Thanks for the KIP Ismael. I agree that giving an early
> enough
> > > > > > >> deprecation
> > > > > > >>> notice for an upcoming change like this one and doing so in a
> > major
> > > > > > >> release
> > > > > > >>> is best in this case.
> > > > > > >>>
> > > > > > >>> +1 (binding)
> > > > > > >>>
> > > > > > >>> Konstantine
> > > > > > >>>
> > > > > > >>> On Mon, Jun 7, 2021 at 7:30 AM Ryanne Dolan <
> > ryannedo...@gmail.com
> > > > >
> > > > > > >> wrote:
> > > > > > >>>
> > > > > >  +1 (non-binding)
> > > > > > 
> > > > > >  Ryanne
> > > > > > 
> > > > > >  On Mon, Jun 7, 2021, 9:26 AM Satish Duggana <
> > > > satish.dugg...@gmail.com
> > > > > > >
> > > > > >  wrote:
> > > > > > 
> > > > > > > +1 (non-binding)
> > > > > > >
> > > > > > > On Mon, 7 Jun 2021 at 19:30, Dongjin Lee <
> dong...@apache.org
> > >
> > > > wrote:
> > > > > > >
> > > > > > >> +1 (non-binding)
> > > > > > >>
> > > > > > >> As a note: I think the exact removal schedule may be
> > changed.
> > > > > > >>
> > > > > > >> Best,
> > > > > > >> Dongjin
> > > > > > >>
> > > > > > >> On Mon, Jun 7, 2021, 10:56 PM Josep Prat
> > > > > > >>  > > > > > 
> > > > > > >> wrote:
> > > > > > >>
> > > > > > >>> Thanks Ismael, it's a +1 (non-binding) from
> > > > > > <
> > > >
> >
> https://www.google.com/maps/search/Ismael,+it's+a+%2B1+(non-binding)+from?entry=gmail=g
> > > > >
> > > > > > my side,
> > > > > > >>>
> > > > > > >>>
> > > > > > >>> Best,
> > > > > > >>>
> > > > > > >>> ———
> > > > > > >>> Josep Prat
> > > > > > >>>
> > > > > > >>> Aiven Deutschland GmbH
> > > > > > >>>
> > > > > > >>> Immanuelkirchstraße 26, 10405 Berlin
> > > > > > >>>
> > > > > > >>> Amtsgericht Charlottenburg, HRB 209739 B
> > > > > > >>>
> > > > > > >>> Geschäftsführer: Oskari Saarenmaa & Hannu Valtonen
> > > > > > >>>
> > > > > > >>> m: +491715557497
> > > > > > >>>
> > > > > > >>> w: aiven.io
> > > > > > >>>
> > > > > > >>> e: josep.p...@aiven.io
> > > > > > >>>
> > > > > > >>> On Mon, Jun 7, 2021, 15:51 Ismael Juma <
> ism...@juma.me.uk>
> > > > > > >> wrote:
> > > > > > >>>
> > > > > >  Since the goal is to provide ample warning regarding the
> > > > future
> > > > > > > removal
> > > > > > >>> of
> > > > > >  Java 8 support and the change we're proposing for 3.0 is
> > > > > > >> simply a
> > > > > >  documentation update, I am starting the vote:
> > > > > > 
> > > > > > 
> > > > > > >>>
> > > > > > >>
> > > > > > >
> > > > > > 
> > > > > > >>>
> > > > > > >>
> > > > > >
> > > >
> >
> https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=181308223
> > > > > > 
> > > > > >  If there are concerns or objections, feel free to point
> > them
> > > > > > >> out
> > > > > > >>> in
> > > > > > >> this
> > > > > >  thread or the discuss thread.
> > > > > > 
> > > > > >  Ismael
> > > > > > 
> > > > > > >>>
> > > > > > >>
> > > > > > >
> > > > > > 
> > > > > > >>>
> > > > > > >>
> > > > > > >
> > > > > > >
> > > > > >
> > > >
> > > >
> > >
> >
>


[jira] [Created] (KAFKA-12928) Add a check whether the Task's statestore is actually a directory

2021-06-10 Thread Dongjin Lee (Jira)
Dongjin Lee created KAFKA-12928:
---

 Summary: Add a check whether the Task's statestore is actually a 
directory
 Key: KAFKA-12928
 URL: https://issues.apache.org/jira/browse/KAFKA-12928
 Project: Kafka
  Issue Type: Bug
  Components: streams
Reporter: Dongjin Lee
Assignee: Dongjin Lee


I found this problem while working on 
[KAFKA-10585|https://issues.apache.org/jira/browse/KAFKA-10585].

As of present, StateDirectory checks whether the Task's statestore directory 
exists and, if not, creates it. Since it does not check whether it is actually 
a directory, for example, if a regular file occupies the Task's statestore's 
path, the validation logic may be detoured.



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


Re: [DISCUSS] KIP-726: Make the CooperativeStickyAssignor as the default assignor

2021-06-10 Thread Luke Chen
Hi Ryan,
Thanks for your good comments. I've listed your comments in "Rejected
Alternatives" in KIP.

1. Some cooperative-sticky related defects might not free before V3.0
→ We've marked important defects as blocker for V3.0, ex: KAFKA-12896.
Please raise any important defect if you found any.

2. Cooperative-sticky assignor is also very new for C/C++ users in
librdkafka, so not many in that community have tried incremental
cooperative yet. And bugs are still recently being worked out there too.
→ Thanks for raising this. I checked this library and found currently
only 1 cooperative-sticky related bug open, which is good (10 bugs are
fixed). Anyway, I think the clients can always change the assignor to other
assignors if there are still bugs in the library.

Thank you.
Luke

On Thu, Jun 10, 2021 at 12:40 PM Ryan Leslie  wrote:

> Thanks for the quick replies, Luke and Sophie.
>
> I've not voted, but I agree with accepting the KIP since it's a superior
> feature. I was just reacting mostly to this comment since it didn't mention
> open issues:
>
> > > > Thanks Luke. We may as well get this KIP in to 3.0 so that we can
> fully
> > > > enable cooperative rebalancing
> > > > by default in 3.0 if we have KAFKA-12477 done in time, and if we
> don't
> > > then
> > > > there's no harm as it's
> > > > not going to change the behavior.
>
> But I see now, as Luke said, that the main issue is already considered a
> blocker so it was assumed. Though, I did also wonder if any bugs that may
> have existed since several version ago should actually hold up 3.0, which I
> know is especially about moving away from ZooKeeper.
>
> My sentiment was just that during many release cycles of Kafka since
> cooperative was introduced, there have been issues discovered. And that
> makes sense given that the implementation was complex and quite a lot of
> code changed to make it happen. Hopefully the last of the kinks will have
> been worked out before 3.0. I just wondered if it should be a default in
> 3.0 if it hasn't yet been free of defects for a significant period of time.
> KIP-726 doesn't list any drawbacks for cooperative-sticky, but perhaps this
> is one. I also appreciate that it's already successfully adopted by many,
> particularly streams / connect users. But this may also be where the
> feature has the most benefit due to expensive setup/teardown during
> rebalance, and stop-the-world can be less of a concern for many "regular
> consumers".
>
> This is probably irrelevant here, but another thing to mention is that the
> feature is also very new for C/C++ users in librdkafka, so not many in that
> community have tried incremental cooperative yet. And bugs are still
> recently being worked out there too.
>
> Just playing devil's advocate here, sorry to come across as a negative
> nancy!
>
> On 2021/06/09 00:05:41, Sophie Blee-Goldman 
> wrote:
> > Hey Ryan,
> >
> > Yes, I believe any open bugs regarding the cooperative-sticky assignor
> > should be considered as blockers
> > to it being made the default, if not blockers to the release in general.
> I
> > don't think they need to block the
> > acceptance of this KIP, though, just possibly the implementation of it.
>


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

2021-06-10 Thread Apache Jenkins Server
See 


Changes:


--
[...truncated 479163 lines...]
[Pipeline] sh
[2021-06-10T08:11:48.668Z] + mvn compile
[2021-06-10T08:11:49.686Z] [INFO] Scanning for projects...
[2021-06-10T08:11:49.686Z] [INFO] 
[2021-06-10T08:11:49.686Z] [INFO] -< 
streams.examples:streams.examples >--
[2021-06-10T08:11:49.686Z] [INFO] Building Kafka Streams Quickstart :: Java 0.1
[2021-06-10T08:11:49.686Z] [INFO] [ jar 
]-
[2021-06-10T08:11:50.705Z] [INFO] 
[2021-06-10T08:11:50.705Z] [INFO] --- maven-resources-plugin:2.6:resources 
(default-resources) @ streams.examples ---
[2021-06-10T08:11:50.705Z] [INFO] Using 'UTF-8' encoding to copy filtered 
resources.
[2021-06-10T08:11:50.705Z] [INFO] Copying 1 resource
[2021-06-10T08:11:50.705Z] [INFO] 
[2021-06-10T08:11:50.705Z] [INFO] --- maven-compiler-plugin:3.1:compile 
(default-compile) @ streams.examples ---
[2021-06-10T08:11:51.900Z] 
[2021-06-10T08:11:51.901Z] SaslSslAdminIntegrationTest > testAclDelete() PASSED
[2021-06-10T08:11:51.901Z] 
[2021-06-10T08:11:51.901Z] TransactionsTest > testBumpTransactionalEpoch() 
STARTED
[2021-06-10T08:11:53.862Z] [INFO] Changes detected - recompiling the module!
[2021-06-10T08:11:53.862Z] [INFO] Compiling 3 source files to 
/home/jenkins/workspace/Kafka_kafka_trunk/streams/quickstart/test-streams-archetype/streams.examples/target/classes
[2021-06-10T08:11:55.838Z] [INFO] 

[2021-06-10T08:11:55.838Z] [INFO] BUILD SUCCESS
[2021-06-10T08:11:55.838Z] [INFO] 

[2021-06-10T08:11:55.838Z] [INFO] Total time:  6.517 s
[2021-06-10T08:11:55.838Z] [INFO] Finished at: 2021-06-10T08:11:55Z
[2021-06-10T08:11:55.838Z] [INFO] 

[Pipeline] }
[Pipeline] // dir
[Pipeline] }
[Pipeline] // dir
[Pipeline] }
[Pipeline] // dir
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] // node
[Pipeline] }
[Pipeline] // timestamps
[Pipeline] }
[Pipeline] // timeout
[Pipeline] }
[Pipeline] // stage
[Pipeline] }
[2021-06-10T08:12:09.723Z] 
[2021-06-10T08:12:09.723Z] TransactionsTest > testBumpTransactionalEpoch() 
PASSED
[2021-06-10T08:12:09.723Z] 
[2021-06-10T08:12:09.723Z] TransactionsTest > 
testSendOffsetsWithGroupMetadata() STARTED
[2021-06-10T08:12:12.814Z] 
[2021-06-10T08:12:12.814Z] > Task :streams:integrationTest
[2021-06-10T08:12:12.814Z] 
[2021-06-10T08:12:12.814Z] 
org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorManyStandbys PASSED
[2021-06-10T08:12:12.814Z] 
[2021-06-10T08:12:12.814Z] 
org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > 
testHighAvailabilityTaskAssignorManyStandbys STARTED
[2021-06-10T08:12:27.329Z] 
[2021-06-10T08:12:27.329Z] 
org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > 
testHighAvailabilityTaskAssignorManyStandbys PASSED
[2021-06-10T08:12:27.329Z] 
[2021-06-10T08:12:27.329Z] 
org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorLargeNumConsumers STARTED
[2021-06-10T08:12:28.252Z] 
[2021-06-10T08:12:28.252Z] 
org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorLargeNumConsumers PASSED
[2021-06-10T08:12:28.252Z] 
[2021-06-10T08:12:28.252Z] 
org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > 
testStickyTaskAssignorLargeNumConsumers STARTED
[2021-06-10T08:12:30.607Z] 
[2021-06-10T08:12:30.607Z] 
org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > 
testStickyTaskAssignorLargeNumConsumers PASSED
[2021-06-10T08:12:31.529Z] streams-0: SMOKE-TEST-CLIENT-CLOSED
[2021-06-10T08:12:31.529Z] streams-4: SMOKE-TEST-CLIENT-CLOSED
[2021-06-10T08:12:31.529Z] streams-2: SMOKE-TEST-CLIENT-CLOSED
[2021-06-10T08:12:31.529Z] streams-7: SMOKE-TEST-CLIENT-CLOSED
[2021-06-10T08:12:31.529Z] streams-1: SMOKE-TEST-CLIENT-CLOSED
[2021-06-10T08:12:31.529Z] streams-6: SMOKE-TEST-CLIENT-CLOSED
[2021-06-10T08:12:31.529Z] streams-3: SMOKE-TEST-CLIENT-CLOSED
[2021-06-10T08:12:31.529Z] streams-5: SMOKE-TEST-CLIENT-CLOSED
[2021-06-10T08:12:32.452Z] 
[2021-06-10T08:12:32.452Z] 270 tests completed, 1 failed
[2021-06-10T08:12:39.890Z] 
[2021-06-10T08:12:39.890Z] > Task :core:integrationTest
[2021-06-10T08:12:39.890Z] 
[2021-06-10T08:12:39.890Z] TransactionsTest > 
testSendOffsetsWithGroupMetadata() PASSED
[2021-06-10T08:12:39.890Z] 
[2021-06-10T08:12:39.890Z] TransactionsTest > testBasicTransactions() STARTED
[2021-06-10T08:12:39.890Z] 
[2021-06-10T08:12:39.890Z] TransactionsTest > testBasicTransactions() PASSED
[2021-06-10T08:12:39.890Z] 

Re: [VOTE] KIP-750: Drop support for Java 8 in Kafka 4.0 (deprecate in 3.0)

2021-06-10 Thread David Jacot
+1 (binding), thanks!

On Thu, Jun 10, 2021 at 3:17 AM Colin McCabe  wrote:

> +1 (binding).
>
> Looking forward to 4.0 (heh)
>
> best,
> Colin
>
> On Wed, Jun 9, 2021, at 02:45, Tom Bentley wrote:
> > Hi Ismael,
> >
> > Thanks for the KIP, +1 (binding).
> >
> > Cheers,
> >
> > Tom
> >
> > On Wed, Jun 9, 2021 at 10:04 AM Mickael Maison  >
> > wrote:
> >
> > > +1 (binding)
> > > Thanks
> > >
> > > On Wed, Jun 9, 2021 at 1:25 AM Israel Ekpo 
> wrote:
> > > >
> > > > This is great!
> > > >
> > > > Thanks for the KIP
> > > >
> > > > +1 (non-binding)
> > > >
> > > >
> > > > On Tue, Jun 8, 2021 at 3:13 AM Bruno Cadonna 
> wrote:
> > > >
> > > > > Hi Ismael,
> > > > >
> > > > > Thank you for the KIP!
> > > > >
> > > > > +1 (binding)
> > > > >
> > > > > Best,
> > > > > Bruno
> > > > >
> > > > > On 08.06.21 10:11, Matthew de Detrich wrote:
> > > > > > +1 (non binding)
> > > > > >
> > > > > > On Tue, Jun 8, 2021 at 4:48 AM Luke Chen 
> wrote:
> > > > > >
> > > > > >> Hi Ismael,
> > > > > >> Thanks for the KIP.
> > > > > >> +1 (non-binding)
> > > > > >>
> > > > > >> Thanks.
> > > > > >> Luke
> > > > > >>
> > > > > >> On Tue, Jun 8, 2021 at 7:18 AM Konstantine Karantasis
> > > > > >>  wrote:
> > > > > >>
> > > > > >>> Thanks for the KIP Ismael. I agree that giving an early enough
> > > > > >> deprecation
> > > > > >>> notice for an upcoming change like this one and doing so in a
> major
> > > > > >> release
> > > > > >>> is best in this case.
> > > > > >>>
> > > > > >>> +1 (binding)
> > > > > >>>
> > > > > >>> Konstantine
> > > > > >>>
> > > > > >>> On Mon, Jun 7, 2021 at 7:30 AM Ryanne Dolan <
> ryannedo...@gmail.com
> > > >
> > > > > >> wrote:
> > > > > >>>
> > > > >  +1 (non-binding)
> > > > > 
> > > > >  Ryanne
> > > > > 
> > > > >  On Mon, Jun 7, 2021, 9:26 AM Satish Duggana <
> > > satish.dugg...@gmail.com
> > > > > >
> > > > >  wrote:
> > > > > 
> > > > > > +1 (non-binding)
> > > > > >
> > > > > > On Mon, 7 Jun 2021 at 19:30, Dongjin Lee  >
> > > wrote:
> > > > > >
> > > > > >> +1 (non-binding)
> > > > > >>
> > > > > >> As a note: I think the exact removal schedule may be
> changed.
> > > > > >>
> > > > > >> Best,
> > > > > >> Dongjin
> > > > > >>
> > > > > >> On Mon, Jun 7, 2021, 10:56 PM Josep Prat
> > > > > >>  > > > > 
> > > > > >> wrote:
> > > > > >>
> > > > > >>> Thanks Ismael, it's a +1 (non-binding) from
> > > > > <
> > >
> https://www.google.com/maps/search/Ismael,+it's+a+%2B1+(non-binding)+from?entry=gmail=g
> > > >
> > > > > my side,
> > > > > >>>
> > > > > >>>
> > > > > >>> Best,
> > > > > >>>
> > > > > >>> ———
> > > > > >>> Josep Prat
> > > > > >>>
> > > > > >>> Aiven Deutschland GmbH
> > > > > >>>
> > > > > >>> Immanuelkirchstraße 26, 10405 Berlin
> > > > > >>>
> > > > > >>> Amtsgericht Charlottenburg, HRB 209739 B
> > > > > >>>
> > > > > >>> Geschäftsführer: Oskari Saarenmaa & Hannu Valtonen
> > > > > >>>
> > > > > >>> m: +491715557497
> > > > > >>>
> > > > > >>> w: aiven.io
> > > > > >>>
> > > > > >>> e: josep.p...@aiven.io
> > > > > >>>
> > > > > >>> On Mon, Jun 7, 2021, 15:51 Ismael Juma 
> > > > > >> wrote:
> > > > > >>>
> > > > >  Since the goal is to provide ample warning regarding the
> > > future
> > > > > > removal
> > > > > >>> of
> > > > >  Java 8 support and the change we're proposing for 3.0 is
> > > > > >> simply a
> > > > >  documentation update, I am starting the vote:
> > > > > 
> > > > > 
> > > > > >>>
> > > > > >>
> > > > > >
> > > > > 
> > > > > >>>
> > > > > >>
> > > > >
> > >
> https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=181308223
> > > > > 
> > > > >  If there are concerns or objections, feel free to point
> them
> > > > > >> out
> > > > > >>> in
> > > > > >> this
> > > > >  thread or the discuss thread.
> > > > > 
> > > > >  Ismael
> > > > > 
> > > > > >>>
> > > > > >>
> > > > > >
> > > > > 
> > > > > >>>
> > > > > >>
> > > > > >
> > > > > >
> > > > >
> > >
> > >
> >
>