[jira] [Created] (KAFKA-9572) Sum Computation with Exactly-Once Enabled and Injected Failures Misses Some Records

Bruno Cadonna created KAFKA-9572: Summary: Sum Computation with Exactly-Once Enabled and Injected Failures Misses Some Records Key: KAFKA-9572 URL: https://issues.apache.org/jira/browse/KAFKA-9572

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

Hi all, Sorry for the late reply! I am also in favour of baby steps. I am undecided whether the KIP should contain a opt-out config or not. The overhead of emit-on-change might affect latency. For applications where low latency is crucial and there are not too many idempotent updates, it would

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

Hi John, 'The intermediate state of the suppression' in KIP does not mean the state of upstream KTable - sure, the state of the upstream KTable can be queried by materializing the operator immediately before the suppress as you shown. What I meant in KIP was the final state of the buffer, which

JIRA access request

Hi, I am a newbie, could somebody please open JIRA access for me ? Thanks.

ConsumerRebalanceListener not being invoked

Hello Kafka Team, I just cannot get my registered "ConsumerRebalanceListener" to be invoked. GitHub Commit for a full picture if that helps: https://github.com/slydogshah/appGalCloud/commit/323a447929a17d8449b931a2972a746251dce495 Here is my KafkaConsumer bootstrap code Properties config

[jira] [Resolved] (KAFKA-9533) ValueTransform forwards `null` values

[ https://issues.apache.org/jira/browse/KAFKA-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-9533. Resolution: Fixed > ValueTransform forwards `null` values > -

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

See

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

See Changes: [jason] KAFKA-9558; Fix retry logic in KafkaAdminClient listOffsets (#8119) -- [...truncated 2.89 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

Re: [DISCUSS] KIP-518: Allow listing consumer groups per state

On Thu, Feb 13, 2020, at 08:24, Mickael Maison wrote: > Hi Colin, > > > Can you please specify what the result is when a newer client tries to use > > this on an older broker? Does that result in an > > UnsupportedVersionException? > Yes, in case this feature is not supported by the broker, >

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

Thanks for the response, Dongjin, I'm sorry, but I'm still not following. It seems like the view you would get on the "current state of the buffer" would always be equivalent to the view of the upstream table. Let me try an example, and maybe you can point out the flaw in my reasoning. Let's

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

Thanks for your remarks, Bruno! I'm in favor of standardizing on terminology like "not forwarding idempotent updates" or "dropping idempotent updates". Maybe we should make a pass on the KIP and just convert everything to this phrasing. In retrospect, even the term "emit-on-change" has too much

Re: [DISCUSS] KIP-570: Add leader epoch in StopReplicaRequest

Hey Jason, You're right. The leader epoch is not bumped when a topic is deleted. Using a sentinel (e.g. -1) which would override any existing epoch sounds like a good approach in this case. Let me update the KIP to reflect that. Thanks, David On Fri, Feb 14, 2020 at 8:11 PM Jason Gustafson

[jira] [Resolved] (KAFKA-9473) A large number of core system tests failing due to Kafka server failed to start on trunk

[ https://issues.apache.org/jira/browse/KAFKA-9473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9473. Resolution: Fixed > A large number of core system tests failing due to Kafka server failed to >

[jira] [Created] (KAFKA-9576) Topic creation failure causing Stream thread death

Boyang Chen created KAFKA-9576: -- Summary: Topic creation failure causing Stream thread death Key: KAFKA-9576 URL: https://issues.apache.org/jira/browse/KAFKA-9576 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-9544) Flaky Test `KafkaAdminClientTest.testDefaultApiTimeoutOverride`

[ https://issues.apache.org/jira/browse/KAFKA-9544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9544. Resolution: Fixed > Flaky Test `KafkaAdminClientTest.testDefaultApiTimeoutOverride` >

[jira] [Created] (KAFKA-9575) "Notable changes in 2.5.0" doesn't mention ZooKeeper 3.5.7

Ron Dagostino created KAFKA-9575: Summary: "Notable changes in 2.5.0" doesn't mention ZooKeeper 3.5.7 Key: KAFKA-9575 URL: https://issues.apache.org/jira/browse/KAFKA-9575 Project: Kafka

Jenkins build is back to normal : kafka-2.5-jdk8 #33

See

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

See Changes: [github] KAFKA-9558; Fix retry logic in KafkaAdminClient listOffsets (#8119) -- [...truncated 1.64 MB...] kafka.coordinator.group.GroupMetadataManagerTest >

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

See Changes: [github] KAFKA-9544; Fix flaky test [github] MINOR: fix omitted 'next.' in interactive queries documentation (#7883) [github] KAFKA-9533: ValueTransform forwards `null` values (#8108)

[jira] [Created] (KAFKA-9577) Client encountering SASL_HANDSHAKE protocol version errors on 2.5 / trunk

Lucas Bradstreet created KAFKA-9577: --- Summary: Client encountering SASL_HANDSHAKE protocol version errors on 2.5 / trunk Key: KAFKA-9577 URL: https://issues.apache.org/jira/browse/KAFKA-9577

[jira] [Created] (KAFKA-9574) Contact page links to spam/ads site on search-hadoop[.]com domain

Gert van Dijk created KAFKA-9574: Summary: Contact page links to spam/ads site on search-hadoop[.]com domain Key: KAFKA-9574 URL: https://issues.apache.org/jira/browse/KAFKA-9574 Project: Kafka

Re: [DISCUSS] KIP-569: DescribeConfigsResponse - Update the schema to include datatype of the field

Bump. Thanks Shailesh On Tue, Feb 11, 2020 at 1:00 PM Shailesh Panwar wrote: > Hi all, > We would like to extend the DescribeConfigsResponse schema to include the > data-type of the fields. > > The KIP can be found here: > >

[jira] [Created] (KAFKA-9573) TestUpgrade system test failed on Java11.

Nikolay Izhikov created KAFKA-9573: -- Summary: TestUpgrade system test failed on Java11. Key: KAFKA-9573 URL: https://issues.apache.org/jira/browse/KAFKA-9573 Project: Kafka Issue Type: