Matthias J. Sax created KAFKA-7969:
--
Summary: Flaky Test
DescribeConsumerGroupTest#testDescribeOffsetsOfExistingGroupWithNoMembers
Key: KAFKA-7969
URL: https://issues.apache.org/jira/browse/KAFKA-7969
[
https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7930.
Resolution: Fixed
Fix Version/s: 2.3.0
> StreamsResetter makes "changelog" topic
Matthias J. Sax created KAFKA-7966:
--
Summary: Flaky Test
DynamicBrokerReconfigurationTest#testLogCleanerConfig
Key: KAFKA-7966
URL: https://issues.apache.org/jira/browse/KAFKA-7966
Project: Kafka
Matthias J. Sax created KAFKA-7965:
--
Summary: Flaky Test
ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup
Key: KAFKA-7965
URL:
Matthias J. Sax created KAFKA-7964:
--
Summary: Flaky Test
ConsumerBounceTest#testConsumerReceivesFatalExceptionWhenGroupPassesMaxSize
Key: KAFKA-7964
URL: https://issues.apache.org/jira/browse/KAFKA-7964
Matthias J. Sax created KAFKA-7957:
--
Summary: Flaky Test DynamicBrokerReconfigurationTest
#testMetricsReporterUpdate
Key: KAFKA-7957
URL: https://issues.apache.org/jira/browse/KAFKA-7957
Project:
Matthias J. Sax created KAFKA-7952:
--
Summary: Consider to switch to in-memory stores in test whenever
possible
Key: KAFKA-7952
URL: https://issues.apache.org/jira/browse/KAFKA-7952
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reopened KAFKA-7540:
> Transient failure: kafka.api.ConsumerBounceTest.testClose
>
Matthias J. Sax created KAFKA-7947:
--
Summary: Flaky Test EpochDrivenReplicationProtocolAcceptanceTest
#shouldFollowLeaderEpochBasicWorkflow
Key: KAFKA-7947
URL: https://issues.apache.org/jira/browse/KAFKA-7947
Matthias J. Sax created KAFKA-7946:
--
Summary: Flaky Test
DeleteConsumerGroupsTest#testDeleteNonEmptyGroup
Key: KAFKA-7946
URL: https://issues.apache.org/jira/browse/KAFKA-7946
Project: Kafka
Matthias J. Sax created KAFKA-7940:
--
Summary: Flaky Test CustomQuotaCallbackTest#testCustomQuotaCallback
Key: KAFKA-7940
URL: https://issues.apache.org/jira/browse/KAFKA-7940
Project: Kafka
Matthias J. Sax created KAFKA-7939:
--
Summary: Flaky Test
KafkaAdminClientTest#testCreateTopicsRetryBackoff
Key: KAFKA-7939
URL: https://issues.apache.org/jira/browse/KAFKA-7939
Project: Kafka
Matthias J. Sax created KAFKA-7938:
--
Summary: Flaky Test
DeleteConsumerGroupsTest#testDeleteCmdWithShortInitialization
Key: KAFKA-7938
URL: https://issues.apache.org/jira/browse/KAFKA-7938
Project:
Matthias J. Sax created KAFKA-7937:
--
Summary: Flaky Test
ResetConsumerGroupOffsetTest.testResetOffsetsNotExistingGroup
Key: KAFKA-7937
URL: https://issues.apache.org/jira/browse/KAFKA-7937
Project:
Matthias J. Sax created KAFKA-7936:
--
Summary: Flaky
ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup
Key: KAFKA-7936
URL: https://issues.apache.org/jira/browse/KAFKA-7936
[
https://issues.apache.org/jira/browse/KAFKA-7758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7758.
Resolution: Fixed
> When Naming a Repartition Topic with Aggregations Reuse Repartition
Matthias J. Sax created KAFKA-7934:
--
Summary: Optimize restore for windowed and session stores
Key: KAFKA-7934
URL: https://issues.apache.org/jira/browse/KAFKA-7934
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7882.
Resolution: Duplicate
> StateStores are frequently closed during the 'transform' method
>
Matthias J. Sax created KAFKA-7921:
--
Summary: Instable KafkaStreamsTest
Key: KAFKA-7921
URL: https://issues.apache.org/jira/browse/KAFKA-7921
Project: Kafka
Issue Type: Bug
Matthias J. Sax created KAFKA-7911:
--
Summary: Add Timezone Support for Windowed Aggregations
Key: KAFKA-7911
URL: https://issues.apache.org/jira/browse/KAFKA-7911
Project: Kafka
Issue Type:
Matthias J. Sax created KAFKA-7875:
--
Summary: Add KStream#flatTransformValues
Key: KAFKA-7875
URL: https://issues.apache.org/jira/browse/KAFKA-7875
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-4217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-4217.
Resolution: Fixed
Fix Version/s: 2.2.0
> KStream.transform equivalent of flatMap
>
[
https://issues.apache.org/jira/browse/KAFKA-4726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-4726.
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed via
Matthias J. Sax created KAFKA-7843:
--
Summary: Initializer should have (read) access to key
Key: KAFKA-7843
URL: https://issues.apache.org/jira/browse/KAFKA-7843
Project: Kafka
Issue Type:
Matthias J. Sax created KAFKA-7842:
--
Summary: Reducer should have (read) access to key
Key: KAFKA-7842
URL: https://issues.apache.org/jira/browse/KAFKA-7842
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-4726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reopened KAFKA-4726:
This is actually no duplicate of KAFKA-4218, because 4218 only covers
ValueTransformer, but
[
https://issues.apache.org/jira/browse/KAFKA-3745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reopened KAFKA-3745:
This is actually no duplicate of KAFKA-4218, because 4218 only covers
ValueTransformer, but
[
https://issues.apache.org/jira/browse/KAFKA-4721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-4721.
Resolution: Implemented
> KafkaStreams (and possibly others) should inherit Closeable
>
[
https://issues.apache.org/jira/browse/KAFKA-7655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7655.
Resolution: Fixed
Fix Version/s: 2.0.2
2.1.1
Matthias J. Sax created KAFKA-7699:
--
Summary: Improve wall-clock time punctuations
Key: KAFKA-7699
URL: https://issues.apache.org/jira/browse/KAFKA-7699
Project: Kafka
Issue Type: New
[
https://issues.apache.org/jira/browse/KAFKA-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7367.
Resolution: Fixed
Fix Version/s: 2.2.0
> Streams should not create state store
[
https://issues.apache.org/jira/browse/KAFKA-7668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7668.
Resolution: Duplicate
Thanks for confirming and thanks for reporting in the first place!
[
https://issues.apache.org/jira/browse/KAFKA-7402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7402.
Resolution: Fixed
Fix Version/s: 2.2.0
> Kafka Streams should implement
[
https://issues.apache.org/jira/browse/KAFKA-6641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6641.
Resolution: Duplicate
> Consider auto repartitioning for Stream.transform() API
>
Matthias J. Sax created KAFKA-7606:
--
Summary: Remove deprecated --zookeeper option from StreamsResetter
Key: KAFKA-7606
URL: https://issues.apache.org/jira/browse/KAFKA-7606
Project: Kafka
Matthias J. Sax created KAFKA-7602:
--
Summary: Improve usage of @see tag in Streams JavaDocs
Key: KAFKA-7602
URL: https://issues.apache.org/jira/browse/KAFKA-7602
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-7595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7595.
Resolution: Not A Bug
> Kafka Streams: KTrable to KTable join introduces duplicates in
Matthias J. Sax created KAFKA-7584:
--
Summary: StreamsConfig throws ClassCastException if
max.in.flight.request.per.connect is specified as String
Key: KAFKA-7584
URL:
[
https://issues.apache.org/jira/browse/KAFKA-5824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-5824.
Resolution: Won't Fix
Resolving this, because `ProcessorTopologyTestDriver` is an internal
[
https://issues.apache.org/jira/browse/KAFKA-7521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7521.
Resolution: Fixed
Assignee: Joan Goyeau
Fix Version/s: 2.1.0
>
Matthias J. Sax created KAFKA-7499:
--
Summary: Extend ProductionExceptionHandler to cover serialization
exceptions
Key: KAFKA-7499
URL: https://issues.apache.org/jira/browse/KAFKA-7499
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-7198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7198.
Resolution: Fixed
> Enhance KafkaStreams start method javadoc
>
Matthias J. Sax created KAFKA-7492:
--
Summary: Explain `null` handling for reduce and aggregate
Key: KAFKA-7492
URL: https://issues.apache.org/jira/browse/KAFKA-7492
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-7477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reopened KAFKA-7477:
> Improve Streams close timeout semantics
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-7477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7477.
Resolution: Fixed
> Improve Streams close timeout semantics
>
Matthias J. Sax created KAFKA-7480:
--
Summary: GlobalThread should honor custom auto.offset.reset policy
Key: KAFKA-7480
URL: https://issues.apache.org/jira/browse/KAFKA-7480
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7456.
Resolution: Fixed
> Serde Inheritance in Streams DSL
>
>
[
https://issues.apache.org/jira/browse/KAFKA-5836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-5836.
Resolution: Duplicate
> Kafka Streams - API for specifying internal stream name on join
>
[
https://issues.apache.org/jira/browse/KAFKA-6273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6273.
Resolution: Duplicate
> Allow names for windowing joins
> ---
Matthias J. Sax created KAFKA-7420:
--
Summary: Global stores should be guarded as read-only for regular
tasks
Key: KAFKA-7420
URL: https://issues.apache.org/jira/browse/KAFKA-7420
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-6699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6699.
Resolution: Not A Bug
This ticket does not seem to be a bug but a configuration question.
[
https://issues.apache.org/jira/browse/KAFKA-6457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6457.
Resolution: Duplicate
> Error: NOT_LEADER_FOR_PARTITION leads to NPE
>
[
https://issues.apache.org/jira/browse/KAFKA-6457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reopened KAFKA-6457:
> Error: NOT_LEADER_FOR_PARTITION leads to NPE
>
[
https://issues.apache.org/jira/browse/KAFKA-7365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7365.
Resolution: Invalid
> max.poll.records setting in Kafka Consumer is not working
>
Matthias J. Sax created KAFKA-7380:
--
Summary: Global thread restore blocks KafkaStreams#start()
Key: KAFKA-7380
URL: https://issues.apache.org/jira/browse/KAFKA-7380
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-7363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7363.
Resolution: Invalid
Please ask question on the mailing list. We use Jira to track bugs
Matthias J. Sax created KAFKA-7317:
--
Summary: Use collections subscription for main consumer to reduce
metadata
Key: KAFKA-7317
URL: https://issues.apache.org/jira/browse/KAFKA-7317
Project: Kafka
Matthias J. Sax created KAFKA-7302:
--
Summary: Remove Java7 examples from Streams Docs
Key: KAFKA-7302
URL: https://issues.apache.org/jira/browse/KAFKA-7302
Project: Kafka
Issue Type:
Matthias J. Sax created KAFKA-7294:
--
Summary: Optimize repartitioning for merge()
Key: KAFKA-7294
URL: https://issues.apache.org/jira/browse/KAFKA-7294
Project: Kafka
Issue Type:
Matthias J. Sax created KAFKA-7293:
--
Summary: Merge followed by groupByKey/join might violate
co-partioning
Key: KAFKA-7293
URL: https://issues.apache.org/jira/browse/KAFKA-7293
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-7284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7284.
Resolution: Fixed
> Producer getting fenced may cause Streams to shut down
>
[
https://issues.apache.org/jira/browse/KAFKA-6966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6966.
Resolution: Fixed
> Extend `TopologyDescription.Sink` to return `TopicNameExtractor`
>
Matthias J. Sax created KAFKA-7245:
--
Summary: Deprecate WindowStore#put(key, value)
Key: KAFKA-7245
URL: https://issues.apache.org/jira/browse/KAFKA-7245
Project: Kafka
Issue Type:
Matthias J. Sax created KAFKA-7131:
--
Summary: Update release script to generate announcement email text
Key: KAFKA-7131
URL: https://issues.apache.org/jira/browse/KAFKA-7131
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6583.
Resolution: Duplicate
> Metadata should include number of state stores for task
>
[
https://issues.apache.org/jira/browse/KAFKA-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reopened KAFKA-6583:
> Metadata should include number of state stores for task
>
[
https://issues.apache.org/jira/browse/KAFKA-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6583.
Resolution: Fixed
> Metadata should include number of state stores for task
>
Matthias J. Sax created KAFKA-7101:
--
Summary: Session Window store should set topic policy
`compact,cleanup`
Key: KAFKA-7101
URL: https://issues.apache.org/jira/browse/KAFKA-7101
Project: Kafka
Matthias J. Sax created KAFKA-7089:
--
Summary: Extend `kafka-consumer-groups.sh` to show "beginning
offsets"
Key: KAFKA-7089
URL: https://issues.apache.org/jira/browse/KAFKA-7089
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-7055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7055.
Resolution: Fixed
Fix Version/s: 2.0.0
> Kafka Streams Processor API allows you to
[
https://issues.apache.org/jira/browse/KAFKA-6782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6782.
Resolution: Fixed
Fix Version/s: 1.1.1
1.0.2
[
https://issues.apache.org/jira/browse/KAFKA-6976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6976.
Resolution: Not A Bug
Closing this because it's not a bug, but a configuration issue.
>
[
https://issues.apache.org/jira/browse/KAFKA-6906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6906.
Resolution: Fixed
Fix Version/s: 1.1.1
2.0.0
> Kafka Streams
Matthias J. Sax created KAFKA-7041:
--
Summary: Using RocksDB bulk loading for StandbyTasks
Key: KAFKA-7041
URL: https://issues.apache.org/jira/browse/KAFKA-7041
Project: Kafka
Issue Type:
Matthias J. Sax created KAFKA-7021:
--
Summary: Source KTable checkpoint is not correct
Key: KAFKA-7021
URL: https://issues.apache.org/jira/browse/KAFKA-7021
Project: Kafka
Issue Type: Bug
Matthias J. Sax created KAFKA-7015:
--
Summary: Enhance RecordCollectorImpl exceptions with more context
information
Key: KAFKA-7015
URL: https://issues.apache.org/jira/browse/KAFKA-7015
[
https://issues.apache.org/jira/browse/KAFKA-6538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6538.
Resolution: Fixed
Fix Version/s: 2.0.0
> Enhance ByteStore exceptions with more
Matthias J. Sax created KAFKA-6999:
--
Summary: Document read-write lock usage of caching enabled stores
Key: KAFKA-6999
URL: https://issues.apache.org/jira/browse/KAFKA-6999
Project: Kafka
Matthias J. Sax created KAFKA-6998:
--
Summary: Remove caching wrapper stores if cache-size is configured
to zero bytes
Key: KAFKA-6998
URL: https://issues.apache.org/jira/browse/KAFKA-6998
Project:
[
https://issues.apache.org/jira/browse/KAFKA-6730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6730.
Resolution: Fixed
> Simplify state store recovery
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-6054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6054.
Resolution: Fixed
> ERROR "SubscriptionInfo - unable to decode subscription data:
[
https://issues.apache.org/jira/browse/KAFKA-4936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-4936.
Resolution: Fixed
> Allow dynamic routing of output records
>
Matthias J. Sax created KAFKA-6966:
--
Summary: Extend `TopologyDescription.Sink` to return
`TopicNameExtractor`
Key: KAFKA-6966
URL: https://issues.apache.org/jira/browse/KAFKA-6966
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-6920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6920.
Resolution: Duplicate
> Enhance ConsumerRecordFactory and OutputVerifier for Header support
Matthias J. Sax created KAFKA-6920:
--
Summary: Enhance ConsumerRecordFactory and OutputVerifier for
Header support
Key: KAFKA-6920
URL: https://issues.apache.org/jira/browse/KAFKA-6920
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reopened KAFKA-5697:
Assignee: (was: John Roesler)
> StreamThread.shutdown() need to interrupt the stream
[
https://issues.apache.org/jira/browse/KAFKA-6838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6838.
Resolution: Duplicate
Thanks for confirmation [~feli6]! Closing as duplicate.
>
Matthias J. Sax created KAFKA-6906:
--
Summary: Kafka Streams does not commit transactions if data is
produced via wall-clock punctuation
Key: KAFKA-6906
URL: https://issues.apache.org/jira/browse/KAFKA-6906
Matthias J. Sax created KAFKA-6889:
--
Summary: Fix Streams system test to only specify used log files
Key: KAFKA-6889
URL: https://issues.apache.org/jira/browse/KAFKA-6889
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reopened KAFKA-4327:
I discussed with [~guozhang] about this because I think we should actually move
the tool to
[
https://issues.apache.org/jira/browse/KAFKA-6865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6865.
Resolution: Incomplete
> Devops Insights
> ---
>
> Key:
[
https://issues.apache.org/jira/browse/KAFKA-6866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6866.
Resolution: Incomplete
> Increase memory
> ---
>
> Key:
[
https://issues.apache.org/jira/browse/KAFKA-6677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6677.
Resolution: Fixed
Fix Version/s: 1.2.0
> Remove EOS producer config
[
https://issues.apache.org/jira/browse/KAFKA-5253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-5253.
Resolution: Fixed
Fix Version/s: 1.2.0
> TopologyTestDriver must handle streams
[
https://issues.apache.org/jira/browse/KAFKA-6642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6642.
Resolution: Duplicate
I am closing this a duplicate of KAFKA-6718 -- let us know if you
Matthias J. Sax created KAFKA-6730:
--
Summary: Simplify state store recovery
Key: KAFKA-6730
URL: https://issues.apache.org/jira/browse/KAFKA-6730
Project: Kafka
Issue Type: Improvement
Matthias J. Sax created KAFKA-6729:
--
Summary: KTable should use user source topics if possible and not
create changelog topic
Key: KAFKA-6729
URL: https://issues.apache.org/jira/browse/KAFKA-6729
[
https://issues.apache.org/jira/browse/KAFKA-6712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6712.
Resolution: Duplicate
> Throw a specific exception with wrong topic name for interactive
Matthias J. Sax created KAFKA-6687:
--
Summary: Allow to read a topic multiple times
Key: KAFKA-6687
URL: https://issues.apache.org/jira/browse/KAFKA-6687
Project: Kafka
Issue Type:
Matthias J. Sax created KAFKA-6686:
--
Summary: Allow reading topic as KStream and GlobalKTable
Key: KAFKA-6686
URL: https://issues.apache.org/jira/browse/KAFKA-6686
Project: Kafka
Issue
801 - 900 of 1642 matches
Mail list logo
