Jenkins build is back to normal : Kafka » kafka-trunk-jdk11 #187

See

Jenkins build is back to normal : Kafka » kafka-trunk-jdk8 #179

See

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #213

See Changes: [github] MINOR: Fix documentation for KIP-585 (#9524) -- [...truncated 3.45 MB...] org.apache.kafka.streams.scala.kstream.KStreamTest > join 2 K

[jira] [Created] (KAFKA-10659) Cogroup topology generation fails if input streams are repartitioned

blueedgenick created KAFKA-10659: Summary: Cogroup topology generation fails if input streams are repartitioned Key: KAFKA-10659 URL: https://issues.apache.org/jira/browse/KAFKA-10659 Project: Kafka

[jira] [Created] (KAFKA-10658) ErrantRecordReporter.report always return completed future even though the record is not sent to DLQ topic yet

Chia-Ping Tsai created KAFKA-10658: -- Summary: ErrantRecordReporter.report always return completed future even though the record is not sent to DLQ topic yet Key: KAFKA-10658 URL: https://issues.apache.org/jira/b

Re: [DISCUSS] KIP-634: Complementary support for headers in Kafka Streams DSL

Thanks Sophie! Haven't followed KIP-478 but sounds great. I'll be happy to help on that migration to the new PAPI if it's still an open issue. We can bump this KIP after that. Cheers, Jorge. On Wed, Oct 28, 2020 at 7:00 PM Sophie Blee-Goldman wrote: > I *think* that the `To` Matthias was referr

[jira] [Created] (KAFKA-10657) Incorporate Envelope into auto-generated JSON schema

Boyang Chen created KAFKA-10657: --- Summary: Incorporate Envelope into auto-generated JSON schema Key: KAFKA-10657 URL: https://issues.apache.org/jira/browse/KAFKA-10657 Project: Kafka Issue Type

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #178

See Changes: [github] MINOR: call super.close() when closing RocksDB options (#9498) -- [...truncated 6.85 MB...] org.apache.kafka.streams.TopologyTestDriver

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #212

See Changes: [github] MINOR: call super.close() when closing RocksDB options (#9498) -- [...truncated 6.90 MB...] org.apache.kafka.streams.test.MockProcessor

[jira] [Created] (KAFKA-10656) NetworkClient.java: print out the feature flags received at DEBUG level, as well as the other version information

Colin McCabe created KAFKA-10656: Summary: NetworkClient.java: print out the feature flags received at DEBUG level, as well as the other version information Key: KAFKA-10656 URL: https://issues.apache.org/jira/bro

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #186

See Changes: [github] MINOR: call super.close() when closing RocksDB options (#9498) -- [...truncated 3.45 MB...] org.apache.kafka.streams.test.MockProcesso

[jira] [Created] (KAFKA-10655) Raft leader should resign after write failures

Jason Gustafson created KAFKA-10655: --- Summary: Raft leader should resign after write failures Key: KAFKA-10655 URL: https://issues.apache.org/jira/browse/KAFKA-10655 Project: Kafka Issue Ty

Re: [DISCUSS] KIP-634: Complementary support for headers in Kafka Streams DSL

I *think* that the `To` Matthias was referring to was not KStream#to but the To class which is accepted as a possible parameter of ProcessorContext#forward (correct me if wrong). This was on the old ProcessorContext interface, which has now been replaced with the new api.ProcessorContext in KIP-47

Re: [DISCUSS] KIP-634: Complementary support for headers in Kafka Streams DSL

Hi Matthias, Sorry for the late reply. I like the proposal. Just to check if I got it right: We can extend the `kstream.to()` function to support setting headers. e.g.: ``` void to(final String topic, final Produced produced, final HeadersExtractor headersExtractor);

Re: [DISCUSS] KIP-631: The Quorum-based Kafka Controller

HI again, Colin. I just noticed that both ConfigRecord and AccessControlRecord have a ResourceType of type int8. I thought that config resources are in the set {topics, clients, users, brokers} and ACL resource types are a different set as defined by the org.apache.kafka.common.resource.ResourceT

[jira] [Created] (KAFKA-10654) connector has failed, but worker status was ok

wehbi created KAFKA-10654: - Summary: connector has failed, but worker status was ok Key: KAFKA-10654 URL: https://issues.apache.org/jira/browse/KAFKA-10654 Project: Kafka Issue Type: Bug Co

[jira] [Created] (KAFKA-10653) get producer's ip for topic on server

bo liu created KAFKA-10653: -- Summary: get producer's ip for topic on server Key: KAFKA-10653 URL: https://issues.apache.org/jira/browse/KAFKA-10653 Project: Kafka Issue Type: Improvement