Build failed in Jenkins: kafka-trunk-jdk10 #455

See Changes: [junrao] KAFKA-7117: Support AdminClient API in AclCommand (KIP-332) (#5463) -- [...truncated 2.15 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

Re: [DISCUSS] KIP 368: Allow SASL Connections to Periodically Re-Authenticate

Hi again, Rajini. It occurs to me that from a *behavior* perspective there are really 3 fundamental differences between the low-level approach you provided and the high-level approach as it currently exists in the PR: 1) *When re-authentication starts*. The low-level approach initiates re-authen

[jira] [Created] (KAFKA-7388) An equal sign in a property value causes the broker to fail

Andre Araujo created KAFKA-7388: --- Summary: An equal sign in a property value causes the broker to fail Key: KAFKA-7388 URL: https://issues.apache.org/jira/browse/KAFKA-7388 Project: Kafka Issu

[jira] [Resolved] (KAFKA-7117) Allow AclCommand to use AdminClient API

[ https://issues.apache.org/jira/browse/KAFKA-7117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-7117. Resolution: Fixed Fix Version/s: 2.1.0 Merged the PR to trunk. > Allow AclCommand to use AdminClien

Build failed in Jenkins: kafka-trunk-jdk10 #454

See Changes: [lindong28] KAFKA-6082; Fence zookeeper updates with controller epoch zkVersion -- [...truncated 2.15 MB...] org.apache.kafka.streams.test.OutputVerifierTest

Re: [DISCUSS] KIP-358: Migrate Streams API to Duration instead of long ms times

(1) Sounds good to me, to just use IllegalArgumentException for both -- and thanks for pointing out that Duration can be negative and we need to check for this. For the KIP, it would be nice to add to all methods than (even if we don't do it in the code but only document in JavaDocs). (2) I would

[VOTE] KIP-158: Kafka Connect should allow source connectors to set topic-specific settings for new topics

I believe the feedback on KIP-158 has been addressed. I'd like to start a vote. KIP: https://cwiki.apache.org/confluence/display/KAFKA/KIP-158%3A+Kafka+Connect+should+allow+source+connectors+to+set+topic-specific+settings+for+new+topics Discussion Thread: https://www.mail-archive.com/dev@kafka.ap

[jira] [Resolved] (KAFKA-6082) consider fencing zookeeper updates with controller epoch zkVersion

[ https://issues.apache.org/jira/browse/KAFKA-6082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-6082. - Resolution: Fixed > consider fencing zookeeper updates with controller epoch zkVersion >

Re: [DISCUSS] KIP 368: Allow SASL Connections to Periodically Re-Authenticate

Hi Rajini. The code really helped me to understand what you were thinking -- thanks. I'm still digesting, but here are some quick observations: Your approach (I'll call it the "low-level" approach, as compared to the existing PR, which works at a higher level of abstraction) -- the low-level app

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

See

Build failed in Jenkins: kafka-1.1-jdk7 #190

See Changes: [lindong28] MINOR: Use annotationProcessor instead of compile for JMH annotation -- [...truncated 1.93 MB...] org.apache.kafka.streams.tools.StreamsResetterTest

Build failed in Jenkins: kafka-1.1-jdk7 #191

See Changes: [ismael] MINOR: Update README to specify Gradle 4.6 as the minimum required -- [...truncated 422.88 KB...] kafka.zk.KafkaZkClientTest > testDelegationTokenMethod

Build failed in Jenkins: kafka-1.0-jdk7 #238

See Changes: [ismael] MINOR: Update README to specify Gradle 4.6 as the minimum required -- [...truncated 288.59 KB...] kafka.producer.AsyncProducerTest > testJavaProducer P

Build failed in Jenkins: kafka-trunk-jdk10 #449

See Changes: [rajinisivaram] KAFKA-7372: Upgrade Jetty for preliminary Java 11 and TLS 1.3 support -- [...truncated 2.20 MB...] org.apache.kafka.streams.test.OutputVerif

Jenkins build is back to normal : kafka-trunk-jdk10 #452

See

Jenkins build is back to normal : kafka-1.1-jdk7 #192

See

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

See Changes: [ismael] MINOR: Update README to specify Gradle 4.6 as the minimum required -- [...truncated 2.68 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

Jenkins build is back to normal : kafka-2.0-jdk8 #135

See

Build failed in Jenkins: kafka-trunk-jdk10 #451

See Changes: [ismael] MINOR: Update README to specify Gradle 4.6 as the minimum required -- [...truncated 2.23 MB...] org.apache.kafka.streams.test.OutputVerifierTest > s

Build failed in Jenkins: kafka-0.11.0-jdk7 #398

See Changes: [wangguoz] MINOR: Update streams upgrade system tests 0.11.0.3 (#5613) -- [...truncated 1.55 MB...] org.apache.kafka.streams.integration.EosIntegrationTest >

Jenkins build is back to normal : kafka-1.0-jdk7 #239

See

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

See Changes: [wangguoz] MINOR: Enable ignored upgrade system tests 2.0 (#5614) -- [...truncated 434.57 KB...] kafka.controller.PartitionStateMachineTest > testInvalidNonexis

Jenkins build is back to normal : kafka-trunk-jdk10 #450

See

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

See Changes: [lindong28] MINOR: Use annotationProcessor instead of compile for JMH annotation -- [...truncated 1.98 MB...] org.apache.kafka.clients.producer.MockProducerTest

[DISCUSS] KIP-371: Add a configuration to build custom SSL principal name

Hi all, I have created a KIP that proposes couple of options for building custom SSL principal names. https://cwiki.apache.org/confluence/display/KAFKA/KIP-371%3A+Add+a+configuration+to+build+custom+SSL+principal+name Please take a look. Thanks, Manikumar

Re: [DISCUSS] KIP-358: Migrate Streams API to Duration instead of long ms times

Hey all, (1): Duration can be negative, just like long. We need to enforce any bounds that we currently enforce. We don't need the `throws` declaration for runtime exceptions, but the potential IllegalArgumentException should be documented in the javadoc for these methods. I still feel that surfac

Re: KIP-213 - Scalable/Usable Foreign-Key KTable joins - Rebooted.

Hi James, The proposal we are discussing is https://cwiki.apache.org/confluence/display/KAFKA/KIP-213+Support+non-key+joining+in+KTable I'm not sure if it's been updated to reflect current thinking. -John On Fri, Sep 7, 2018 at 8:49 AM James Kwan wrote: > I am new to this group and I found th

[jira] [Resolved] (KAFKA-7387) Kafka distributed worker reads config from backup while launching connector

[ https://issues.apache.org/jira/browse/KAFKA-7387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] satyanarayan komandur resolved KAFKA-7387. -- Resolution: Not A Bug Issue is with the JDBC connector and not with the kafka c

[jira] [Created] (KAFKA-7387) Kafka distributed worker reads config from backup while launching connector

satyanarayan komandur created KAFKA-7387: Summary: Kafka distributed worker reads config from backup while launching connector Key: KAFKA-7387 URL: https://issues.apache.org/jira/browse/KAFKA-7387

[jira] [Created] (KAFKA-7386) Streams Scala wrapper should not cache serdes

John Roesler created KAFKA-7386: --- Summary: Streams Scala wrapper should not cache serdes Key: KAFKA-7386 URL: https://issues.apache.org/jira/browse/KAFKA-7386 Project: Kafka Issue Type: Bug

Re: Add to contributor list

Thanks On Fri, Sep 7, 2018 at 4:50 PM Guozhang Wang wrote: > Added "Murali Krishnan Mani". > > > Guozhang > > On Fri, Sep 7, 2018 at 8:42 AM, Murali Mani wrote: > > > Thanks Guozhang. I already have the id for Apache Jira / Issues. > "Murali > > Mani" is my id, can you please add me to the Ap

Re: Add to contributor list

Added "Murali Krishnan Mani". Guozhang On Fri, Sep 7, 2018 at 8:42 AM, Murali Mani wrote: > Thanks Guozhang. I already have the id for Apache Jira / Issues. "Murali > Mani" is my id, can you please add me to the Apache Kafka contributor list? > > On Tue, Sep 4, 2018 at 7:29 PM Guozhang Wang

Re: Add to contributor list

Thanks Guozhang. I already have the id for Apache Jira / Issues. "Murali Mani" is my id, can you please add me to the Apache Kafka contributor list? On Tue, Sep 4, 2018 at 7:29 PM Guozhang Wang wrote: > Hi Murali, > > Note you do not need PMC member to send you the invitation for becoming a >

[jira] [Created] (KAFKA-7385) Log compactor crashes when empty headers are retained with idempotent / transaction producers

Dhruvil Shah created KAFKA-7385: --- Summary: Log compactor crashes when empty headers are retained with idempotent / transaction producers Key: KAFKA-7385 URL: https://issues.apache.org/jira/browse/KAFKA-7385

Re: [DISCUSS] KIP-358: Migrate Streams API to Duration instead of long ms times

Hello, Matthias. Thanks, for feedback. > (1) Some methods declare `throws IllegalArgumentException`, others> don't. `duration.toMillis()` can throw ArithmeticException. It can happen if overflow occurs during conversion. Please, see source of jdk method Duration#toMillis. Task author suggest to

Re: KIP-213 - Scalable/Usable Foreign-Key KTable joins - Rebooted.

I am new to this group and I found this subject interesting. Sounds like you guys want to implement a join table of two streams? Is there somewhere I can see the original requirement or proposal? > On Sep 7, 2018, at 8:13 AM, Jan Filipiak wrote: > > > On 05.09.2018 22:17, Adam Bellemare w

Re: KIP-213 - Scalable/Usable Foreign-Key KTable joins - Rebooted.

On 05.09.2018 22:17, Adam Bellemare wrote: I'm currently testing using a Windowed Store to store the highwater mark. By all indications this should work fine, with the caveat being that it can only resolve out-of-order arrival for up to the size of the window (ie: 24h, 72h, etc). This would rem

[jira] [Created] (KAFKA-7384) Compatibility issues between Kafka Brokers 1.1.0 and older kafka clients

Vasilis Tsanis created KAFKA-7384: - Summary: Compatibility issues between Kafka Brokers 1.1.0 and older kafka clients Key: KAFKA-7384 URL: https://issues.apache.org/jira/browse/KAFKA-7384 Project: Kaf

Re: [VOTE] KIP-336: Consolidate ExtendedSerializer/Serializer and ExtendedDeserializer/Deserializer

Hi All, Many thanks for participating the discussion and voting. The KIP has passed with 3 binding votes (Jason, Harsha, Ismael) and 2 non-binding (Attila and Manikumar). If you have time, please also have a look at the corresponding code review: https://github.com/apache/kafka/pull/5494 Cheers,

Re: [DISCUSS] KIP-349 Priorities for Source Topics

On 07.09.2018 05:21, Matthias J. Sax wrote: I am still not sure how Samza's MessageChooser actually works and how this would align with KafkaConsumer fetch requests. Maybe I can give some background (conceptually); @Colin, please correct me if I say anything wrong: When a fetch request is s