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

See

[jira] [Resolved] (KAFKA-12789) Remove Stale comments for meta response handling logic

[ https://issues.apache.org/jira/browse/KAFKA-12789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] HaiyuanZhao resolved KAFKA-12789. - Resolution: Fixed > Remove Stale comments for meta response handling logic > ---

[jira] [Resolved] (KAFKA-12615) Correct comments for the method Selector.clear

[ https://issues.apache.org/jira/browse/KAFKA-12615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] HaiyuanZhao resolved KAFKA-12615. - Resolution: Fixed > Correct comments for the method Selector.clear > ---

[jira] [Resolved] (KAFKA-13148) Kraft Controller doesn't handle scheduleAppend returning Long.MAX_VALUE

[ https://issues.apache.org/jira/browse/KAFKA-13148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-13148. - Resolution: Fixed Closing this since it was fixed by KAFKA-12158. > Kraft Controller do

[jira] [Created] (KAFKA-13157) Kafka-dump-log needs to support snapshot records

Jose Armando Garcia Sancio created KAFKA-13157: -- Summary: Kafka-dump-log needs to support snapshot records Key: KAFKA-13157 URL: https://issues.apache.org/jira/browse/KAFKA-13157 Project:

[jira] [Created] (KAFKA-13158) Replace EasyMock and PowerMock with Mockito for ConnectClusterStateImpl Test and ConnectorPluginsResourceTest

YI-CHEN WANG created KAFKA-13158: Summary: Replace EasyMock and PowerMock with Mockito for ConnectClusterStateImpl Test and ConnectorPluginsResourceTest Key: KAFKA-13158 URL: https://issues.apache.org/jira/browse/

[jira] [Created] (KAFKA-13159) Enable system tests for transactions in KRaft mode

David Arthur created KAFKA-13159: Summary: Enable system tests for transactions in KRaft mode Key: KAFKA-13159 URL: https://issues.apache.org/jira/browse/KAFKA-13159 Project: Kafka Issue Type

[jira] [Resolved] (KAFKA-12997) Expose log record append time to the controller/broker

[ https://issues.apache.org/jira/browse/KAFKA-12997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio resolved KAFKA-12997. Resolution: Fixed > Expose log record append time to the controlle

[jira] [Created] (KAFKA-13160) Fix BrokerConfigHandler to expect empty string as the resource name for dynamic default broker configs in KRaft

Ryan Dielhenn created KAFKA-13160: - Summary: Fix BrokerConfigHandler to expect empty string as the resource name for dynamic default broker configs in KRaft Key: KAFKA-13160 URL: https://issues.apache.org/jira/bro

[jira] [Resolved] (KAFKA-12647) Implement loading snapshot in the broker

[ https://issues.apache.org/jira/browse/KAFKA-12647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio resolved KAFKA-12647. Resolution: Fixed > Implement loading snapshot in the broker > ---

[jira] [Resolved] (KAFKA-12646) Implement snapshot generation on brokers

[ https://issues.apache.org/jira/browse/KAFKA-12646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio resolved KAFKA-12646. Resolution: Fixed > Implement snapshot generation on brokers > ---

Re: [DISCUSS] Apache Kafka 3.0.0 release plan with new updated dates

Hi Konstantine, I would like to report another bug in KRaft. The ConfigHandler that processes dynamic broker config deltas in KRaft expects that the default resource name for dynamic broker configs is the old default entity name used in ZK: "". Since dynamic default broker configs are persisted a

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

See

[jira] [Reopened] (KAFKA-13132) Upgrading to topic IDs in LISR requests has gaps introduced in 3.0

[ https://issues.apache.org/jira/browse/KAFKA-13132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Justine Olshan reopened KAFKA-13132: Found an issue where we don't sufficiently cover case 2. I have a plan to properly cover. c

[jira] [Created] (KAFKA-13161) Follower leader and ISR state not updated after partition change in KRaft

Jason Gustafson created KAFKA-13161: --- Summary: Follower leader and ISR state not updated after partition change in KRaft Key: KAFKA-13161 URL: https://issues.apache.org/jira/browse/KAFKA-13161 Proje

[jira] [Created] (KAFKA-13162) ElectLeader API must be forwarded to Controller

Jason Gustafson created KAFKA-13162: --- Summary: ElectLeader API must be forwarded to Controller Key: KAFKA-13162 URL: https://issues.apache.org/jira/browse/KAFKA-13162 Project: Kafka Issue T

Re: [DISCUSS] KIP-759: Unneeded repartition canceling

Thanks for the KIP Ivan! I think it's a good feature to give advanced users more control, and allow them to build more efficient application. Not sure if I like the proposed named though (the good old "naming things" discussion :)) Did you consider alternatives? What about - markAsPartitioned(

Re: [DISCUSS] KIP-655: Windowed "Distinct" Operation for KStream

Couple of questions: - Why restrict de-duplication for the key only? Should we not also consider the value (or make it somehow flexible and let the user choose?) - I am wondering if the return type should be `KStream` instead of a `KTable`? If I deduplicate a stream, I might expect a stream bac

Re: [DISCUSS] KIP-759: Unneeded repartition canceling

Do we really need a whole DSL operator for this? I think the original name for this operator -- `cancelRepartition()` -- is itself a sign that this is not an operation on the stream itself but rather a command/request to whichever operator would have otherwise triggered this repartition. What abou

[jira] [Resolved] (KAFKA-13145) Renaming the time interval window for better understanding

[ https://issues.apache.org/jira/browse/KAFKA-13145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-13145. --- Resolution: Won't Fix > Renaming the time interval window for better understanding > ---

Re: [DISCUSS] KIP-747 Add support for basic aggregation APIs

I was playing with the code a little bit, but it seems not to be easy to use generics to enforce that V is `Comparable`... We would need to introduce a new interface interface ComparableStream> extends KStream { KTable min(); } But it also requires a nasty cast to actually use it:

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

See Changes: -- [...truncated 488710 lines...] [2021-08-04T02:34:00.121Z] ApiVersionsRequestTest > testApiVersionsRequestValidationV0() > kafka.server.ApiVersionsRequestTe