John Roesler created KAFKA-10540:
Summary: Convert KStream aggregations to new PAPI
Key: KAFKA-10540
URL: https://issues.apache.org/jira/browse/KAFKA-10540
Project: Kafka
Issue Type:
John Roesler created KAFKA-10539:
Summary: Convert KStreamImpl joins to new PAPI
Key: KAFKA-10539
URL: https://issues.apache.org/jira/browse/KAFKA-10539
Project: Kafka
Issue Type: Sub-task
John Roesler created KAFKA-10538:
Summary: Convert KStreamImpl maps to new PAPI
Key: KAFKA-10538
URL: https://issues.apache.org/jira/browse/KAFKA-10538
Project: Kafka
Issue Type: Sub-task
John Roesler created KAFKA-10537:
Summary: Convert KStreamImpl filters to new PAPI
Key: KAFKA-10537
URL: https://issues.apache.org/jira/browse/KAFKA-10537
Project: Kafka
Issue Type: Sub-task
John Roesler created KAFKA-10536:
Summary: KIP-478: Implement KStream changes
Key: KAFKA-10536
URL: https://issues.apache.org/jira/browse/KAFKA-10536
Project: Kafka
Issue Type: Sub-task
John Roesler created KAFKA-10535:
Summary: KIP-478: Implement StateStoreContext and Record
Key: KAFKA-10535
URL: https://issues.apache.org/jira/browse/KAFKA-10535
Project: Kafka
Issue Type:
John Roesler created KAFKA-10472:
Summary: Consider migrating Topology methods to the Builder pattern
Key: KAFKA-10472
URL: https://issues.apache.org/jira/browse/KAFKA-10472
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10307.
--
Resolution: Not A Bug
This bug report was based on an invalid assumption that topologies
John Roesler created KAFKA-10437:
Summary: Convert test-utils (and StateStore) for KIP-478
Key: KAFKA-10437
URL: https://issues.apache.org/jira/browse/KAFKA-10437
Project: Kafka
Issue Type:
John Roesler created KAFKA-10436:
Summary: Implement KIP-478 Topology changes
Key: KAFKA-10436
URL: https://issues.apache.org/jira/browse/KAFKA-10436
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-10379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10379.
--
Resolution: Fixed
> Implement the KIP-478 StreamBuilder#addGlobalStore()
>
John Roesler created KAFKA-10379:
Summary: Implement the KIP-478 StreamBuilder#addGlobalStore()
Key: KAFKA-10379
URL: https://issues.apache.org/jira/browse/KAFKA-10379
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-10261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10261.
--
Resolution: Fixed
> Introduce the KIP-478 processors with shims
>
John Roesler created KAFKA-10336:
Summary: Rolling upgrade with Suppression AND Standbys may throw
exceptions
Key: KAFKA-10336
URL: https://issues.apache.org/jira/browse/KAFKA-10336
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-9210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-9210.
-
Resolution: Fixed
> kafka stream loss data
> --
>
> Key:
John Roesler created KAFKA-10319:
Summary: Fix unknown offset sum on trunk
Key: KAFKA-10319
URL: https://issues.apache.org/jira/browse/KAFKA-10319
Project: Kafka
Issue Type: Sub-task
John Roesler created KAFKA-10298:
Summary: Replace Windows with a proper interface
Key: KAFKA-10298
URL: https://issues.apache.org/jira/browse/KAFKA-10298
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-10254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10254.
--
Resolution: Fixed
Changing resolution to "fixed", since the linked duplicate is fixed.
>
[
https://issues.apache.org/jira/browse/KAFKA-10254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reopened KAFKA-10254:
--
> 100% cpu usage by kafkaConsumer poll , when broker can‘t be connect
>
[
https://issues.apache.org/jira/browse/KAFKA-9763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-9763.
-
Resolution: Fixed
> Recent changes to Connect's InsertField will fail to inject field on key of
[
https://issues.apache.org/jira/browse/KAFKA-9763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reopened KAFKA-9763:
-
> Recent changes to Connect's InsertField will fail to inject field on key of
> tombstone record
>
[
https://issues.apache.org/jira/browse/KAFKA-10254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10254.
--
Resolution: Duplicate
Hey [~xiaotong.wang] , thanks for the report! It looks like a duplicate
John Roesler created KAFKA-10261:
Summary: Introduce the KIP-478 processors with shims
Key: KAFKA-10261
URL: https://issues.apache.org/jira/browse/KAFKA-10261
Project: Kafka
Issue Type:
John Roesler created KAFKA-10260:
Summary: Streams could recover stores in a task independently
Key: KAFKA-10260
URL: https://issues.apache.org/jira/browse/KAFKA-10260
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-10248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10248.
--
Resolution: Fixed
> Drop idempotent KTable source updates
>
John Roesler created KAFKA-10248:
Summary: Drop idempotent KTable source updates
Key: KAFKA-10248
URL: https://issues.apache.org/jira/browse/KAFKA-10248
Project: Kafka
Issue Type: Sub-task
John Roesler created KAFKA-10247:
Summary: Streams may attempt to process after closing a task
Key: KAFKA-10247
URL: https://issues.apache.org/jira/browse/KAFKA-10247
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-10221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10221.
--
Resolution: Fixed
> Backport fix for KAFKA-9603 to 2.5
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10173.
--
Fix Version/s: (was: 2.5.1)
(was: 2.4.2)
Resolution: Fixed
John Roesler created KAFKA-10217:
Summary: Move nodeLevelSensor and storeLevelSensor methods from
StreamsMetricsImpl to StreamsMetrics
Key: KAFKA-10217
URL: https://issues.apache.org/jira/browse/KAFKA-10217
John Roesler created KAFKA-10215:
Summary: MockProcessorContext doesn't work with SessionStores
Key: KAFKA-10215
URL: https://issues.apache.org/jira/browse/KAFKA-10215
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-10185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10185.
--
Resolution: Fixed
> Streams should log summarized restoration information at info level
>
John Roesler created KAFKA-10203:
Summary: Rolling upgrade from 2.1.1 to trunk (2.7.x) doesn't work
Key: KAFKA-10203
URL: https://issues.apache.org/jira/browse/KAFKA-10203
Project: Kafka
John Roesler created KAFKA-10202:
Summary: SmokeTest should provide a machanism to generate
continuously AND verify the result
Key: KAFKA-10202
URL: https://issues.apache.org/jira/browse/KAFKA-10202
John Roesler created KAFKA-10200:
Summary: MockProcessorContext doesn't work with WindowStores
Key: KAFKA-10200
URL: https://issues.apache.org/jira/browse/KAFKA-10200
Project: Kafka
Issue
John Roesler created KAFKA-10185:
Summary: Streams should log summarized restoration information at
info level
Key: KAFKA-10185
URL: https://issues.apache.org/jira/browse/KAFKA-10185
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10165.
--
Resolution: Fixed
> Percentiles metric leaking memory
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-10086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10086.
--
Resolution: Fixed
> Standby state isn't always re-used when transitioning to active
>
John Roesler created KAFKA-10121:
Summary: Streams Task Assignment optimization design
Key: KAFKA-10121
URL: https://issues.apache.org/jira/browse/KAFKA-10121
Project: Kafka
Issue Type: Task
John Roesler created KAFKA-10091:
Summary: Improve task idling
Key: KAFKA-10091
URL: https://issues.apache.org/jira/browse/KAFKA-10091
Project: Kafka
Issue Type: Task
Components:
John Roesler created KAFKA-10086:
Summary: Write Integration Test for
StreamsTaskAssignor/HighAvailabilityTaskAssignor
Key: KAFKA-10086
URL: https://issues.apache.org/jira/browse/KAFKA-10086
Project:
John Roesler created KAFKA-10084:
Summary: System test failure:
StreamsEosTest.test_failure_and_recovery_complex
Key: KAFKA-10084
URL: https://issues.apache.org/jira/browse/KAFKA-10084
Project: Kafka
John Roesler created KAFKA-10068:
Summary: Verify HighAvailabilityTaskAssignor performance with
large clusters and topologies
Key: KAFKA-10068
URL: https://issues.apache.org/jira/browse/KAFKA-10068
John Roesler created KAFKA-10058:
Summary: Create Windowing Operations overview documentation
Key: KAFKA-10058
URL: https://issues.apache.org/jira/browse/KAFKA-10058
Project: Kafka
Issue
John Roesler created KAFKA-10046:
Summary: Deprecated PartitionGrouper config is ignored
Key: KAFKA-10046
URL: https://issues.apache.org/jira/browse/KAFKA-10046
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-9994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-9994.
-
Resolution: Fixed
> Catch TaskMigrated exception in task corruption code path
>
[
https://issues.apache.org/jira/browse/KAFKA-10008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10008.
--
Resolution: Won't Fix
Following the other comments, we've decided just to document it.
>
[
https://issues.apache.org/jira/browse/KAFKA-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-9925.
-
Resolution: Fixed
> Non-key KTable Joining may result in duplicate schema name in confluence
>
[
https://issues.apache.org/jira/browse/KAFKA-9875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-9875.
-
Resolution: Fixed
https://github.com/apache/kafka/pull/8578
> Flaky Test
>
John Roesler created KAFKA-9831:
---
Summary: Failing test:
EosIntegrationTest.shouldNotViolateEosIfOneTaskFailsWithState[exactly_once_beta]
Key: KAFKA-9831
URL: https://issues.apache.org/jira/browse/KAFKA-9831
John Roesler created KAFKA-9791:
---
Summary: Streams should log the effective RocksDB configuration
when opening a database
Key: KAFKA-9791
URL: https://issues.apache.org/jira/browse/KAFKA-9791
Project:
[
https://issues.apache.org/jira/browse/KAFKA-9742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-9742.
-
Resolution: Fixed
> StandbyTaskEOSIntegrationTest broken
>
John Roesler created KAFKA-9742:
---
Summary: Flaky test StandbyTaskEOSIntegrationTest
Key: KAFKA-9742
URL: https://issues.apache.org/jira/browse/KAFKA-9742
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-9734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-9734.
-
Resolution: Fixed
> Streams IllegalStateException in trunk during rebalance
>
John Roesler created KAFKA-9734:
---
Summary: Streams IllegalStateException in trunk during rebalance
Key: KAFKA-9734
URL: https://issues.apache.org/jira/browse/KAFKA-9734
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-9636.
-
Resolution: Not A Bug
Closing this ticket as "not a bug" because the test failure turned out to
[
https://issues.apache.org/jira/browse/KAFKA-7932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-7932.
-
Resolution: Duplicate
Subsumed by https://issues.apache.org/jira/browse/KAFKA-9274
> Streams
[
https://issues.apache.org/jira/browse/KAFKA-8147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-8147.
-
Resolution: Fixed
Merged as
[
https://issues.apache.org/jira/browse/KAFKA-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reopened KAFKA-9533:
-
> ValueTransform forwards `null` values
> -
>
>
John Roesler created KAFKA-9562:
---
Summary: Streams not making progress under heavy failures with EOS
enabled on 2.5 branch
Key: KAFKA-9562
URL: https://issues.apache.org/jira/browse/KAFKA-9562
Project:
[
https://issues.apache.org/jira/browse/KAFKA-9557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-9557.
-
Fix Version/s: 2.6.0
Resolution: Fixed
> Thread-level "process" metrics are computed
John Roesler created KAFKA-9557:
---
Summary: Thread-level "process" metrics are computed incorrectly
Key: KAFKA-9557
URL: https://issues.apache.org/jira/browse/KAFKA-9557
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-9500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-9500.
-
Resolution: Fixed
> Foreign-Key Join creates an invalid topology
>
[
https://issues.apache.org/jira/browse/KAFKA-9503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-9503.
-
Resolution: Fixed
> TopologyTestDriver processes intermediate results in the wrong order
>
[
https://issues.apache.org/jira/browse/KAFKA-9390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-9390.
-
Resolution: Fixed
> Non-key joining of KTable not compatible with confluent avro serdes
>
John Roesler created KAFKA-9503:
---
Summary: TopologyTestDriver processes intermediate results in the
wrong order
Key: KAFKA-9503
URL: https://issues.apache.org/jira/browse/KAFKA-9503
Project: Kafka
John Roesler created KAFKA-9500:
---
Summary: Foreign-Key Join creates an invalid topology
Key: KAFKA-9500
URL: https://issues.apache.org/jira/browse/KAFKA-9500
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-6144.
-
Resolution: Fixed
> Allow serving interactive queries from in-sync Standbys
>
[
https://issues.apache.org/jira/browse/KAFKA-9431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-9431.
-
Resolution: Fixed
> Expose API in KafkaStreams to fetch all local offset lags
>
[
https://issues.apache.org/jira/browse/KAFKA-9429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-9429.
-
Resolution: Fixed
> Allow ability to control whether stale reads out of state stores are
[
https://issues.apache.org/jira/browse/KAFKA-9428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-9428.
-
Resolution: Fixed
> Expose standby information in KafkaStreams via queryMetadataForKey API
>
[
https://issues.apache.org/jira/browse/KAFKA-8868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-8868.
-
Resolution: Fixed
> Consider auto-generating Streams binary protocol messages
>
[
https://issues.apache.org/jira/browse/KAFKA-9310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-9310.
-
Resolution: Fixed
> StreamThread may die from recoverable UnknownProducerId exception
>
John Roesler created KAFKA-9310:
---
Summary: StreamThread may die from recoverable UnknownProducerId
exception
Key: KAFKA-9310
URL: https://issues.apache.org/jira/browse/KAFKA-9310
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-9138.
-
Resolution: Fixed
Added the system test in
John Roesler created KAFKA-9289:
---
Summary: consolidate all the streams smoke system tests
Key: KAFKA-9289
URL: https://issues.apache.org/jira/browse/KAFKA-9289
Project: Kafka
Issue Type: Bug
John Roesler created KAFKA-9268:
---
Summary: Follow-on: Streams Threads may die from recoverable
errors with EOS enabled
Key: KAFKA-9268
URL: https://issues.apache.org/jira/browse/KAFKA-9268
Project:
[
https://issues.apache.org/jira/browse/KAFKA-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-9231.
-
Resolution: Fixed
Fixed in 2.4 by
John Roesler created KAFKA-9263:
---
Summary: Reocurrence: Transient failure in
kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpointkafka.api.AdminClientIntegrationTest.testAlterReplicaLogDirs
Key: KAFKA-9263
John Roesler created KAFKA-9264:
---
Summary: Reocurrence: Flaky Test
DelegationTokenEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl
Key: KAFKA-9264
URL:
[
https://issues.apache.org/jira/browse/KAFKA-8937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reopened KAFKA-8937:
-
This test has just failed again for me. Apparently, it is not fixed.
Unfortunately, Jenkins didn't
John Roesler created KAFKA-9231:
---
Summary: ProducerFencedException may cause Streams Thread to die
Key: KAFKA-9231
URL: https://issues.apache.org/jira/browse/KAFKA-9231
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-9169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-9169.
-
Resolution: Fixed
This was fixed in https://github.com/apache/kafka/pull/7681/ and merged to
John Roesler created KAFKA-9138:
---
Summary: Add system test covering Foreign Key joins (KIP-213)
Key: KAFKA-9138
URL: https://issues.apache.org/jira/browse/KAFKA-9138
Project: Kafka
Issue Type:
John Roesler created KAFKA-9103:
---
Summary: KIP-441: Add TaskLags to SubscriptionInfo
Key: KAFKA-9103
URL: https://issues.apache.org/jira/browse/KAFKA-9103
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-8902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-8902.
-
Resolution: Fixed
I wrote a simple Streams application using the Processor API to update 10
John Roesler created KAFKA-9058:
---
Summary: Foreign Key Join should not require a queriable store
Key: KAFKA-9058
URL: https://issues.apache.org/jira/browse/KAFKA-9058
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-9022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-9022.
-
Resolution: Duplicate
> Flaky Test KTableKTableForeignKeyJoinIntegrationTest.
>
[
https://issues.apache.org/jira/browse/KAFKA-9006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-9006.
-
Resolution: Duplicate
> Flaky Test
>
John Roesler created KAFKA-8868:
---
Summary: Consider auto-generating Streams binary protocol messages
Key: KAFKA-8868
URL: https://issues.apache.org/jira/browse/KAFKA-8868
Project: Kafka
Issue
John Roesler created KAFKA-8770:
---
Summary: Either switch to or add an option for emit-on-change
Key: KAFKA-8770
URL: https://issues.apache.org/jira/browse/KAFKA-8770
Project: Kafka
Issue Type:
John Roesler created KAFKA-8769:
---
Summary: Consider computing stream time independently per key
Key: KAFKA-8769
URL: https://issues.apache.org/jira/browse/KAFKA-8769
Project: Kafka
Issue Type:
John Roesler created KAFKA-8696:
---
Summary: Clean up Sum/Count/Total metrics
Key: KAFKA-8696
URL: https://issues.apache.org/jira/browse/KAFKA-8696
Project: Kafka
Issue Type: Improvement
John Roesler created KAFKA-8582:
---
Summary: Consider adding an ExpiredWindowRecordHandler to Suppress
Key: KAFKA-8582
URL: https://issues.apache.org/jira/browse/KAFKA-8582
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-8452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-8452.
-
Resolution: Fixed
> Possible Suppress buffer optimization: de-duplicate prior value
>
John Roesler created KAFKA-8478:
---
Summary: Poll for more records before forced processing
Key: KAFKA-8478
URL: https://issues.apache.org/jira/browse/KAFKA-8478
Project: Kafka
Issue Type:
John Roesler created KAFKA-8455:
---
Summary: Add NothingSerde to Serdes
Key: KAFKA-8455
URL: https://issues.apache.org/jira/browse/KAFKA-8455
Project: Kafka
Issue Type: Improvement
John Roesler created KAFKA-8452:
---
Summary: Possible Suppress buffer optimization: de-duplicate prior
value
Key: KAFKA-8452
URL: https://issues.apache.org/jira/browse/KAFKA-8452
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-7991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-7991.
-
Resolution: Duplicate
Yep. Closing as a duplicate.
> Add StreamsUpgradeTest for 2.2 release
>
John Roesler created KAFKA-8410:
---
Summary: Strengthen the types of Processors, at least in the DSL,
maybe in the PAPI as well
Key: KAFKA-8410
URL: https://issues.apache.org/jira/browse/KAFKA-8410
101 - 200 of 274 matches
Mail list logo
