Re: Add a customized logo for Kafka Streams

Matthias makes a good point about being careful not to position Streams as outside of Apache Kafka. One obvious thing we could do it just include the Kafka logo as-is in the Streams logo, somehow. I have some unqualified opinions on what that might look like: A good logo is simple and clean, so

Re: Subject: [VOTE] 2.4.1 RC0

+1 (binding) Verified signature, built from source, and ran quickstart successfully (using openjdk version "11.0.6"). I also ran unit tests locally which resulted in a few flaky tests for which there are already open Jiras: ReassignPartitionsClusterTest.shouldMoveSinglePartitionWithinBroker

Re: [DISCUSS] KIP-508: Make Suppression State Queriable - rebooted.

Thanks Matthias, Good idea. I've changed the ticket name and added a note clarifying that this ticket is not the same as https://issues.apache.org/jira/browse/KAFKA-7224 Incidentally, I learned that I never documented my reasons for abandoning my work on KAFKA-7224 ! I've now updated that

[jira] [Created] (KAFKA-9682) Flaky Test KafkaBasedLogTest#testSendAndReadToEnd

Matthias J. Sax created KAFKA-9682: -- Summary: Flaky Test KafkaBasedLogTest#testSendAndReadToEnd Key: KAFKA-9682 URL: https://issues.apache.org/jira/browse/KAFKA-9682 Project: Kafka Issue

Re: [DISCUSS] KIP-508: Make Suppression State Queriable - rebooted.

-BEGIN PGP SIGNED MESSAGE- Hash: SHA512 Thanks for clarification. Can you maybe update the Jira ticket? Do we have a ticket for spill-to-disk? Maybe link to it and explain that it's two different things? Maybe even rename the ticket to something more clear, ie, "make suppress result

Re: KIP-560 Discuss

Thanks for the KIP Sang! I have a couple of more comments about the wiki page: (1) The "Public Interface" section should only list the new stuff. This KIP does not change anything with regard to the existing options `--input-topic` or `--intermediate-topic` and thus it's just "noise" to have

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

Hi Matthias, Oh, I see. Next time, I will take that into account. It looked like at the time there wasn't much contention over the major points of the proposal, so I thought I could pass it. I will also make some last modifications to the KIP. Thanks for your vote! Best, Richard On Sat, Mar

Re: [DISCUSS] KIP-508: Make Suppression State Queriable - rebooted.

Hey Matthias, I’m sorry if the ticket was poorly stated. The ticket is to add a DSL overload to pass a Materialized argument to suppress. As a result, the result of the suppression would be queriable. This is unrelated to “persistent buffer” aka “spill-to-disk”. There was some confusion

Suppress PyCharm Inspection warning

I get an inspection warning in PyCharm "if a protected member is accessed outside the class where it's defined or in a module." I import TopicPartition in order to be able to create TopicPartition objects for assignment to the consumer. The following change in __init__ in the kafka directory

Re: [DISCUSS] KIP-508: Make Suppression State Queriable - rebooted.

-BEGIN PGP SIGNED MESSAGE- Hash: SHA512 Thanks for the KIP Dongjin, I am still not sure if I can follow, what might also be caused by the backing JIRA ticket (maybe John can clarify the intent of the ticket as he created it): Currently, suppress() only uses an in-memory buffer and my

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

-BEGIN PGP SIGNED MESSAGE- Hash: SHA512 What is the status of this KIP? - -Matthias On 2/17/20 2:41 PM, John Roesler wrote: > 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,

Re: Add a customized logo for Kafka Streams

-BEGIN PGP SIGNED MESSAGE- Hash: SHA512 Boyang, thanks for starting this discussion. I like the idea in general however we need to be a little careful IMHO -- as you mentioned Kafka is one project and thus we should avoid the impression that Kafka Streams is not part of Apache Kafka.

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

-BEGIN PGP SIGNED MESSAGE- Hash: SHA512 Richard, you cannot close a KIP as accepted with 2 binging votes. (cf https://cwiki.apache.org/confluence/display/KAFKA/Bylaws) You could only discard the KIP as long as it's not accepted :D However, I am +1 (binding) and thus you can close the

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

See Changes: [github] MINOR: Break up StreamsPartitionAssignor's gargantuan #assign (#8245) -- [...truncated 2.91 MB...] org.apache.kafka.streams.TestTopicsTest >

Re: KIP-560 Discuss

-BEGIN PGP SIGNED MESSAGE- Hash: SHA512 Thanks for the KIP Sang! I have a couple of more comments about the wiki page: (1) The "Public Interface" section should only list the new stuff. This KIP does not change anything with regard to the existing options `--input-topic` or

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

See Changes: [github] MINOR: Reset `streamTime` on clear (#8250) [github] MINOR: Break up StreamsPartitionAssignor's gargantuan #assign (#8245) -- [...truncated 2.89

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

See Changes: [github] KAFKA-9645: Fallback to unsubscribe during Task Migrated (#8220) [github] MINOR: Reset `streamTime` on clear (#8250) -- [...truncated 2.91 MB...]

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

See Changes: [github] KAFKA-9645: Fallback to unsubscribe during Task Migrated (#8220) -- [...truncated 2.89 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

[jira] [Resolved] (KAFKA-9645) Records could not find corresponding partition/task

[ https://issues.apache.org/jira/browse/KAFKA-9645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9645. -- Fix Version/s: 2.6.0 Resolution: Fixed > Records could not find corresponding

[jira] [Created] (KAFKA-9681) Change whitelist/blacklist terms

Gérald Quintana created KAFKA-9681: -- Summary: Change whitelist/blacklist terms Key: KAFKA-9681 URL: https://issues.apache.org/jira/browse/KAFKA-9681 Project: Kafka Issue Type: Wish

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

See

[jira] [Created] (KAFKA-9680) Negative consumer lag

Sayed Mohammad Hossein Torabi created KAFKA-9680: Summary: Negative consumer lag Key: KAFKA-9680 URL: https://issues.apache.org/jira/browse/KAFKA-9680 Project: Kafka Issue

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

See Changes: [github] HOTFIX: fix StateManagerUtilTest and StreamTaskTest failures (#8247) -- [...truncated 5.84 MB...] org.apache.kafka.streams.TopologyTestDriverTest

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

See

回复：回复：回复：[Vote] KIP-571: Add option to force remove members in StreamsResetter

Hi, Matthias Thanks, I updated the KIP to mention the deprecated and newly added methods. 1. What happens is `groupInstanceId` is used for a dynamic group? What happens if both parameters are specified? What happens if `memberId` is specified for a static group? => my understanding is that