Build failed in Jenkins: kafka-trunk-jdk11 #534

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H42 (ubuntu xenial) in workspace

Build failed in Jenkins: kafka-trunk-jdk11 #533

See Changes: [rhauch] KAFKA-5505: Incremental cooperative rebalancing in Connect (KIP-415) -- Started by an SCM change [EnvInject] - Loading node environment variables.

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

See Changes: [rhauch] Add '?expand' query param for additional info on '/connectors'. (#6658) -- [...truncated 2.43 MB...]

Re: [VOTE] 2.2.1 RC1

Since there is no vote on this RC yet, I'll extend the deadline to Monday, May 20, at 9:00 am. Thanks in advance for checking / testing / voting. --Vahid On Mon, May 13, 2019, 20:15 Vahid Hashemian wrote: > Hello Kafka users, developers and client-developers, > > This is the second candidate

[jira] [Resolved] (KAFKA-5505) Connect: Do not restart connector and existing tasks on task-set change

[ https://issues.apache.org/jira/browse/KAFKA-5505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-5505. -- Resolution: Fixed Reviewer: Randall Hauch > Connect: Do not restart connector and

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

See Changes: [jason] KAFKA-8256; Replace Heartbeat request/response with automated protocol [ismael] KAFKA-8376; Least loaded node should consider connections which are

[jira] [Resolved] (KAFKA-3522) Consider adding version information into rocksDB storage format

[ https://issues.apache.org/jira/browse/KAFKA-3522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-3522. Resolution: Fixed Fix Version/s: 2.3.0 > Consider adding version information into

Question about integrating kafka broker with a service

Hi, I am one of the Kafka users and I have a question about how to integrate our service with Kafka. Basically, we want to enable Kafka with TLS and we want to enable mutual authentication use SSL context. We’ve already got a service which will sign the cert and manage the key. Our goal is to

Build failed in Jenkins: kafka-trunk-jdk11 #532

See Changes: [ismael] KAFKA-8376; Least loaded node should consider connections which are [rhauch] Add '?expand' query param for additional info on '/connectors'. (#6658)

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

See Changes: [jason] KAFKA-8220; Avoid kicking out static group members through rebalance [jason] MINOR: Added missing method parameter to `performAssignment` javadoc [bbejeck] KAFKA-8347: Choose next record

[jira] [Created] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins

Matthias J. Sax created KAFKA-8377: -- Summary: KTable#transformValue might lead to incorrect result in joins Key: KAFKA-8377 URL: https://issues.apache.org/jira/browse/KAFKA-8377 Project: Kafka

Build failed in Jenkins: kafka-trunk-jdk11 #531

See Changes: [jason] KAFKA-8256; Replace Heartbeat request/response with automated protocol -- Started by an SCM change [EnvInject] - Loading node environment variables.

[jira] [Resolved] (KAFKA-8256) Replace Heartbeat request/response with automated protocol

[ https://issues.apache.org/jira/browse/KAFKA-8256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8256. Resolution: Fixed > Replace Heartbeat request/response with automated protocol >

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

See Changes: [wangguoz] KAFKA-3816: Add MDC logging to Connect runtime (#5743) -- [...truncated 1.45 MB...] kafka.log.LogCleanerLagIntegrationTest > cleanerTest[2]

[jira] [Resolved] (KAFKA-6852) Allow Log Levels to be dynamically configured

[ https://issues.apache.org/jira/browse/KAFKA-6852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yeva Byzek resolved KAFKA-6852. --- Resolution: Duplicate This is getting addressed in KAFKA-7800 > Allow Log Levels to be dynamically

Re: [VOTE] KIP-455: Create an Administrative API for Replica Reassignment

Hi George, Yes, KIP-455 allows the reassignment of individual partitions to be cancelled. I think it's very important for these operations to be at the partition level. best, Colin On Tue, May 14, 2019, at 16:34, George Li wrote: > Hi Colin, > > Thanks for the updated KIP.  It has very good

Build failed in Jenkins: kafka-trunk-jdk11 #530

See Changes: [github] KAFAK-3522: Add TopologyTestDriver unit tests (#6179) -- Started by an SCM change Started by an SCM change [EnvInject] - Loading node environment

Build failed in Jenkins: kafka-trunk-jdk11 #529

See Changes: [jason] KAFKA-8220; Avoid kicking out static group members through rebalance [jason] MINOR: Added missing method parameter to `performAssignment` javadoc [bbejeck] KAFKA-8347: Choose next record

[jira] [Resolved] (KAFKA-8220) Avoid kicking out members through rebalance timeout

[ https://issues.apache.org/jira/browse/KAFKA-8220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8220. Resolution: Fixed > Avoid kicking out members through rebalance timeout >

Build failed in Jenkins: kafka-trunk-jdk11 #528

See Changes: [wangguoz] KAFKA-3816: Add MDC logging to Connect runtime (#5743) -- Started by an SCM change [EnvInject] - Loading node environment variables. Building

[jira] [Created] (KAFKA-8376) Flaky test ClientAuthenticationFailureTest.testTransactionalProducerWithInvalidCredentials test.

Manikumar created KAFKA-8376: Summary: Flaky test ClientAuthenticationFailureTest.testTransactionalProducerWithInvalidCredentials test. Key: KAFKA-8376 URL: https://issues.apache.org/jira/browse/KAFKA-8376

Re: [VOTE] KIP-458: Connector Client Config Override Policy

While implementing the KIP it became evident that for the validate call from the Connect Rest interface it was required to pass each config individually to the policy implementation to be able to determine which overrides are allowed. This happened since the interface relied on using

Build failed in Jenkins: kafka-2.2-jdk8 #119

See Changes: [rhauch] MINOR: Enable console logs in Connect tests (#6745) -- [...truncated 2.71 MB...] kafka.security.auth.SimpleAclAuthorizerTest >

[jira] [Created] (KAFKA-8375) Offset jumps back after commit

Markus Dybeck created KAFKA-8375: Summary: Offset jumps back after commit Key: KAFKA-8375 URL: https://issues.apache.org/jira/browse/KAFKA-8375 Project: Kafka Issue Type: Bug

Build failed in Jenkins: kafka-2.0-jdk8 #268

See Changes: [rhauch] KAFKA-8320 : fix retriable exception package for source connectors [rhauch] MINOR: Enable console logs in Connect tests (#6745) -- [...truncated