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

See Changes: [github] MINOR: add docs for KIP-680 (#10048) -- [...truncated 3.60 MB...] KafkaZkClientTest > testSetTopicPartitionStatesRaw() STARTED

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

See Changes: [github] MINOR: Extends RocksDB docs (#10046) [github] MINOR: Word count should account for extra whitespaces between words (#10044) [github] KAFKA-9274: Add timeout handling for

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

See Changes: [github] KAFKA-10833: Expose task configurations in Connect REST API (KIP-661) (#9726) [github] KAFKA-10834: Remove redundant type casts in Connect (#10053)

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

See Changes: [github] KAFKA-5488: Add type-safe split() operator (#9107) [github] KAFKA-10833: Expose task configurations in Connect REST API (KIP-661) (#9726) [github] KAFKA-10834: Remove

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

See Changes: [github] MINOR: Extends RocksDB docs (#10046) [github] MINOR: Word count should account for extra whitespaces between words (#10044) --

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

See Changes: [github] MINOR: Add KafkaEventQueue (#10030) -- [...truncated 7.20 MB...] TransactionsTest > testConsecutivelyRunInitTransactions() STARTED

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

See Changes: [github] KAFKA-5488: Add type-safe split() operator (#9107) [github] KAFKA-10833: Expose task configurations in Connect REST API (KIP-661) (#9726) [github] KAFKA-10834: Remove

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

See Changes: [github] MINOR: Add ConfigRepository, use in Partition and KafkaApis (#10005) [github] MINOR: Add KafkaEventQueue (#10030) [github] KAFKA-5488: Add type-safe split() operator (#9107)

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

See Changes: [github] MINOR: Add KafkaEventQueue (#10030) -- [...truncated 3.60 MB...] SocketServerTest > testStagedListenerStartup() PASSED

[jira] [Created] (KAFKA-12295) Shallow Mirroring

Henry Cai created KAFKA-12295: - Summary: Shallow Mirroring Key: KAFKA-12295 URL: https://issues.apache.org/jira/browse/KAFKA-12295 Project: Kafka Issue Type: Improvement Components:

Proposing KIP-712: Shallow Mirroring

Dear Community members, We are proposing a new feature to improve the performance of Kafka mirror maker: https://cwiki.apache.org/confluence/display/KAFKA/KIP-712%3A+Shallow+Mirroring The current Kafka MirrorMaker process (with the underlying Consumer and Producer library) uses significant CPU

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

See Changes: [github] MINOR: Introduce KafkaBroker trait for use in dynamic reconfiguration (#10019) -- [...truncated 7.10 MB...] LogTest >

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

See Changes: [github] MINOR: Add ConfigRepository, use in Partition and KafkaApis (#10005) -- [...truncated 3.61 MB...] AuthorizerIntegrationTest >

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

See Changes: [github] MINOR: Add ConfigRepository, use in Partition and KafkaApis (#10005) -- [...truncated 3.60 MB...] KafkaZkClientTest >

[GitHub] [kafka-site] mimaison commented on pull request #327: Use downloads.apache.org for current releases

mimaison commented on pull request #327: URL: https://github.com/apache/kafka-site/pull/327#issuecomment-773652267 @mjsax Can you take a look? Thanks This is an automated message from the Apache Git Service. To respond to

[jira] [Created] (KAFKA-12294) Consider using the forwarding mechanism for metadata auto topic creation

Boyang Chen created KAFKA-12294: --- Summary: Consider using the forwarding mechanism for metadata auto topic creation Key: KAFKA-12294 URL: https://issues.apache.org/jira/browse/KAFKA-12294 Project:

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

See Changes: [github] MINOR: Introduce KafkaBroker trait for use in dynamic reconfiguration (#10019) -- [...truncated 3.60 MB...]

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

See Changes: [github] MINOR: Introduce KafkaBroker trait for use in dynamic reconfiguration (#10019) -- [...truncated 3.60 MB...] KafkaZkClientTest >

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

See

[jira] [Created] (KAFKA-12293) Remove JCenter and Bintray repositories mentions out of Gradle build (sunset is announced for those repositories)

Dejan Stojadinović created KAFKA-12293: -- Summary: Remove JCenter and Bintray repositories mentions out of Gradle build (sunset is announced for those repositories) Key: KAFKA-12293 URL:

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

See Changes: [github] KAFKA-10835: Replace Runnable and Callable overrides with lambdas in Connect (#9867) -- [...truncated 3.54 MB...] ZooKeeperClientTest

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

See Changes: [github] KAFKA-10835: Replace Runnable and Callable overrides with lambdas in Connect (#9867) -- [...truncated 3.60 MB...] KafkaZkClientTest >

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

See Changes: [David Jacot] KAFKA-12193: Re-resolve IPs after a client disconnects (#9902) -- [...truncated 3.44 MB...]

[jira] [Resolved] (KAFKA-7271) Fix ignored test in streams_upgrade_test.py: test_upgrade_downgrade_brokers

[ https://issues.apache.org/jira/browse/KAFKA-7271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-7271. -- Resolution: Duplicate > Fix ignored test in streams_upgrade_test.py:

[jira] [Created] (KAFKA-12292) Fix Ignored Downgrade Tests in streams_upgrade_test.py: test_upgrade_downgrade_brokers

Bruno Cadonna created KAFKA-12292: - Summary: Fix Ignored Downgrade Tests in streams_upgrade_test.py: test_upgrade_downgrade_brokers Key: KAFKA-12292 URL: https://issues.apache.org/jira/browse/KAFKA-12292

[jira] [Created] (KAFKA-12291) Fix Ignored Upgrade Tests in streams_upgrade_test.py: test_upgrade_downgrade_brokers

Bruno Cadonna created KAFKA-12291: - Summary: Fix Ignored Upgrade Tests in streams_upgrade_test.py: test_upgrade_downgrade_brokers Key: KAFKA-12291 URL: https://issues.apache.org/jira/browse/KAFKA-12291

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

> vvv > long_poll.mode: return_on_records|return_on_response This idea LGTM. It not only makes minimum changes to current behavior but also works for KIP-695. On 2021/02/04 16:07:11, John Roesler wrote: > Hi Matthias, Chia-Ping, and Tom, > > Thanks for the thoughtful

[jira] [Created] (KAFKA-12290) Adding a new topic or removing an existing topic to/from --whitelist in mirrormaker config file stops all replication

Chris Cairns created KAFKA-12290: Summary: Adding a new topic or removing an existing topic to/from --whitelist in mirrormaker config file stops all replication Key: KAFKA-12290 URL:

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

Hi Matthias, Chia-Ping, and Tom, Thanks for the thoughtful replies! Re: poll(~forever~) to block indefinitely on records: Thanks for your dilligence, Chia-Ping. While I wouldn't personally recommend for anyone to write code that blocks forever on I/O, I do agree this is something that "real

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

See Changes: [github] KAFKA-12193: Re-resolve IPs after a client disconnects (#9902) -- [...truncated 3.58 MB...] LogTest >

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

See Changes: [github] KAFKA-12193: Re-resolve IPs after a client disconnects (#9902) -- [...truncated 3.60 MB...] KafkaZkClientTest >

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

See Changes: [github] KAFKA-12193: Re-resolve IPs after a client disconnects (#9902) -- [...truncated 3.55 MB...] SslAdminIntegrationTest >

[jira] [Resolved] (KAFKA-12193) Re-resolve IPs when a client is disconnected

[ https://issues.apache.org/jira/browse/KAFKA-12193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-12193. Fix Version/s: 2.8.0 Resolution: Fixed > Re-resolve IPs when a client is

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

See Changes: [Konstantine Karantasis] KAFKA-12259: Use raw config to infer the connector type when returning a connector status response (#10040) [Randall Hauch] KAFKA-12270: Handle race condition

[jira] [Created] (KAFKA-12289) Add Tests for prefixScan in InMemoryKeyValueStore

Sagar Rao created KAFKA-12289: - Summary: Add Tests for prefixScan in InMemoryKeyValueStore Key: KAFKA-12289 URL: https://issues.apache.org/jira/browse/KAFKA-12289 Project: Kafka Issue Type:

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

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) [github]

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

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

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

Hi, The Javadoc for KafkaConsumer#poll() includes the following: * This method returns immediately if there are records available. *Otherwise, > it will await the passed timeout.* > * If the timeout expires, an empty record set will be returned. Note that > this method may block beyond the > *

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

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