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

See -- [...truncated 593 B...] Fetching upstream changes from https://github.com/apache/kafka.git > git --version # timeout=10 > git fetch --tags --progress

[jira] [Created] (KAFKA-8231) Expansion of ConnectClusterState interface

Chris Egerton created KAFKA-8231: Summary: Expansion of ConnectClusterState interface Key: KAFKA-8231 URL: https://issues.apache.org/jira/browse/KAFKA-8231 Project: Kafka Issue Type:

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

See -- [...truncated 593 B...] Fetching upstream changes from https://github.com/apache/kafka.git > git --version # timeout=10 > git fetch --tags --progress

[DISCUSS] KIP-454: Expansion of the ConnectClusterState interface

Hi all, I've posted "KIP-454: Expansion of the ConnectClusterState interface", which proposes that we add provide more information about the Connect cluster to REST extensions. The KIP can be found at

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

See -- [...truncated 593 B...] Fetching upstream changes from https://github.com/apache/kafka.git > git --version # timeout=10 > git fetch --tags --progress

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

See Changes: [matthias] KAFKA-8213 - Fix typo in Streams Dev Guide (#6574) [matthias] KAFKA-8212 DOCS (kafka) - Fix Maven artifacts table from cutting off -- [...truncated

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

See -- [...truncated 593 B...] Fetching upstream changes from https://github.com/apache/kafka.git > git --version # timeout=10 > git fetch --tags --progress

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

See Changes: [mjsax] KAFKA-8213 - Fix typo in Streams Dev Guide (#6574) [mjsax] KAFKA-8212 DOCS (kafka) - Fix Maven artifacts table from cutting off [github] KAFKA-8209: Wrong link for KStreams DSL in core

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

See -- [...truncated 593 B...] Fetching upstream changes from https://github.com/apache/kafka.git > git --version # timeout=10 > git fetch --tags --progress

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

See Changes: [matthias] KAFKA-8213 - Fix typo in Streams Dev Guide (#6574) [matthias] KAFKA-8212 DOCS (kafka) - Fix Maven artifacts table from cutting off -- [...truncated

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

See -- [...truncated 593 B...] Fetching upstream changes from https://github.com/apache/kafka.git > git --version # timeout=10 > git fetch --tags --progress

[jira] [Created] (KAFKA-8230) Add static membership support in librd consumer client

Boyang Chen created KAFKA-8230: -- Summary: Add static membership support in librd consumer client Key: KAFKA-8230 URL: https://issues.apache.org/jira/browse/KAFKA-8230 Project: Kafka Issue

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

See -- [...truncated 593 B...] Fetching upstream changes from https://github.com/apache/kafka.git > git --version # timeout=10 > git fetch --tags --progress

[jira] [Created] (KAFKA-8229) Connect Sink Task updates nextCommit when commitRequest is true

Scott Reynolds created KAFKA-8229: - Summary: Connect Sink Task updates nextCommit when commitRequest is true Key: KAFKA-8229 URL: https://issues.apache.org/jira/browse/KAFKA-8229 Project: Kafka

[jira] [Resolved] (KAFKA-8209) Wrong link for KStreams DSL in Core Concepts doc

[ https://issues.apache.org/jira/browse/KAFKA-8209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8209. Resolution: Fixed > Wrong link for KStreams DSL in Core Concepts doc >

[jira] [Resolved] (KAFKA-8210) Missing link for KStreams in Streams DSL docs

[ https://issues.apache.org/jira/browse/KAFKA-8210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8210. Resolution: Fixed > Missing link for KStreams in Streams DSL docs >

[jira] [Resolved] (KAFKA-8208) Broken link for out-of-order data in KStreams Core Concepts doc

[ https://issues.apache.org/jira/browse/KAFKA-8208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8208. Resolution: Fixed Fix Version/s: 2.3.0 > Broken link for out-of-order data in KStreams Core

[jira] [Resolved] (KAFKA-8212) KStreams documentation Maven artifact table is cut off

[ https://issues.apache.org/jira/browse/KAFKA-8212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8212. Resolution: Fixed > KStreams documentation Maven artifact table is cut off >

[jira] [Resolved] (KAFKA-8213) KStreams interactive query documentation typo

[ https://issues.apache.org/jira/browse/KAFKA-8213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8213. Resolution: Fixed > KStreams interactive query documentation typo >

Re: [DISCUSS] KIP-446: Add changelog topic configuration to KTable suppress

> Are you sure the users are aware that with `withLoggingDisabled()`, they > might lose data during failover? I hope so :D Of course, we can always improve the JavaDocs. -Matthias On 4/12/19 2:48 PM, Bill Bejeck wrote: > Thanks for the KIP Maarten. > > I also agree that keeping the

Re: [DISCUSS] KIP-429 : Smooth Auto-Scaling for Kafka Streams

Thanks for your answers Guozhang! I slowly understand more and more details. Couple of follow up questions: 10) Consumer Coordinator Algorithm--1a: > If subscription has changed: revoke all partitions by calling > onPartitionsRevoked, send join-group request with empty owned partitions in >

Re: [DISCUSSION] KIP-418: A method-chaining way to branch KStream

Hi all! I have updated the KIP-418 according to the new vision. Matthias, thanks for your comment! Renaming KStream#branch() -> #split() I can see your point: this is to make the name similar to String#split that also returns an array, right? But is it worth the loss of backwards

[jira] [Created] (KAFKA-8228) Exactly once semantics break during server restart for kafka-streams application

Boquan Tang created KAFKA-8228: -- Summary: Exactly once semantics break during server restart for kafka-streams application Key: KAFKA-8228 URL: https://issues.apache.org/jira/browse/KAFKA-8228 Project: