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 Type
[
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-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-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
> [kafka-strea
[
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
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-7
[
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 down
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: I
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
I
[
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
> -
[
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 AutoCloseabl
[
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! Cl
[
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 direc
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 Featur
[
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
2.
[
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-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 no
[
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 no
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: Improv
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: Im
[
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 https://github.com/apache/kafka/pul
[
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: KAFKA-68
[
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: KAFKA-68
[
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 str
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
Issu
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
[
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.
> Transaction
[
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 t
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-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-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-4936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-4936.
Resolution: Fixed
> Allow dynamic routing of output records
> -
[
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: version=2
[
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
> -
>
>
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: Ka
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
Is
[
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 cont
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
Project:
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-7041:
--
Summary: Using RocksDB bulk loading for StandbyTasks
Key: KAFKA-7041
URL: https://issues.apache.org/jira/browse/KAFKA-7041
Project: Kafka
Issue Type: Imp
[
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 does
[
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.
> Ka
[
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
0.
[
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 a
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
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
[
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
> -
[
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: Duplicate
> Metadata should include number of state stores for task
> -
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
I
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: Improveme
Matthias J. Sax created KAFKA-6435:
--
Summary: Application Reset Tool might delete incorrect internal
topics
Key: KAFKA-6435
URL: https://issues.apache.org/jira/browse/KAFKA-6435
Project: Kafka
Matthias J. Sax created KAFKA-6451:
--
Summary: Simplify KStreamReduce
Key: KAFKA-6451
URL: https://issues.apache.org/jira/browse/KAFKA-6451
Project: Kafka
Issue Type: Bug
Components
Matthias J. Sax created KAFKA-6453:
--
Summary: Reconsider timestamp propagation semantics
Key: KAFKA-6453
URL: https://issues.apache.org/jira/browse/KAFKA-6453
Project: Kafka
Issue Type: Impr
Matthias J. Sax created KAFKA-6454:
--
Summary: Allow timestamp manipulation in Processor API
Key: KAFKA-6454
URL: https://issues.apache.org/jira/browse/KAFKA-6454
Project: Kafka
Issue Type: I
Matthias J. Sax created KAFKA-6455:
--
Summary: Improve timestamp propagation at DSL level
Key: KAFKA-6455
URL: https://issues.apache.org/jira/browse/KAFKA-6455
Project: Kafka
Issue Type: Impr
Matthias J. Sax created KAFKA-6461:
--
Summary: TableTableJoinIntegrationTest is unstable if caching is
enabled
Key: KAFKA-6461
URL: https://issues.apache.org/jira/browse/KAFKA-6461
Project: Kafka
Matthias J. Sax created KAFKA-6462:
--
Summary: ResetIntegrationTest unstable
Key: KAFKA-6462
URL: https://issues.apache.org/jira/browse/KAFKA-6462
Project: Kafka
Issue Type: Improvement
Matthias J. Sax created KAFKA-6473:
--
Summary: Add MockProcessorContext to public test-utils
Key: KAFKA-6473
URL: https://issues.apache.org/jira/browse/KAFKA-6473
Project: Kafka
Issue Type: I
Matthias J. Sax created KAFKA-6474:
--
Summary: Rewrite test to use new public TopologyTestDriver
Key: KAFKA-6474
URL: https://issues.apache.org/jira/browse/KAFKA-6474
Project: Kafka
Issue Typ
[
https://issues.apache.org/jira/browse/KAFKA-6461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6461.
Resolution: Fixed
> TableTableJoinIntegrationTest is unstable if caching is enabled
> --
[
https://issues.apache.org/jira/browse/KAFKA-6483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6483.
Resolution: Duplicate
> Support ExtendedSerializer in Kafka Streams
> --
[
https://issues.apache.org/jira/browse/KAFKA-6138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6138.
Resolution: Fixed
> Simplify StreamsBuilder#addGlobalStore
> ---
Matthias J. Sax created KAFKA-6521:
--
Summary: Store record timestamps in KTable stores
Key: KAFKA-6521
URL: https://issues.apache.org/jira/browse/KAFKA-6521
Project: Kafka
Issue Type: Improv
Matthias J. Sax created KAFKA-6538:
--
Summary: Enhance ByteStore exceptions with more context information
Key: KAFKA-6538
URL: https://issues.apache.org/jira/browse/KAFKA-6538
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-6543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6543.
Resolution: Duplicate
> Allow KTables to be bootstrapped at start up, like GKTables
> --
[
https://issues.apache.org/jira/browse/KAFKA-6472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6472.
Resolution: Fixed
> WordCount example code error
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-4186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-4186.
Resolution: Fixed
We did some test rework and this did not fail for a while. Closing this ti
Matthias J. Sax created KAFKA-6607:
--
Summary: Kafka Streams lag not zero when input topic transactional
Key: KAFKA-6607
URL: https://issues.apache.org/jira/browse/KAFKA-6607
Project: Kafka
I
Matthias J. Sax created KAFKA-6621:
--
Summary: Update Streams docs with details for
UncaughtExceptionHandler
Key: KAFKA-6621
URL: https://issues.apache.org/jira/browse/KAFKA-6621
Project: Kafka
Matthias J. Sax created KAFKA-6657:
--
Summary: Add StreamsConfig prefix for different consumers
Key: KAFKA-6657
URL: https://issues.apache.org/jira/browse/KAFKA-6657
Project: Kafka
Issue Type
Matthias J. Sax created KAFKA-6659:
--
Summary: Improve error message if state store is not found
Key: KAFKA-6659
URL: https://issues.apache.org/jira/browse/KAFKA-6659
Project: Kafka
Issue Typ
[
https://issues.apache.org/jira/browse/KAFKA-6655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6655.
Resolution: Duplicate
> CleanupThread] Failed to lock the state directory due to an unexpect
[
https://issues.apache.org/jira/browse/KAFKA-6655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reopened KAFKA-6655:
> CleanupThread] Failed to lock the state directory due to an unexpected
> exception
>
[
https://issues.apache.org/jira/browse/KAFKA-6106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6106.
Resolution: Fixed
> Postpone normal processing of tasks within a thread until restoration of
[
https://issues.apache.org/jira/browse/KAFKA-6667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6667.
Resolution: Invalid
> Issues in kafka Streaming when using encryption with custom serializer
[
https://issues.apache.org/jira/browse/KAFKA-6663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6663.
Resolution: Fixed
> Expression for GlobalKTable is not correct
> ---
Matthias J. Sax created KAFKA-6677:
--
Summary: Remove EOS producer config
max.in.flight.request.per.connection=1
Key: KAFKA-6677
URL: https://issues.apache.org/jira/browse/KAFKA-6677
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-6486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6486.
Resolution: Fixed
> TimeWindows causes unordered calls to windowed aggregation functions
> -
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 Type:
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: Improvemen
[
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 que
[
https://issues.apache.org/jira/browse/KAFKA-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6473.
Resolution: Fixed
Fix Version/s: 1.2.0
> Add MockProcessorContext to public test-util
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
Pro
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
[
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 disa
[
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 creat
[
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 max.in.flight.req
[
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`
>
[
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
> --
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
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: Improvement
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: Improve
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
[
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 only
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 Typ
[
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
> -
[
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-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-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. I
1 - 100 of 1768 matches
Mail list logo
