[jira] [Created] (KAFKA-13439) Deprecate EAGER rebalancing in Kafka Streams

A. Sophie Blee-Goldman created KAFKA-13439: -- Summary: Deprecate EAGER rebalancing in Kafka Streams Key: KAFKA-13439 URL: https://issues.apache.org/jira/browse/KAFKA-13439 Project: Kafka

[jira] [Created] (KAFKA-13438) Replace EasyMock and PowerMock with Mockito for WorkerTest

Liam Clarke-Hutchinson created KAFKA-13438: -- Summary: Replace EasyMock and PowerMock with Mockito for WorkerTest Key: KAFKA-13438 URL: https://issues.apache.org/jira/browse/KAFKA-13438

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

See Changes: -- [...truncated 498074 lines...] [2021-11-10T00:03:02.939Z] > Task :raft:testClasses UP-TO-DATE [2021-11-10T00:03:02.939Z] > Task :connect:json:testJar

[DISCUSS] KIP-796: Interactive Query v2

Hello all, I'd like to start the discussion for KIP-796, which proposes a revamp of the Interactive Query APIs in Kafka Streams. The proposal is here: https://cwiki.apache.org/confluence/x/34xnCw I look forward to your feedback! Thank you, -John

[jira] [Resolved] (KAFKA-13417) Dynamic thread pool re-configurations may not get processed

[ https://issues.apache.org/jira/browse/KAFKA-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-13417. - Resolution: Fixed > Dynamic thread pool re-configurations may not get processed >

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

See

Kafka-13351: nag

Hi, This is my first contribution to Apache Kafka. So I am not sure whether i am too impatient. It would be great if somebody could review my PR. Thanks Florin

Re: [VOTE] KIP-791: Add Record Metadata to State Store Context

+1 (binding) from me. Thanks, Patrick! On Mon, 2021-11-08 at 14:08 -0800, Guozhang Wang wrote: > +1, thanks Patrick! > > > Guozhang > > On Mon, Nov 8, 2021 at 5:44 AM Vasiliki Papavasileiou > wrote: > > > Hi Patrick, > > > > Having the recordMetadata available in the state stores is

订阅

王江欢 wan...@emrubik.com 沈阳数融科技有限公司 TEL：15009881572

Re: Allowing both IPv4 and IPv6 connections on the same port

So I have just created a PR implementation this that does not require adding a new SecurityProtocol as originally suggested, i.e. you can use PLAINTEXT://127.0.0.1:9092,PLAINTEXT://[::1]:9092 but it only passes the validation in the specific case of having 2 addresses on the same port with one

Re: [DISCUSS] KIP-719: Add Log4J2 Appender

Hi Mickael, I greatly appreciate you for reading the proposal so carefully! I wrote it quite a while ago and rechecked it today. > Is the KIP proposing to replace the existing log4-appender or simply add a new one for log4j2? Reading the KIP and with its current title, it's not entirely

[jira] [Resolved] (KAFKA-10543) Convert KTable joins to new PAPI

[ https://issues.apache.org/jira/browse/KAFKA-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jorge Esteban Quilcate Otoya resolved KAFKA-10543. -- Resolution: Fixed https://github.com/apache/kafka/pull/11412

Re: [VOTE] KIP-782: Expandable batch size in producer

Hi devs, Bump this thread. Call for vote for: KIP-782: Expandable batch size in producer. The main goal for this KIP is: 1. higher throughput in producer 2. better memory usage in producer Detailed description can be found here: