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

See Changes: [github] MINOR: Add missing @Test annotation to MetadataTest#testMetadataMerge -- [...truncated 2.88 MB...] org.apache.kafka.streams.TopologyTestDriverTest

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

Hi John, Thanks for your kind explanation with an example. > But it feels like you're saying you're trying to do something different than just query the windowed key and get back the current count? Yes, for example, what if we need to retrieve the (all or range) keys with a closed window? In

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

See Changes: [github] MINOR: Wording fix in Streams DSL docs (#5692) -- [...truncated 2.88 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

Need help to configure Rest Api as source

Hi Team, I need to configure a REST API as the source but I am not getting any document for the same. Can you please share some link or documents which can help me. Thanks in advance. -- Thanks & Regards, Kundan Singh

Re: [DISCUSS] Apache Kafka 2.5.0 release

Randall / Konstantine, Sorry for the late reply. Thanks for the fix and for the update! I see this change on the 2.5 branch (@b403c66). Consider this a retroactive approval for this bugfix :) -David On Fri, Feb 14, 2020 at 2:21 PM Konstantine Karantasis < konstant...@confluent.io> wrote: > Hi

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

See Changes: [github] MINOR: Update shell scripts to support z/OS system (#7913) [github] MINOR: Fix a number of warnings in clients test (#8073) -- [...truncated 2.88

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

See Changes: [github] MINOR: Improve EOS example exception handling (#8052) -- [...truncated 2.88 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

[jira] [Created] (KAFKA-9578) Kafka Tiered Storage - System Tests

Harsha created KAFKA-9578: - Summary: Kafka Tiered Storage - System Tests Key: KAFKA-9578 URL: https://issues.apache.org/jira/browse/KAFKA-9578 Project: Kafka Issue Type: Sub-task

Build failed in Jenkins: kafka-2.2-jdk8-old #212

See Changes: [bill] KAFKA-9533: ValueTransform forwards `null` values (#8108) -- Started by an SCM change Running as SYSTEM [EnvInject] - Loading node environment

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

Thanks Colin, > I guess I don't feel that strongly about it. However, if we are going to > rely on inAnyState() / inStates(...) then let's make sure that the latter > throws an exception when getting an empty list as an argument (since it will > do something other than the obvious behavior of

Re: [VOTE] KIP-545 support automated consumer offset sync across clusters in MM 2.0

Hello committers, I am the author of the KIP-545 and if we still miss votes from the committers, please review the KIP and vote for it, so that the corresponding PR will be reviewed soon.

[jira] [Resolved] (KAFKA-8910) Incorrect javadoc at KafkaProducer.InterceptorCallback#onCompletion

[ https://issues.apache.org/jira/browse/KAFKA-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8910. -- Fix Version/s: 2.6.0 Resolution: Fixed > Incorrect javadoc at

[jira] [Created] (KAFKA-9579) RLM fetch implementation by adding respective purgatory

Satish Duggana created KAFKA-9579: - Summary: RLM fetch implementation by adding respective purgatory Key: KAFKA-9579 URL: https://issues.apache.org/jira/browse/KAFKA-9579 Project: Kafka

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

See Changes: [github] MINOR: Wording fix in Streams DSL docs (#5692) [github] MINOR: Update shell scripts to support z/OS system (#7913) [github] MINOR: Fix a number of warnings in clients test (#8073)

[jira] [Created] (KAFKA-9582) Ensure EOS task producer not through fatal error in unclean shutdown

Boyang Chen created KAFKA-9582: -- Summary: Ensure EOS task producer not through fatal error in unclean shutdown Key: KAFKA-9582 URL: https://issues.apache.org/jira/browse/KAFKA-9582 Project: Kafka

[jira] [Created] (KAFKA-9583) OffsetsForLeaderEpoch requests are sometimes not sent to the leader of partition

Andy Fang created KAFKA-9583: Summary: OffsetsForLeaderEpoch requests are sometimes not sent to the leader of partition Key: KAFKA-9583 URL: https://issues.apache.org/jira/browse/KAFKA-9583 Project:

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

See Changes: [github] HOTFIX: don't try to remove uninitialized changelogs from assignment & -- [...truncated 2.88 MB...]

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

See Changes: [rajinisivaram] MINOR: Add missing @Test annotation to MetadataTest#testMetadataMerge -- [...truncated 1.55 MB...] kafka.tools.ConsoleProducerTest >

Jenkins build is back to normal : kafka-2.3-jdk8 #179

See

[jira] [Created] (KAFKA-9581) Deprecate rebalanceException on StreamThread to avoid infinite loop

Boyang Chen created KAFKA-9581: -- Summary: Deprecate rebalanceException on StreamThread to avoid infinite loop Key: KAFKA-9581 URL: https://issues.apache.org/jira/browse/KAFKA-9581 Project: Kafka

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

See Changes: [bill] KAFKA-9533: ValueTransform forwards `null` values (#8108) -- [...truncated 5.57 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

Re: [DISCUSS] Apache Kafka 2.5.0 release

Hi David, Thanks for being the release main driver. Since the implementation for the last part of KIP-467 wasn't finalized prior to Feb 12th, could you remove KIP-467 from the list? Thanks, Tu On Thu, Feb 20, 2020 at 7:18 AM David Arthur wrote: > Randall / Konstantine, > > Sorry for the late

[jira] [Resolved] (KAFKA-9481) Improve TaskMigratedException handling on Stream thread

[ https://issues.apache.org/jira/browse/KAFKA-9481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9481. -- Fix Version/s: 2.6.0 Resolution: Fixed > Improve TaskMigratedException handling on

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

See Changes: [github] MINOR: Improve EOS example exception handling (#8052) [github] MINOR: Fix javadoc at -- [...truncated 5.86 MB...]

[jira] [Created] (KAFKA-9580) Log clearer error messages when there is an offset out of range

Sanjana Kaundinya created KAFKA-9580: Summary: Log clearer error messages when there is an offset out of range Key: KAFKA-9580 URL: https://issues.apache.org/jira/browse/KAFKA-9580 Project: Kafka

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

See Changes: [github] MINOR: Fix javadoc at -- [...truncated 2.88 MB...] org.apache.kafka.streams.TopologyTestDriverTest > shouldNotUpdateStoreForSmallerValue[Eos

[jira] [Created] (KAFKA-9585) Flaky Test: LagFetchIntegrationTest#shouldFetchLagsDuringRebalancingWithOptimization

Sophie Blee-Goldman created KAFKA-9585: -- Summary: Flaky Test: LagFetchIntegrationTest#shouldFetchLagsDuringRebalancingWithOptimization Key: KAFKA-9585 URL: https://issues.apache.org/jira/browse/KAFKA-9585

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

See Changes: [github] HOTFIX: don't try to remove uninitialized changelogs from assignment & -- [...truncated 5.87 MB...]

[jira] [Created] (KAFKA-9587) Producer configs are omitted in the documentation

Dongjin Lee created KAFKA-9587: -- Summary: Producer configs are omitted in the documentation Key: KAFKA-9587 URL: https://issues.apache.org/jira/browse/KAFKA-9587 Project: Kafka Issue Type:

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

See Changes: [github] KAFKA-9481: Graceful handling TaskMigrated and TaskCorrupted (#8058) -- [...truncated 2.88 MB...] org.apache.kafka.streams.TopologyTestDriverTest

[jira] [Created] (KAFKA-9588) Add rocksdb event listeners in KS

Navinder Brar created KAFKA-9588: Summary: Add rocksdb event listeners in KS Key: KAFKA-9588 URL: https://issues.apache.org/jira/browse/KAFKA-9588 Project: Kafka Issue Type: New Feature

[jira] [Created] (KAFKA-9584) Removing headers causes ConcurrentModificationException

Micah Ramos created KAFKA-9584: -- Summary: Removing headers causes ConcurrentModificationException Key: KAFKA-9584 URL: https://issues.apache.org/jira/browse/KAFKA-9584 Project: Kafka Issue

[jira] [Created] (KAFKA-9586) Fix errored json filename in ops documentation

Dongjin Lee created KAFKA-9586: -- Summary: Fix errored json filename in ops documentation Key: KAFKA-9586 URL: https://issues.apache.org/jira/browse/KAFKA-9586 Project: Kafka Issue Type:

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

See Changes: [bill] KAFKA-9533: ValueTransform forwards `null` values (#8108) [github] KAFKA-9562: part 1: ignore exceptions while flushing stores in -- [...truncated 2.90

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

See Changes: [github] KAFKA-9481: Graceful handling TaskMigrated and TaskCorrupted (#8058) -- [...truncated 2.90 MB...]

[jira] [Resolved] (KAFKA-6266) Kafka 1.0.0 : Repeated occurrence of WARN Resetting first dirty offset of __consumer_offsets-xx to log start offset 203569 since the checkpointed offset 120955 is invali

[ https://issues.apache.org/jira/browse/KAFKA-6266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-6266. Resolution: Fixed Merged into 2.4 and trunk. > Kafka 1.0.0 : Repeated occurrence of WARN Resetting first

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

[ https://issues.apache.org/jira/browse/KAFKA-9574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-9574. --- Resolution: Fixed > Contact page links to spam/ads site on search-hadoop[.]com domain >

[jira] [Resolved] (KAFKA-9571) MirrorMaker task failing during pool

[ https://issues.apache.org/jira/browse/KAFKA-9571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nitish Goyal resolved KAFKA-9571. - Resolution: Fixed > MirrorMaker task failing during pool >

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

Hi John, I am glad to help you with your imagination. With overhead, I mainly meant the additional lookup into the state store to get the current value, but I see now in the code that we do that lookup anyways (although I think we could avoid that in the cases where we do not need the old value).