Re: [KAFKA-557] Add emit on change support for Kafka Streams

Talking about optimizations and reducing downstream load: Do we actually have any numbers? I have the impression that this KIP is more or less build on the _assumption_ that there is a problem. Yes, there are some use cases that would benefit from this; But how many applications would actually

Build failed in Jenkins: kafka-2.4-jdk8 #147

See Changes: [vahid.hashemian] KAFKA-8245: Fix Flaky Test -- [...truncated 2.75 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

Re: [KAFKA-557] Add emit on change support for Kafka Streams

Hi John! Thanks for the reply. About the changes we have discussed so far. I think upon further consideration, we have been mostly talking about this from the perspective that no stop-gap effort is acceptable. However, in recent discussion, if we consider optimization, then it appears that the

Build failed in Jenkins: kafka-2.5-jdk8 #29

See Changes: [vahid.hashemian] KAFKA-8245: Fix Flaky Test -- [...truncated 2.89 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

Build failed in Jenkins: kafka-2.4-jdk8 #146

See Changes: [ismael] KAFKA-9515: Upgrade ZooKeeper to 3.5.7 (#8125) -- [...truncated 5.56 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

Re: [DISCUSS] KIP-552: Add interface to handle unused config

Thanks Matthias, I got the impression this was considered and rejected in KAFKA-7509, but I'm not sure why. Maybe it was never really considered at all, just proposed and not-noticed? Perhaps Randall or Sönke can comment. See:

[jira] [Created] (KAFKA-9564) Integration Tests for Tiered Storage

Alexandre Dupriez created KAFKA-9564: Summary: Integration Tests for Tiered Storage Key: KAFKA-9564 URL: https://issues.apache.org/jira/browse/KAFKA-9564 Project: Kafka Issue Type:

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

See Changes: [github] KAFKA-8245: Fix Flaky Test -- [...truncated 5.85 MB...] org.apache.kafka.streams.test.ConsumerRecordFactoryTest >

Re: [KAFKA-557] Add emit on change support for Kafka Streams

Hi again, all, Sorry on my part for my silence. I've just taken another look over the recent history of this discussion. It seems like the #1 point to clarify (because it affect everything else) is that, yes, I was 100% envisioning this as an _optimization_. As a consequence, I don't think it's

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

See Changes: [github] KAFKA-8245: Fix Flaky Test -- [...truncated 2.88 MB...] org.apache.kafka.streams.MockTimeTest > shouldGetNanosAsMillis PASSED

Build failed in Jenkins: kafka-2.5-jdk8 #28

See Changes: [ismael] KAFKA-9515: Upgrade ZooKeeper to 3.5.7 (#8125) -- [...truncated 2.89 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

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

See Changes: [github] KAFKA-9515: Upgrade ZooKeeper to 3.5.7 (#8125) -- [...truncated 2.89 MB...] org.apache.kafka.streams.test.ConsumerRecordFactoryTest >

Re: [DISCUSS] KIP-552: Add interface to handle unused config

-BEGIN PGP SIGNED MESSAGE- Hash: SHA512 I am just getting aware of this KIP (not sure why I missed it). In Kafka Streams we have nested clients and need to "forward" configs from outer layer to inner layers -- hence, we prefix some configs to be able to know which inner nested clients

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

See Changes: [github] KAFKA-9515: Upgrade ZooKeeper to 3.5.7 (#8125) -- [...truncated 2.88 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

Re: [DISCUSS] KIP-494 Connect REST Endpoint for Transformations (SMTs) and other Plugins

Thanks for the feedback, Chris. WRT Worker-plugins, I see your point that they aren't very useful for people trying to create connectors to see what exists already, but I would find them useful for things like making assertions against a docker image to confirm the pluginpaths/classpaths are

Re: [DISCUSS] KIP-552: Add interface to handle unused config

Thanks Patrik, This seems to be a long and wandering issue. It seems that KAFKA-7509 has followed a similar trajectory to KAFKA-6793/KIP-552 , and 7509 is just recently closed in favor of whatever we decide to do in KAFKA-6793. Considering (what I hope is) the whole history of this issue, a few

[jira] [Resolved] (KAFKA-9515) Upgrade ZooKeeper to 3.5.7

[ https://issues.apache.org/jira/browse/KAFKA-9515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-9515. Resolution: Fixed > Upgrade ZooKeeper to 3.5.7 > -- > >

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

See Changes: [github] MINOR: Add upgrade note about TLSv1 and TLSv1.1 being disabled in 2.5.0 -- [...truncated 2.89 MB...]

Build failed in Jenkins: kafka-2.5-jdk8 #27

See Changes: [rajinisivaram] MINOR: Add upgrade note about TLSv1 and TLSv1.1 being disabled in 2.5.0 -- [...truncated 2.89 MB...]

Fwd: Issue Regarding Kafka-log size. In Windows Operating system

-- Forwarded message - From: Savan Tripathi Date: Mon, 17 Feb 2020 at 12:48 Subject: Issue Regarding Kafka-log size. In Windows Operating system To: Dear sir, I am new to Apache Kafka. I am developing an application in which Apache kafka is working as broker. I am producing

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

See Changes: [github] MINOR: Add upgrade note about TLSv1 and TLSv1.1 being disabled in 2.5.0 -- [...truncated 2.89 MB...]

Build failed in Jenkins: kafka-2.5-jdk8 #26

See Changes: [rajinisivaram] KAFKA-9319: Fix generation of CA certificate for system tests. (#8106) -- [...truncated 2.89 MB...]

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

See Changes: [github] KAFKA-9319: Fix generation of CA certificate for system tests. (#8106) -- [...truncated 2.88 MB...]