[jira] [Resolved] (KAFKA-13733) Reset consumer group offset with not exist topic throw wrong exception

[ https://issues.apache.org/jira/browse/KAFKA-13733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dengziming resolved KAFKA-13733. Resolution: Not A Problem > Reset consumer group offset with not exist topic throw wrong

[GitHub] [kafka-site] dajac commented on pull request #400: MINOR: Updates for 3.0.1

dajac commented on pull request #400: URL: https://github.com/apache/kafka-site/pull/400#issuecomment-1068712846 @mimaison Could we also update the doc in the main repo? Otherwise we might lose the updates in the next minor release. -- This is an automated message from the Apache Git

[jira] [Created] (KAFKA-13747) refactor TopologyTest to test different store type with parametrized

Luke Chen created KAFKA-13747: - Summary: refactor TopologyTest to test different store type with parametrized Key: KAFKA-13747 URL: https://issues.apache.org/jira/browse/KAFKA-13747 Project: Kafka

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

See

Re: [DISCUSS] KIP-825: introduce a new API to control when aggregated results are produced

Thanks for the feedback Matthias. `allowedLateness` may not be a good name. What I have in mind is to use this to control how frequently we try to emit final results. Maybe it's more flexible to be used as config in properties as we don't need to recompile DSL to change it. For option 1, I

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

See Changes: -- [...truncated 516408 lines...] [2022-03-16T00:05:14.413Z] [2022-03-16T00:05:14.413Z]

Re: [DISCUSS] KIP-825: introduce a new API to control when aggregated results are produced

Thanks for the KIP. A general comment: it seem that we won't need any new `allowedLateness` parameter because the grace-period is defined on the window itself already? (On the other hand, if I think about it once more, maybe the `grace-period` is actually not a property of the window but a

Re: [VOTE] KIP-820: Extend KStream process with new Processor API

+1 (binding) Thanks for pushing this through. Was a difficult discussion! -Matthias On 3/15/22 10:01 AM, John Roesler wrote: Thanks for the update, Jorge! I’m still +1 (binding) Thanks, John On Thu, Feb 17, 2022, at 12:57, Guozhang Wang wrote: Thanks Jorge, overall looks good to me.

Re: [DISCUSS] KIP-820: Extend KStream process with new Processor API

Thanks. It would be good to add the concrete interfaces of the new classed to the KIP, ie, - FixedKeyProcessorSupplier - FixedKeyProcessor - FixedKeyProcessorContext - FixedKeyRecord -Matthias On 3/10/22 3:15 PM, Jorge Esteban Quilcate Otoya wrote: Thanks all! I agree with Matthias

Re: [VOTE] KIP-622 Add currentSystemTimeMs and currentStreamTimeMs to ProcessorContext

Just a quick FYI. KIP-622 overlapped with KIP-478. We added the new method to the new `api.ProcessorContext` via https://issues.apache.org/jira/browse/KAFKA-13699 for 3.2.0 release. Please let us know if there are any concerns. I updated the KIP accordingly. -Matthias On 3/5/21 8:42 PM,

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.0 #188

See

Build failed in Jenkins: Kafka » Kafka Branch Builder » 2.8 #100

See Changes: -- [...truncated 467520 lines...] [2022-03-15T22:14:30.876Z] > Task :connect:api:compileJava UP-TO-DATE [2022-03-15T22:14:30.876Z] > Task :connect:api:classes

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #772

See

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.1 #88

See Changes: -- [...truncated 504302 lines...] [2022-03-15T21:59:58.992Z] KafkaZkClientTest > testGetBrokerMethods() STARTED [2022-03-15T21:59:58.992Z]

[jira] [Created] (KAFKA-13746) Flaky kafka.admin.TopicCommandIntegrationTest.testDescribeUnderMinIsrPartitionsMixed

Guozhang Wang created KAFKA-13746: - Summary: Flaky kafka.admin.TopicCommandIntegrationTest.testDescribeUnderMinIsrPartitionsMixed Key: KAFKA-13746 URL: https://issues.apache.org/jira/browse/KAFKA-13746

[jira] [Created] (KAFKA-13745) Flaky kafka.network.SocketServerTest.testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone

Guozhang Wang created KAFKA-13745: - Summary: Flaky kafka.network.SocketServerTest.testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone Key: KAFKA-13745 URL:

[jira] [Resolved] (KAFKA-13727) Edge case in cleaner can result in premature removal of ABORT marker

[ https://issues.apache.org/jira/browse/KAFKA-13727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-13727. - Fix Version/s: 2.8.2 3.1.1 3.0.2

Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.1 #87

See

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #771

See

[jira] [Reopened] (KAFKA-13542) Utilize the new Consumer#enforceRebalance(reason) API in Streams

[ https://issues.apache.org/jira/browse/KAFKA-13542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reopened KAFKA-13542: Reopening this since it was reverted pending investigation into a benchmark

Re: [VOTE] KIP-820: Extend KStream process with new Processor API

Thanks for the update, Jorge! I’m still +1 (binding) Thanks, John On Thu, Feb 17, 2022, at 12:57, Guozhang Wang wrote: > Thanks Jorge, overall looks good to me. > > Maybe we can clarify a bit in the wiki that the reason we have to not > include the additional `final String... stateStoreNames`

[jira] [Created] (KAFKA-13744) Quota metric tags are inconsistent

Jorge Esteban Quilcate Otoya created KAFKA-13744: Summary: Quota metric tags are inconsistent Key: KAFKA-13744 URL: https://issues.apache.org/jira/browse/KAFKA-13744 Project: Kafka

[jira] [Created] (KAFKA-13743) kraft controller should prevent topics with conflicting metrics names from being created

Colin McCabe created KAFKA-13743: Summary: kraft controller should prevent topics with conflicting metrics names from being created Key: KAFKA-13743 URL: https://issues.apache.org/jira/browse/KAFKA-13743

[jira] [Created] (KAFKA-13742) Quota byte-rate/request metrics are loaded only when at least one quota is register

Jorge Esteban Quilcate Otoya created KAFKA-13742: Summary: Quota byte-rate/request metrics are loaded only when at least one quota is register Key: KAFKA-13742 URL:

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #770

See

Re: Need permissions to edit the KIP-714

Done, cheers. Guozhang On Tue, Mar 15, 2022 at 8:46 AM Sarat Kakarla wrote: > Oh my bad, I don't have Apache ID, now I have created one: 'saratkakarla' > > Please grant me the permissions to edit the KIP-714 > > Thanks > Sarat > > On 3/14/22, 7:46 PM, "Guozhang Wang" wrote: > > Hello

Re: Need permissions to edit the KIP-714

Oh my bad, I don't have Apache ID, now I have created one: 'saratkakarla' Please grant me the permissions to edit the KIP-714 Thanks Sarat On 3/14/22, 7:46 PM, "Guozhang Wang" wrote: Hello Sarat, What's your apache ID? I cannot find it via your full name in apache wiki space.

Re: [DISCUSS] Apache Kafka 3.2.0 release

Hi Levani, feature freeze is tomorrow but I will cut the release branch on Monday. So you have a buffer. Even after Monday, you will still have the possibility to merge minor changes to the feature into the release branch until code freeze (30 March 2022). However, the main part of a

Re: [DISCUSS] Apache Kafka 3.2.0 release

Hi Bruno, I assume we will be able to merge changes tomorrow as well? Thanks, Levani > On 15. Mar 2022, at 16:11, Bruno Cadonna wrote: > > Hi all, > > A quick reminder that feature freeze for Apache 3.2.0 is tomorrow. Please > make sure to get your features merged into trunk. > > I will

[jira] [Created] (KAFKA-13741) Cluster IDs should not have leading dash

David Arthur created KAFKA-13741: Summary: Cluster IDs should not have leading dash Key: KAFKA-13741 URL: https://issues.apache.org/jira/browse/KAFKA-13741 Project: Kafka Issue Type: Bug

Re: [DISCUSS] Apache Kafka 3.2.0 release

Hi all, A quick reminder that feature freeze for Apache 3.2.0 is tomorrow. Please make sure to get your features merged into trunk. I will cut the release branch on Monday. Best, Bruno On 07.03.22 15:03, Bruno Cadonna wrote: Hi Kafkateers, Last week we reached KIP freeze for the next

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #769

See

[jira] [Created] (KAFKA-13740) kafka-stream-client-shutdown

Prashanth Joseph Babu created KAFKA-13740: - Summary: kafka-stream-client-shutdown Key: KAFKA-13740 URL: https://issues.apache.org/jira/browse/KAFKA-13740 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-13739) Sliding window without grace not working

bounkong khamphousone created KAFKA-13739: - Summary: Sliding window without grace not working Key: KAFKA-13739 URL: https://issues.apache.org/jira/browse/KAFKA-13739 Project: Kafka

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #768

See

[jira] [Created] (KAFKA-13738) Mirror Maker2 properties are not being picked up from properties file

Juhi Bhadviya created KAFKA-13738: - Summary: Mirror Maker2 properties are not being picked up from properties file Key: KAFKA-13738 URL: https://issues.apache.org/jira/browse/KAFKA-13738 Project: