Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #497

See Changes: [github] MINOR: Fix always pass unit test in MetadataRequestTest (#10033) -- [...truncated 3.60 MB...] AuthorizerIntegrationTest > shouldThrowT

Build failed in Jenkins: Kafka » kafka-2.4-jdk8 #23

See Changes: [Konstantine Karantasis] KAFKA-10895: Gracefully handle invalid JAAS configs (follow up fix) (#9987) -- [...truncated 2.90 MB...] org.apache.kafka

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #444

See Changes: [github] MINOR: remove unused import in TopicIdWithOldInterBrokerProtocolTest (#10037) -- [...truncated 3.58 MB...] LogTest > testFetchUpToLogE

Build failed in Jenkins: Kafka » kafka-2.5-jdk8 #34

See Changes: [Konstantine Karantasis] KAFKA-10413: Allow for even distribution of lost/new tasks when multiple Connect workers join at the same time (#9319) --

Build failed in Jenkins: Kafka » kafka-2.7-jdk8 #112

See Changes: [Randall Hauch] KAFKA-12270: Handle race condition when Connect tasks attempt to create topics (#10032) -- [...truncated 3.45 MB...] org.apache.k

Build failed in Jenkins: Kafka » kafka-2.3-jdk8 #16

See Changes: [Konstantine Karantasis] KAFKA-10895: Gracefully handle invalid JAAS configs (follow up fix) (#9987) -- [...truncated 2.15 MB...] kafka.utils.timer

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #496

See Changes: [github] KAFKA-10716: persist UUID in state directory for stable processId across restarts (#9978) [github] MINOR: remove unused import in TopicIdWithOldInterBrokerProtocolTest (#1003

Re: [VOTE] KIP-695: Improve Streams Time Synchronization

Thanks for your sharing Matthias. I agree that is indeed an anti-pattern to assume poll() returns data or not. However, I check all usages of poll() in code base. There is an interesting use case - poll(a bigger timeout) - it implies that callers want to block poll()(forever) unless there are a

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #443

See Changes: [github] KAFKA-12270: Handle race condition when Connect tasks attempt to create topics (#10032) [github] KAFKA-10716: persist UUID in state directory for stable processId across resta

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #495

See Changes: [github] KAFKA-12250; Add metadata record serde for KIP-631 (#9998) [github] KAFKA-12270: Handle race condition when Connect tasks attempt to create topics (#10032) -

Build failed in Jenkins: Kafka » kafka-2.7-jdk8 #111

See Changes: [Konstantine Karantasis] KAFKA-10895: Gracefully handle invalid JAAS configs (follow up fix) (#9987) [Konstantine Karantasis] KAFKA-12259: Use raw config to infer the connector type when

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #442

See Changes: [github] MINOR: Replace BrokerStates.scala with BrokerState.java (#10028) [github] KAFKA-10895: Gracefully handle invalid JAAS configs (follow up fix) (#9987) [David Arthur] KAFKA-1227

Build failed in Jenkins: Kafka » kafka-2.4-jdk8 #22

See Changes: [Konstantine Karantasis] KAFKA-10413: Allow for even distribution of lost/new tasks when multiple Connect workers join at the same time (#9319) --

[jira] [Created] (KAFKA-12288) Remove task-level filesystem locks

A. Sophie Blee-Goldman created KAFKA-12288: -- Summary: Remove task-level filesystem locks Key: KAFKA-12288 URL: https://issues.apache.org/jira/browse/KAFKA-12288 Project: Kafka Issue

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #494

See Changes: [github] MINOR: Replace BrokerStates.scala with BrokerState.java (#10028) [github] KAFKA-10895: Gracefully handle invalid JAAS configs (follow up fix) (#9987) [David Arthur] KAFKA-122

[jira] [Resolved] (KAFKA-10413) rebalancing leads to unevenly balanced connectors

[ https://issues.apache.org/jira/browse/KAFKA-10413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-10413. Resolution: Fixed > rebalancing leads to unevenly balanced connectors > --

[jira] [Resolved] (KAFKA-12270) Kafka Connect may fail a task when racing to create topic

[ https://issues.apache.org/jira/browse/KAFKA-12270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-12270. --- Fix Version/s: 2.6.2 2.7.1 2.8.0 Reviewer: Kon

[jira] [Resolved] (KAFKA-12250) Add metadata record serde logic for KIP-631

[ https://issues.apache.org/jira/browse/KAFKA-12250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-12250. - Resolution: Fixed > Add metadata record serde logic for KIP-631 > --

[jira] [Reopened] (KAFKA-10648) Add Prefix Scan support to State Stores

[ https://issues.apache.org/jira/browse/KAFKA-10648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-10648: - Ups. Just say Guozhangs comment about the missing docs... Reopening. > Add Prefix Scan supp

[jira] [Resolved] (KAFKA-12259) Consolidated Status endpoint returns 500 when config provider can't find a config

[ https://issues.apache.org/jira/browse/KAFKA-12259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-12259. Resolution: Fixed > Consolidated Status endpoint returns 500 when config p

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #493

See Changes: [github] KAFKA-10648: Add Prefix Scan support to State Stores (#9508) [github] MINOR: Add mock implementation of `BrokerToControllerChannelManager` (#10026) [github] MINOR: Fix window

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #474

See Changes: [github] MINOR: Fix windows startup scripts to use connect-log4j.properties instead of tools-log4j.properties (#10034) -- [...truncated 7.18 MB

[jira] [Resolved] (KAFKA-10895) Basic auth extension's JAAS config can be corrupted by other plugins

[ https://issues.apache.org/jira/browse/KAFKA-10895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-10895. Resolution: Fixed > Basic auth extension's JAAS config can be corrupted by

Re: [VOTE] KIP-695: Improve Streams Time Synchronization

Thanks for your email John. I agree that it seems to be an anti-pattern to write code that makes assumptions if poll() returns data or not. Thus, we should fix-forward the system test from my point of view. >From my understanding, the impact of KIP-695 is that we might return early from poll() (i

Build failed in Jenkins: Kafka » kafka-2.6-jdk8 #82

See Changes: [Konstantine Karantasis] KAFKA-10413: Allow for even distribution of lost/new tasks when multiple Connect workers join at the same time (#9319) --

[jira] [Created] (KAFKA-12287) Add WARN logging on consumer-groups when reset-offsets by timestamp or duration can't find an offset and defaults to latest.

Jorge Esteban Quilcate Otoya created KAFKA-12287: Summary: Add WARN logging on consumer-groups when reset-offsets by timestamp or duration can't find an offset and defaults to latest. Key: KAFKA-12287

Jenkins build is back to normal : Kafka » kafka-trunk-jdk8 #440

See

[jira] [Created] (KAFKA-12286) Consider storage/cpu tradeoff in metadata record framing schema

Jason Gustafson created KAFKA-12286: --- Summary: Consider storage/cpu tradeoff in metadata record framing schema Key: KAFKA-12286 URL: https://issues.apache.org/jira/browse/KAFKA-12286 Project: Kafka

Jenkins build is back to normal : Kafka » kafka-trunk-jdk15 #492

See

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #473

See Changes: [github] MINOR: Disable Travis PR builds (#10038) [github] KAFKA-10648: Add Prefix Scan support to State Stores (#9508) [github] MINOR: Add mock implementation of `BrokerToControllerCh

Re: [DISCUSS] Apache Kafka 2.8.0 release

Hello again, all, This is a reminder that today is the Feature Freeze deadline. To avoid any last-minute crunch or time-zone unfairness, I'll cut the branch toward the end of the week. Please wrap up your features and transition fully into a stabilization mode. The next checkpoint is Code Freeze

Re: [apache/kafka] KAFKA-10413 Allow even distribution of lost/new tasks when more than one worker

Added. Welcome Ramesh! - Konstantine On Tue, Feb 2, 2021 at 10:13 PM Luke Chen wrote: > Hi Committers, > please help Ramens add JIRA account: *ramkrish1489* into contribution list. > > Thanks. > Luke > > On Wed, Feb 3, 2021 at 2:10 PM Ramesh Krishnan > wrote: > > > Hi Luke, > > > > Please find

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #472

See Changes: [github] MINOR: change modifier of ConsumerRecords(FetchedRecords) from public to package-private (#10036) [github] MINOR: Introduce ProducerIdGenerator trait (#10009) --

[jira] [Created] (KAFKA-12285) Handle offline replicas in MetadataPartitions

David Arthur created KAFKA-12285: Summary: Handle offline replicas in MetadataPartitions Key: KAFKA-12285 URL: https://issues.apache.org/jira/browse/KAFKA-12285 Project: Kafka Issue Type: Imp

[jira] [Created] (KAFKA-12284) Flaky Test MirrorConnectorsIntegrationSSLTest#testOneWayReplicationWithAutoOffsetSync

Matthias J. Sax created KAFKA-12284: --- Summary: Flaky Test MirrorConnectorsIntegrationSSLTest#testOneWayReplicationWithAutoOffsetSync Key: KAFKA-12284 URL: https://issues.apache.org/jira/browse/KAFKA-12284

Re: [VOTE] KIP-695: Improve Streams Time Synchronization

Hello again all, I'm resurrecting this thread to discuss an issue that has come up after merging the code for this KIP. The issue is that some of the system tests need to be updated in the same way that this integration test needed to be updated: https://github.com/apache/kafka/pull/9836/files#di

[jira] [Created] (KAFKA-12283) Flaky Test RebalanceSourceConnectorsIntegrationTest#testMultipleWorkersRejoining

Matthias J. Sax created KAFKA-12283: --- Summary: Flaky Test RebalanceSourceConnectorsIntegrationTest#testMultipleWorkersRejoining Key: KAFKA-12283 URL: https://issues.apache.org/jira/browse/KAFKA-12283

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #439

See Changes: [github] KAFKA-12249: Add client-side Decommission Broker RPC (KIP-500) (#9996) -- [...truncated 7.14 MB...] LogValidatorTest > testLogAppendTim

[jira] [Created] (KAFKA-12282) KIP-500: Reconcile configuration variables between trunk and the KIP-500 branch

Alok Nikhil created KAFKA-12282: --- Summary: KIP-500: Reconcile configuration variables between trunk and the KIP-500 branch Key: KAFKA-12282 URL: https://issues.apache.org/jira/browse/KAFKA-12282 Project

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #491

See Changes: [github] MINOR: change modifier of ConsumerRecords(FetchedRecords) from public to package-private (#10036) -- [...truncated 3.59 MB...] Author

[jira] [Reopened] (KAFKA-10764) Add support for returning topic IDs on create, supplying topic IDs for delete

[ https://issues.apache.org/jira/browse/KAFKA-10764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Justine Olshan reopened KAFKA-10764: We need to revisit the admin client apis for this. > Add support for returning topic IDs on c

[jira] [Resolved] (KAFKA-4640) Improve Streams unit test coverage

[ https://issues.apache.org/jira/browse/KAFKA-4640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Walker Carlson resolved KAFKA-4640. --- Resolution: Fixed > Improve Streams unit test coverage > -- >

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #471

See Changes: [github] KAFKA-12249: Add client-side Decommission Broker RPC (KIP-500) (#9996) -- [...truncated 3.59 MB...] KafkaZkClientTest > testSetTopicPar

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #490

See Changes: [github] KAFKA-12249: Add client-side Decommission Broker RPC (KIP-500) (#9996) -- [...truncated 3.59 MB...] AuthorizerIntegrationTest > testCo

Re: Kafka Advisory Topic

After discussing this a bit more and looking into what it would take to implement this feature Knowles and I are going to hold off until we see what the removal of Zookeeper will look like. We are still interested in this feature but we figure that things will change significantly enough that it's

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #489

See Changes: -- [...truncated 3.58 MB...] ZooKeeperClientTest > testZNodeChildChangeHandlerForChildChangeNotTriggered() PASSED ZooKeeperClientTest > testMixedPipeline()

[DISCUSS] KIP-711 Deprecate org.apache.kafka.streams.errors.BrokerNotFoundException

Dear All, I'd like to start discuss thread for KIP-711 (https://cwiki.apache.org/confluence/x/3hJRCg) It's been 3 years since 234ec8a gets rid of usage of BrokerNotFoundException. Hence, it is time to deprecate BrokerNotFoundException. Best Regards, Chia-Ping

[jira] [Created] (KAFKA-12281) Deprecate org.apache.kafka.streams.errors.BrokerNotFoundException

Chia-Ping Tsai created KAFKA-12281: -- Summary: Deprecate org.apache.kafka.streams.errors.BrokerNotFoundException Key: KAFKA-12281 URL: https://issues.apache.org/jira/browse/KAFKA-12281 Project: Kafka