[jira] [Reopened] (KAFKA-10378) issue when create producer using java

[ https://issues.apache.org/jira/browse/KAFKA-10378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reopened KAFKA-10378: - > issue when create producer using java > - > >

[jira] [Resolved] (KAFKA-10378) issue when create producer using java

[ https://issues.apache.org/jira/browse/KAFKA-10378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mohammad Abdelqader resolved KAFKA-10378. - Fix Version/s: 2.6.0 Resolution: Fixed Solve by add 

[jira] [Created] (KAFKA-10377) Delete Useless Code

Bingkun.ji created KAFKA-10377: -- Summary: Delete Useless Code Key: KAFKA-10377 URL: https://issues.apache.org/jira/browse/KAFKA-10377 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-10261) Introduce the KIP-478 processors with shims

[ https://issues.apache.org/jira/browse/KAFKA-10261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-10261. -- Resolution: Fixed > Introduce the KIP-478 processors with shims >

[jira] [Created] (KAFKA-10379) Implement the KIP-478 StreamBuilder#addGlobalStore()

John Roesler created KAFKA-10379: Summary: Implement the KIP-478 StreamBuilder#addGlobalStore() Key: KAFKA-10379 URL: https://issues.apache.org/jira/browse/KAFKA-10379 Project: Kafka Issue

Re: [VOTE] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

Hi everybody. Just bumping this thread. This is a pretty minor change only for the Scala API and it's pending in the voting state for a while. -Yuriy On Fri, Aug 7, 2020 at 8:10 AM Yuriy Badalyantc wrote: > Hi everybody. > > There was some minor change since the voting process started

Re: [VOTE] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

Looks good, +1 (non binding) *William Reynolds**Technical Operations Engineer* Read our latest technical blog posts here . This email

[jira] [Created] (KAFKA-10380) Make dist flatten rocksdbjni

Adrian Cole created KAFKA-10380: --- Summary: Make dist flatten rocksdbjni Key: KAFKA-10380 URL: https://issues.apache.org/jira/browse/KAFKA-10380 Project: Kafka Issue Type: Task

Re: [DISCUSS] KIP-406: GlobalStreamThread should honor custom reset policy

Hi Matthias, IMHO, now as you explained using ‘global.consumer.auto.offset.reset’ is not as straightforward  as it seems and it might change the existing behavior for users without they releasing it, I also  think that we should change the behavior inside global stream thread to not die on 

[jira] [Created] (KAFKA-10378) issue when create producer using java

Mohammad Abdelqader created KAFKA-10378: --- Summary: issue when create producer using java Key: KAFKA-10378 URL: https://issues.apache.org/jira/browse/KAFKA-10378 Project: Kafka Issue

Consumer Rebalance issue and follow-up on KAFKA-9752

Hi, This is regards to https://issues.apache.org/jira/browse/KAFKA-9752 issue where Consumer rebalance can be stuck after new member timeout with old JoinGroup version. We have taken the fix, but now see a different issue . Earlier the ConsumerGroup was stuck in "PendingRebalance" state , which

Re: Request for access to create KIP

Have you created the account already? What's your account id? On Sat, Aug 8, 2020 at 4:36 PM Koushik Chitta wrote: > Hi Team, > > Can you please grant me access to create KIP ? > > Thanks, > Koushik >

[jira] [Resolved] (KAFKA-9935) Kafka not releasing member from Consumer Group

[ https://issues.apache.org/jira/browse/KAFKA-9935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-9935. Resolution: Duplicate Closing as duplicate of KAFKA-9752. Please reopen if reproduced with 2.5.0

[jira] [Resolved] (KAFKA-10105) Regression in group coordinator dealing with flaky clients joining while leaving

[ https://issues.apache.org/jira/browse/KAFKA-10105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-10105. - Resolution: Duplicate Closing as duplicate of KAFKA-9752. Please reopen if reproduced with

Build failed in Jenkins: kafka-trunk-jdk8 #4771

See Changes: [github] KAFKA-10261: Introduce the KIP-478 apis with adapters (#9004) -- [...truncated 3.19 MB...] org.apache.kafka.streams.test.OutputVerifierTest >