[jira] [Resolved] (KAFKA-8624) 这边是服务端的kafka,版本是 kafka_2.11-1.0.0.2,当客户端向主题发送消息的时候抛出如下异常,客户端跟服务端的版本不一致吗?

2019-07-04 Thread CHARELS (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] CHARELS resolved KAFKA-8624. Resolution: Fixed Fix Version/s: 1.1.0

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

2019-07-04 Thread Apache Jenkins Server
See Changes: [jason] KAFKA-8443; Broker support for fetch from followers (#6832) [github] MINOR: Control plane listener tests should not use static port (#7033) --

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

2019-07-04 Thread Apache Jenkins Server
See

About the kafka's exchange performance inquiry

2019-07-04 Thread tang min
Dear developer team, Thank you very much Kafka for this product. Now our team from China has encountered a problem: We need to transfer images and messages between two remote servers. Each of these two remote servers needs to have a picture as the original material.In other words, because we

[jira] [Resolved] (KAFKA-8443) Allow broker to select a preferred read replica for consumer

2019-07-04 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8443. Resolution: Fixed Fix Version/s: 2.4.0 > Allow broker to select a preferred read

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

2019-07-04 Thread Apache Jenkins Server
See Changes: [jason] MINOR: Fix a wrong description in PipeDemo's javadoc (#6901) -- [...truncated 5.91 MB...] org.apache.kafka.streams.KafkaStreamsTest >

[jira] [Created] (KAFKA-8630) Unit testing a streams processor with a WindowStore throws a ClassCastException

2019-07-04 Thread Justin Fetherolf (JIRA)
Justin Fetherolf created KAFKA-8630: --- Summary: Unit testing a streams processor with a WindowStore throws a ClassCastException Key: KAFKA-8630 URL: https://issues.apache.org/jira/browse/KAFKA-8630

Re: [DISCUSS] KIP-213: Second follow-up on Foreign Key Joins

2019-07-04 Thread Adam Bellemare
Hi Matthias A thought about a variation of S1 that may work - it has a few moving parts, so I hope I explained it clearly enough. When we change keys on the LHS: (k,a) -> (k,b) (k,a,hashOf(b),PROPAGATE_OLD_VALUE) goes to RHS-0 (k,b,PROPAGATE_NEW_VALUE) goes to RHS-1 A) When the

Re: PR review

2019-07-04 Thread M. Manna
https://github.com/apache/kafka/pull/6771 Could this be reviewed please ? On Wed, 3 Jul 2019 at 11:35, M. Manna wrote: > https://github.com/apache/kafka/pull/6771 > > Bouncing both users and dev to get some activity going. We are waiting for > a while to get this KIP pr merged. > > Could

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

2019-07-04 Thread Apache Jenkins Server
See Changes: [jason] MINOR: Fix a wrong description in PipeDemo's javadoc (#6901) -- Started by an SCM change [EnvInject] - Loading node environment variables. Building

[jira] [Created] (KAFKA-8629) Kafka Streams Apps to support small native images through GraalVM

2019-07-04 Thread Andy Muir (JIRA)
Andy Muir created KAFKA-8629: Summary: Kafka Streams Apps to support small native images through GraalVM Key: KAFKA-8629 URL: https://issues.apache.org/jira/browse/KAFKA-8629 Project: Kafka

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

2019-07-04 Thread Apache Jenkins Server
See Changes: [github] MINOR: WorkerUtils#topicDescriptions must unwrap exceptions properly [cmccabe] MINOR: add useConfiguredPartitioner and skipFlush options for --