John Roesler created KAFKA-14995:
Summary: Automate asf.yaml collaborators refresh
Key: KAFKA-14995
URL: https://issues.apache.org/jira/browse/KAFKA-14995
Project: Kafka
Issue Type:
John Roesler created KAFKA-14364:
Summary: Support evolving serde with Foreign Key Join
Key: KAFKA-14364
URL: https://issues.apache.org/jira/browse/KAFKA-14364
Project: Kafka
Issue Type:
John Roesler created KAFKA-14254:
Summary: Format timestamps in assignor logs as dates instead of
integers
Key: KAFKA-14254
URL: https://issues.apache.org/jira/browse/KAFKA-14254
Project: Kafka
John Roesler created KAFKA-14253:
Summary: StreamsPartitionAssignor should print the member count in
assignment logs
Key: KAFKA-14253
URL: https://issues.apache.org/jira/browse/KAFKA-14253
Project:
John Roesler created KAFKA-14202:
Summary: IQv2: Expose binary store schema to store implementations
Key: KAFKA-14202
URL: https://issues.apache.org/jira/browse/KAFKA-14202
Project: Kafka
John Roesler created KAFKA-14020:
Summary: Performance regression in Producer
Key: KAFKA-14020
URL: https://issues.apache.org/jira/browse/KAFKA-14020
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-13654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-13654.
--
Fix Version/s: 3.3.0
Resolution: Fixed
> Extend KStream process with new Processor API
John Roesler created KAFKA-13820:
Summary: Add debug-level logs to explain why a store is filtered
out during interactive query
Key: KAFKA-13820
URL: https://issues.apache.org/jira/browse/KAFKA-13820
John Roesler created KAFKA-13819:
Summary: Add application.server to Streams assignor logs when set
Key: KAFKA-13819
URL: https://issues.apache.org/jira/browse/KAFKA-13819
Project: Kafka
John Roesler created KAFKA-13818:
Summary: Add generation to consumer assignor logs
Key: KAFKA-13818
URL: https://issues.apache.org/jira/browse/KAFKA-13818
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-13479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-13479.
--
Fix Version/s: 3.2.0
Resolution: Fixed
> Interactive Query v2
>
>
[
https://issues.apache.org/jira/browse/KAFKA-13554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-13554.
--
Resolution: Won't Fix
> Rename RangeQuery to KeyRangeQuery
>
[
https://issues.apache.org/jira/browse/KAFKA-13714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-13714.
--
Fix Version/s: 3.2.0
Assignee: John Roesler
Resolution: Fixed
> Flaky test
John Roesler created KAFKA-13714:
Summary: Flaky test IQv2StoreIntegrationTest
Key: KAFKA-13714
URL: https://issues.apache.org/jira/browse/KAFKA-13714
Project: Kafka
Issue Type: Bug
John Roesler created KAFKA-13622:
Summary: Revisit the complexity of position tracking in state
stores
Key: KAFKA-13622
URL: https://issues.apache.org/jira/browse/KAFKA-13622
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-13608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-13608.
--
Resolution: Duplicate
> Implement Position restoration for all in-memory state stores
>
[
https://issues.apache.org/jira/browse/KAFKA-13524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-13524.
--
Resolution: Fixed
> IQv2: Implement KeyQuery from the RecordCache
>
[
https://issues.apache.org/jira/browse/KAFKA-13525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-13525.
--
Resolution: Fixed
> IQv2: Implement KeyQuery from the KIP
>
John Roesler created KAFKA-13557:
Summary: IQv2: Remove swapResult from the public API
Key: KAFKA-13557
URL: https://issues.apache.org/jira/browse/KAFKA-13557
Project: Kafka
Issue Type:
John Roesler created KAFKA-13554:
Summary: Rename RangeQuery to KeyRangeQuery
Key: KAFKA-13554
URL: https://issues.apache.org/jira/browse/KAFKA-13554
Project: Kafka
Issue Type: Sub-task
John Roesler created KAFKA-13553:
Summary: Add DSL stores to IQv2StoreIntegrationTest
Key: KAFKA-13553
URL: https://issues.apache.org/jira/browse/KAFKA-13553
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-13492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-13492.
--
Resolution: Fixed
> IQ Parity: queries for key/value store range and scan
>
John Roesler created KAFKA-13548:
Summary: IQv2: revisit WindowKeyQuery and WindowRangeQuery
Key: KAFKA-13548
URL: https://issues.apache.org/jira/browse/KAFKA-13548
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-13532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-13532.
--
Resolution: Cannot Reproduce
I looked in every branch build I could find, and didn't see any
John Roesler created KAFKA-13526:
Summary: IQv2: Consider more generic logic for mapping between
binary and typed queries
Key: KAFKA-13526
URL: https://issues.apache.org/jira/browse/KAFKA-13526
John Roesler created KAFKA-13525:
Summary: IQv2: Implement KeyQuery from the KIP
Key: KAFKA-13525
URL: https://issues.apache.org/jira/browse/KAFKA-13525
Project: Kafka
Issue Type: Sub-task
John Roesler created KAFKA-13524:
Summary: IQv2: Add option to query from caches
Key: KAFKA-13524
URL: https://issues.apache.org/jira/browse/KAFKA-13524
Project: Kafka
Issue Type: Sub-task
John Roesler created KAFKA-13523:
Summary: Implement IQv2 support in global stores
Key: KAFKA-13523
URL: https://issues.apache.org/jira/browse/KAFKA-13523
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-13506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-13506.
--
Resolution: Fixed
> IQv2: Transmit position to standbys
> ---
[
https://issues.apache.org/jira/browse/KAFKA-13491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-13491.
--
Resolution: Fixed
> Implement IQv2 Framework
>
>
>
John Roesler created KAFKA-13522:
Summary: IQv2: Implement position tracking and bounding in API
Key: KAFKA-13522
URL: https://issues.apache.org/jira/browse/KAFKA-13522
Project: Kafka
Issue
John Roesler created KAFKA-13506:
Summary: IQv2: Transmit position to standbys
Key: KAFKA-13506
URL: https://issues.apache.org/jira/browse/KAFKA-13506
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-13498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-13498.
--
Resolution: Fixed
> IQv2: Track Position in remaining stores
>
John Roesler created KAFKA-13498:
Summary: IQv2: Track Position in remaining stores
Key: KAFKA-13498
URL: https://issues.apache.org/jira/browse/KAFKA-13498
Project: Kafka
Issue Type:
John Roesler created KAFKA-13492:
Summary: IQ Parity: queries for key/value store range and scan
Key: KAFKA-13492
URL: https://issues.apache.org/jira/browse/KAFKA-13492
Project: Kafka
Issue
John Roesler created KAFKA-13491:
Summary: Implement IQv2 Framework
Key: KAFKA-13491
URL: https://issues.apache.org/jira/browse/KAFKA-13491
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-13480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-13480.
--
Resolution: Fixed
> IQv2: Track Position in KeyValue stores
>
John Roesler created KAFKA-13480:
Summary: IQv2: Track Position in KeyValue stores
Key: KAFKA-13480
URL: https://issues.apache.org/jira/browse/KAFKA-13480
Project: Kafka
Issue Type: Sub-task
John Roesler created KAFKA-13479:
Summary: Interactive Query v2
Key: KAFKA-13479
URL: https://issues.apache.org/jira/browse/KAFKA-13479
Project: Kafka
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/KAFKA-13426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-13426.
--
Resolution: Fixed
> Add recordMetadata to StateStoreContext
>
[
https://issues.apache.org/jira/browse/KAFKA-13429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-13429.
--
Resolution: Fixed
> Update gitignore to include new modules
>
[
https://issues.apache.org/jira/browse/KAFKA-4064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-4064.
-
Fix Version/s: 3.1.0
Resolution: Fixed
> Add support for infinite endpoints for range
John Roesler created KAFKA-13117:
Summary: After processors, migrate TupleForwarder and
CacheFlushListener
Key: KAFKA-13117
URL: https://issues.apache.org/jira/browse/KAFKA-13117
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10546.
--
Resolution: Fixed
> KIP-478: Deprecate the old PAPI interfaces
>
[
https://issues.apache.org/jira/browse/KAFKA-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reopened KAFKA-8410:
-
> Strengthen the types of Processors, at least in the DSL, maybe in the PAPI as
> well
>
[
https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10091.
--
Resolution: Fixed
> Improve task idling
> ---
>
> Key:
[
https://issues.apache.org/jira/browse/KAFKA-12360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-12360.
--
Resolution: Fixed
> Improve documentation of max.task.idle.ms (kafka-streams)
>
[
https://issues.apache.org/jira/browse/KAFKA-8478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-8478.
-
Resolution: Fixed
> Poll for more records before forced processing
>
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-8315.
-
Resolution: Fixed
> Historical join issues
> --
>
> Key:
[
https://issues.apache.org/jira/browse/KAFKA-7458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-7458.
-
Resolution: Fixed
> Avoid enforced processing during bootstrap phase
>
[
https://issues.apache.org/jira/browse/KAFKA-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-8410.
-
Resolution: Fixed
> Strengthen the types of Processors, at least in the DSL, maybe in the PAPI
John Roesler created KAFKA-13002:
Summary: dev branch Streams not able to fetch end offsets from
pre-3.0 brokers
Key: KAFKA-13002
URL: https://issues.apache.org/jira/browse/KAFKA-13002
Project: Kafka
John Roesler created KAFKA-12939:
Summary: After migrating processors, search the codebase for
missed migrations
Key: KAFKA-12939
URL: https://issues.apache.org/jira/browse/KAFKA-12939
Project: Kafka
John Roesler created KAFKA-12842:
Summary: Failing test:
org.apache.kafka.connect.integration.ConnectWorkerIntegrationTest.testSourceTaskNotBlockedOnShutdownWithNonExistentTopic
Key: KAFKA-12842
URL:
John Roesler created KAFKA-12767:
Summary: Properly set Streams system test runtime classpath
Key: KAFKA-12767
URL: https://issues.apache.org/jira/browse/KAFKA-12767
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-12602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-12602.
--
Resolution: Fixed
> The LICENSE and NOTICE files don't list everything they should
>
John Roesler created KAFKA-12625:
Summary: Fix the NOTICE file
Key: KAFKA-12625
URL: https://issues.apache.org/jira/browse/KAFKA-12625
Project: Kafka
Issue Type: Task
Reporter:
John Roesler created KAFKA-12624:
Summary: Fix LICENSE in 2.6
Key: KAFKA-12624
URL: https://issues.apache.org/jira/browse/KAFKA-12624
Project: Kafka
Issue Type: Sub-task
John Roesler created KAFKA-12623:
Summary: Fix LICENSE in 2.7
Key: KAFKA-12623
URL: https://issues.apache.org/jira/browse/KAFKA-12623
Project: Kafka
Issue Type: Sub-task
John Roesler created KAFKA-12622:
Summary: Automate LICENCSE file validation
Key: KAFKA-12622
URL: https://issues.apache.org/jira/browse/KAFKA-12622
Project: Kafka
Issue Type: Task
[
https://issues.apache.org/jira/browse/KAFKA-12593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-12593.
--
Resolution: Fixed
> Some Scala, Python, and Gradle files contain the wrong license header
>
John Roesler created KAFKA-12602:
Summary: The LICENSE and NOTICE files don't list everything they
should
Key: KAFKA-12602
URL: https://issues.apache.org/jira/browse/KAFKA-12602
Project: Kafka
John Roesler created KAFKA-12593:
Summary: The Streams-Scala contains the wrong license header
Key: KAFKA-12593
URL: https://issues.apache.org/jira/browse/KAFKA-12593
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-12557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-12557.
--
Resolution: Fixed
>
[
https://issues.apache.org/jira/browse/KAFKA-12435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-12435.
--
Resolution: Fixed
> Several streams-test-utils classes missing from javadoc
>
[
https://issues.apache.org/jira/browse/KAFKA-12508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-12508.
--
Resolution: Fixed
Disabled KIP-557 entirely.
> Emit-on-change tables may lose updates on
John Roesler created KAFKA-12557:
Summary:
org.apache.kafka.clients.admin.KafkaAdminClientTest#testClientSideTimeoutAfterFailureToReceiveResponse
intermittently hangs indefinitely
Key: KAFKA-12557
URL:
[
https://issues.apache.org/jira/browse/KAFKA-12508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reopened KAFKA-12508:
--
Assignee: John Roesler (was: Bruno Cadonna)
> Emit-on-change tables may lose updates on
[
https://issues.apache.org/jira/browse/KAFKA-12366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-12366.
--
Resolution: Fixed
> Performance regression in stream-table joins on trunk
>
John Roesler created KAFKA-12514:
Summary: NPE in SubscriptionState
Key: KAFKA-12514
URL: https://issues.apache.org/jira/browse/KAFKA-12514
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-10866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10866.
--
Resolution: Fixed
> Add fetched metadata to ConsumerRecords
>
[
https://issues.apache.org/jira/browse/KAFKA-10866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reopened KAFKA-10866:
--
> Add fetched metadata to ConsumerRecords
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reopened KAFKA-10091:
--
> Improve task idling
> ---
>
> Key: KAFKA-10091
>
John Roesler created KAFKA-10867:
Summary: Implement improved semantics using the ConsumerRecords
meta
Key: KAFKA-10867
URL: https://issues.apache.org/jira/browse/KAFKA-10867
Project: Kafka
John Roesler created KAFKA-10866:
Summary: Add fetched metadata to ConsumerRecords
Key: KAFKA-10866
URL: https://issues.apache.org/jira/browse/KAFKA-10866
Project: Kafka
Issue Type: Sub-task
John Roesler created KAFKA-10662:
Summary: Possible hanging test in 2.6 on JDK 11
Key: KAFKA-10662
URL: https://issues.apache.org/jira/browse/KAFKA-10662
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-10638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10638.
--
Resolution: Fixed
> QueryableStateIntegrationTest fails due to stricter store checking
>
John Roesler created KAFKA-10638:
Summary: QueryableStateIntegrationTest fails due to stricter store
checking
Key: KAFKA-10638
URL: https://issues.apache.org/jira/browse/KAFKA-10638
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10284.
--
Resolution: Fixed
> Group membership update due to static member rejoin should be persisted
>
John Roesler created KAFKA-10630:
Summary: State Directory config could be improved
Key: KAFKA-10630
URL: https://issues.apache.org/jira/browse/KAFKA-10630
Project: Kafka
Issue Type: Task
John Roesler created KAFKA-10629:
Summary: TopologyTestDriver should not require a Properties arg
Key: KAFKA-10629
URL: https://issues.apache.org/jira/browse/KAFKA-10629
Project: Kafka
Issue
John Roesler created KAFKA-10628:
Summary: Follow-up: Remove all unnecessary dummy
TopologyTestDriver configs
Key: KAFKA-10628
URL: https://issues.apache.org/jira/browse/KAFKA-10628
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10605.
--
Resolution: Fixed
> KIP-478: deprecate the replaced Processor API members
>
[
https://issues.apache.org/jira/browse/KAFKA-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10455.
--
Resolution: Fixed
> Probing rebalances are not guaranteed to be triggered by non-leader
[
https://issues.apache.org/jira/browse/KAFKA-10215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10215.
--
Resolution: Fixed
Fixed in the new processor API.
> MockProcessorContext doesn't work with
John Roesler created KAFKA-10605:
Summary: KIP-478: deprecate the replaced Processor API members
Key: KAFKA-10605
URL: https://issues.apache.org/jira/browse/KAFKA-10605
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-10562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10562.
--
Resolution: Fixed
> KIP-478: Delegate the store wrappers to the new init method
>
[
https://issues.apache.org/jira/browse/KAFKA-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10437.
--
Resolution: Fixed
> KIP-478: Implement test-utils changes
>
[
https://issues.apache.org/jira/browse/KAFKA-10536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10536.
--
Resolution: Fixed
> KIP-478: Implement KStream changes
> --
>
John Roesler created KAFKA-10603:
Summary: Re-design
Key: KAFKA-10603
URL: https://issues.apache.org/jira/browse/KAFKA-10603
Project: Kafka
Issue Type: New Feature
Reporter:
[
https://issues.apache.org/jira/browse/KAFKA-10598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10598.
--
Resolution: Fixed
> KafkaStreams reports inappropriate error message for IQ
>
John Roesler created KAFKA-10598:
Summary: KafkaStreams reports inappropriate error message for IQ
Key: KAFKA-10598
URL: https://issues.apache.org/jira/browse/KAFKA-10598
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10530.
--
Resolution: Duplicate
Closing now, since this seems like a duplicate report, and visual code
[
https://issues.apache.org/jira/browse/KAFKA-10535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10535.
--
Resolution: Fixed
> KIP-478: Implement StateStoreContext and Record
>
John Roesler created KAFKA-10562:
Summary: Delegate the store wrappers to the new init method
Key: KAFKA-10562
URL: https://issues.apache.org/jira/browse/KAFKA-10562
Project: Kafka
Issue
John Roesler created KAFKA-10546:
Summary: KIP-478: Deprecate old PAPI
Key: KAFKA-10546
URL: https://issues.apache.org/jira/browse/KAFKA-10546
Project: Kafka
Issue Type: Sub-task
John Roesler created KAFKA-10544:
Summary: Convert KTable aggregations to new PAPI
Key: KAFKA-10544
URL: https://issues.apache.org/jira/browse/KAFKA-10544
Project: Kafka
Issue Type: Sub-task
John Roesler created KAFKA-10541:
Summary: Convert KTable filters to new PAPI
Key: KAFKA-10541
URL: https://issues.apache.org/jira/browse/KAFKA-10541
Project: Kafka
Issue Type: Sub-task
John Roesler created KAFKA-10542:
Summary: Convert KTable maps to new PAPI
Key: KAFKA-10542
URL: https://issues.apache.org/jira/browse/KAFKA-10542
Project: Kafka
Issue Type: Sub-task
John Roesler created KAFKA-10543:
Summary: Convert KTable joins to new PAPI
Key: KAFKA-10543
URL: https://issues.apache.org/jira/browse/KAFKA-10543
Project: Kafka
Issue Type: Sub-task
1 - 100 of 274 matches
Mail list logo
