Re: [DISCUSS] KIP-236 Interruptible Partition Reassignment

Hi Viktor, FYI, I have added a new ducktape test:   tests/kafkatest/tests/core/reassign_cancel_test.py to  https://github.com/apache/kafka/pull/6296   After review, do you have any more questions?  Thanks Hi Jun,  Could you help review this when you have time?  Thanks Can we start a vote on

[jira] [Created] (KAFKA-8126) Flaky Test org.apache.kafka.connect.runtime.WorkerTest.testAddRemoveTask

Guozhang Wang created KAFKA-8126: Summary: Flaky Test org.apache.kafka.connect.runtime.WorkerTest.testAddRemoveTask Key: KAFKA-8126 URL: https://issues.apache.org/jira/browse/KAFKA-8126 Project:

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

See Changes: [github] KAFKA-8121; Shutdown ZK client expiry handler earlier during close [colin] KAFKA-7858: Automatically generate JoinGroup request/response --

Jenkins build is back to normal : kafka-trunk-jdk11 #383

See

Re: KIP-213- [DISCUSS] - Three follow-up discussion points - topic partitioning, serializers, hashers

Just my 2 cents. Not sure if others see it differently: 1) it seems that we can lift the restriction on having the same number of input topic partitions, and thus we should exploit this IMHO; don't see why we should enforce an artificial restriction 2) for the value serde it's a little bit more

Re: [DISCUSS] KIP-378: Enable Dependency Injection for Kafka Streams handlers

Hello Wladimir, Thanks for the replies. What do you mean by "the community has opted for the second more complex solution"? Could you elaborate a bit more? Guozhang On Sun, Mar 17, 2019 at 3:45 PM Wladimir Schmidt wrote: > Hi Matthias, > > Sorry, due to other commitments I haven't started

[jira] [Created] (KAFKA-8125) Check for topic existence in CreateTopicsRequest prior to creating replica assignment

Lucas Bradstreet created KAFKA-8125: --- Summary: Check for topic existence in CreateTopicsRequest prior to creating replica assignment Key: KAFKA-8125 URL: https://issues.apache.org/jira/browse/KAFKA-8125

[jira] [Created] (KAFKA-8124) Beginning offset is after the ending offset for topic partition

suseendramani created KAFKA-8124: Summary: Beginning offset is after the ending offset for topic partition Key: KAFKA-8124 URL: https://issues.apache.org/jira/browse/KAFKA-8124 Project: Kafka

[jira] [Reopened] (KAFKA-8107) Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrideDelete

[ https://issues.apache.org/jira/browse/KAFKA-8107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-8107: > Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrideDelete >

[jira] [Resolved] (KAFKA-8107) Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrideDelete

[ https://issues.apache.org/jira/browse/KAFKA-8107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8107. Resolution: Duplicate > Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrideDelete >

[jira] [Created] (KAFKA-8123) Flaky Test RequestQuotaTest#testResponseThrottleTimeWhenBothProduceAndRequestQuotasViolated

Matthias J. Sax created KAFKA-8123: -- Summary: Flaky Test RequestQuotaTest#testResponseThrottleTimeWhenBothProduceAndRequestQuotasViolated Key: KAFKA-8123 URL: https://issues.apache.org/jira/browse/KAFKA-8123

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

See Changes: [github] KAFKA-8121; Shutdown ZK client expiry handler earlier during close -- [...truncated 2.34 MB...]

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

See Changes: [rajinisivaram] MINOR: Improve verification in flaky -- [...truncated 4.67 MB...] org.apache.kafka.connect.transforms.CastTest > castFieldsWithSchema

Re: Inconsistencies in the Kafka protocol guide

Hi Fredrik, There is no need to parse the documentation-- the Kafka protocol now has a protocol specification here: https://github.com/apache/kafka/tree/trunk/clients/src/main/resources/common/message One caveat is that there are no protocol specifications for the message format yet. best,

Inconsistencies in the Kafka protocol guide

Hi, I'm automating a low level C# kafka protocol definition by parsing the Kafka protocol guide (inkl the Record Batch documentation), and I've found some inconsistencies in the protocol guide: 1. Common Request and Response Structure RequestOrResponse => Size (RequestMessage |

[jira] [Resolved] (KAFKA-8121) ZooKeeperClient session expiry thread may leave clients behind after close

[ https://issues.apache.org/jira/browse/KAFKA-8121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-8121. --- Resolution: Fixed Reviewer: Ismael Juma Fix Version/s: 2.2.1

[jira] [Created] (KAFKA-8122) Flaky Test EosIntegrationTest#shouldNotViolateEosIfOneTaskFailsWithState

Matthias J. Sax created KAFKA-8122: -- Summary: Flaky Test EosIntegrationTest#shouldNotViolateEosIfOneTaskFailsWithState Key: KAFKA-8122 URL: https://issues.apache.org/jira/browse/KAFKA-8122 Project:

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

See Changes: [github] KAFKA-8118; Ensure ZK clients are closed in tests, fix verification [github] MINOR: Retain public constructors of classes from public API (#6455)

Jenkins build is back to normal : kafka-trunk-jdk11 #380

See

[jira] [Created] (KAFKA-8121) ZooKeeperClient session expiry thread may leave clients behind after close

Rajini Sivaram created KAFKA-8121: - Summary: ZooKeeperClient session expiry thread may leave clients behind after close Key: KAFKA-8121 URL: https://issues.apache.org/jira/browse/KAFKA-8121 Project:

[jira] [Resolved] (KAFKA-8118) Ensure that tests close ZooKeeper clients since they can impact subsequent tests

[ https://issues.apache.org/jira/browse/KAFKA-8118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-8118. --- Resolution: Fixed Reviewer: Ismael Juma > Ensure that tests close ZooKeeper clients

[jira] [Created] (KAFKA-8120) Getting NegativeArraySizeException when using Kafka Connect to send data to Kafka

Prashant Shahi created KAFKA-8120: - Summary: Getting NegativeArraySizeException when using Kafka Connect to send data to Kafka Key: KAFKA-8120 URL: https://issues.apache.org/jira/browse/KAFKA-8120

Re: [VOTE] 2.2.0 RC2

+1 (non-binding). I used the staged binaries and run some of my tests against them. All seems to look good to me. On Sat, Mar 9, 2019 at 11:56 PM Matthias J. Sax wrote: > Hello Kafka users, developers and client-developers, > > This is the third candidate for release of Apache Kafka 2.2.0. > >

[jira] [Resolved] (KAFKA-8117) Flaky Test DelegationTokenEndToEndAuthorizationTest#testNoProduceWithDescribeAcl

[ https://issues.apache.org/jira/browse/KAFKA-8117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-8117. -- Resolution: Duplicate Fix Version/s: (was: 2.3.0) > Flaky Test >

Jenkins build is back to normal : kafka-trunk-jdk8 #3472

See