[jira] [Created] (KAFKA-6687) Allow to read a topic multiple times

2018-03-19 Thread Matthias J. Sax (JIRA)
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:

[jira] [Created] (KAFKA-6686) Allow reading topic as KStream and GlobalKTable

2018-03-19 Thread Matthias J. Sax (JIRA)
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

[jira] [Resolved] (KAFKA-6486) TimeWindows causes unordered calls to windowed aggregation functions

2018-03-18 Thread Matthias J. Sax (JIRA)
[ 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 >

[jira] [Created] (KAFKA-6677) Remove EOS producer config max.in.flight.request.per.connection=1

2018-03-17 Thread Matthias J. Sax (JIRA)
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

[jira] [Resolved] (KAFKA-6663) Expression for GlobalKTable is not correct

2018-03-16 Thread Matthias J. Sax (JIRA)
[ 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 >

[jira] [Resolved] (KAFKA-6667) Issues in kafka Streaming when using encryption with custom serializers and deserializers

2018-03-16 Thread Matthias J. Sax (JIRA)
[ 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

[jira] [Resolved] (KAFKA-6106) Postpone normal processing of tasks within a thread until restoration of all tasks have completed

2018-03-15 Thread Matthias J. Sax (JIRA)
[ 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

[jira] [Reopened] (KAFKA-6655) CleanupThread] Failed to lock the state directory due to an unexpected exception

2018-03-15 Thread Matthias J. Sax (JIRA)
[ 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 >

[jira] [Resolved] (KAFKA-6655) CleanupThread] Failed to lock the state directory due to an unexpected exception

2018-03-14 Thread Matthias J. Sax (JIRA)
[ 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

[jira] [Created] (KAFKA-6659) Improve error message if state store is not found

2018-03-14 Thread Matthias J. Sax (JIRA)
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

[jira] [Created] (KAFKA-6657) Add StreamsConfig prefix for different consumers

2018-03-14 Thread Matthias J. Sax (JIRA)
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

[jira] [Created] (KAFKA-6621) Update Streams docs with details for UncaughtExceptionHandler

2018-03-07 Thread Matthias J. Sax (JIRA)
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

[jira] [Created] (KAFKA-6607) Kafka Streams lag not zero when input topic transactional

2018-03-02 Thread Matthias J. Sax (JIRA)
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

[jira] [Resolved] (KAFKA-4186) Transient failure in KStreamAggregationIntegrationTest

2018-02-16 Thread Matthias J. Sax (JIRA)
[ 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

[jira] [Resolved] (KAFKA-6472) WordCount example code error

2018-02-13 Thread Matthias J. Sax (JIRA)
[ 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 > > >

[jira] [Resolved] (KAFKA-6543) Allow KTables to be bootstrapped at start up, like GKTables

2018-02-08 Thread Matthias J. Sax (JIRA)
[ 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 >

[jira] [Created] (KAFKA-6538) Enhance ByteStore exceptions with more context information

2018-02-06 Thread Matthias J. Sax (JIRA)
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

[jira] [Created] (KAFKA-6521) Store record timestamps in KTable stores

2018-02-01 Thread Matthias J. Sax (JIRA)
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:

[jira] [Resolved] (KAFKA-6138) Simplify StreamsBuilder#addGlobalStore

2018-01-31 Thread Matthias J. Sax (JIRA)
[ 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 >

[jira] [Resolved] (KAFKA-6483) Support ExtendedSerializer in Kafka Streams

2018-01-26 Thread Matthias J. Sax (JIRA)
[ 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 >

[jira] [Resolved] (KAFKA-6461) TableTableJoinIntegrationTest is unstable if caching is enabled

2018-01-23 Thread Matthias J. Sax (JIRA)
[ 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 >

[jira] [Created] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver

2018-01-23 Thread Matthias J. Sax (JIRA)
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

[jira] [Created] (KAFKA-6473) Add MockProcessorContext to public test-utils

2018-01-23 Thread Matthias J. Sax (JIRA)
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:

[jira] [Created] (KAFKA-6462) ResetIntegrationTest unstable

2018-01-18 Thread Matthias J. Sax (JIRA)
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

[jira] [Created] (KAFKA-6461) TableTableJoinIntegrationTest is unstable if caching is enabled

2018-01-18 Thread Matthias J. Sax (JIRA)
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

[jira] [Created] (KAFKA-6455) Improve timestamp propagation at DSL level

2018-01-16 Thread Matthias J. Sax (JIRA)
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:

[jira] [Created] (KAFKA-6454) Allow timestamp manipulation in Processor API

2018-01-16 Thread Matthias J. Sax (JIRA)
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:

[jira] [Created] (KAFKA-6453) Reconsider timestamp propagation semantics

2018-01-16 Thread Matthias J. Sax (JIRA)
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:

[jira] [Created] (KAFKA-6451) Simplify KStreamReduce

2018-01-16 Thread Matthias J. Sax (JIRA)
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

[jira] [Created] (KAFKA-6435) Application Reset Tool might delete incorrect internal topics

2018-01-09 Thread Matthias J. Sax (JIRA)
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

[jira] [Created] (KAFKA-6419) Menu order in Streams docs incorrect

2018-01-02 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-6419: -- Summary: Menu order in Streams docs incorrect Key: KAFKA-6419 URL: https://issues.apache.org/jira/browse/KAFKA-6419 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-6411) Update KStream javadoc examples to use new StateStore API

2017-12-29 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6411. Resolution: Duplicate > Update KStream javadoc examples to use new StateStore API >

[jira] [Resolved] (KAFKA-6402) KStream Ktable join integration test fails randomly

2017-12-26 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6402. Resolution: Duplicate > KStream Ktable join integration test fails randomly >

[jira] [Resolved] (KAFKA-6401) InvalidStateStoreException immediately after starting streams

2017-12-26 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6401. Resolution: Not A Problem > InvalidStateStoreException immediately after starting streams >

[jira] [Created] (KAFKA-6400) Consider setting default cache size to zero in Kafka Streams

2017-12-23 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-6400: -- Summary: Consider setting default cache size to zero in Kafka Streams Key: KAFKA-6400 URL: https://issues.apache.org/jira/browse/KAFKA-6400 Project: Kafka

[jira] [Created] (KAFKA-6399) Consider reducing "max.poll.interval.ms" default for Kafka Streams

2017-12-22 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-6399: -- Summary: Consider reducing "max.poll.interval.ms" default for Kafka Streams Key: KAFKA-6399 URL: https://issues.apache.org/jira/browse/KAFKA-6399 Project: Kafka

[jira] [Created] (KAFKA-6398) Stream-Table join fails, if table is not materialized

2017-12-21 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-6398: -- Summary: Stream-Table join fails, if table is not materialized Key: KAFKA-6398 URL: https://issues.apache.org/jira/browse/KAFKA-6398 Project: Kafka

[jira] [Created] (KAFKA-6386) Deprecate KafkaStreams constructor talking StreamsConfig parameter

2017-12-19 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-6386: -- Summary: Deprecate KafkaStreams constructor talking StreamsConfig parameter Key: KAFKA-6386 URL: https://issues.apache.org/jira/browse/KAFKA-6386 Project: Kafka

[jira] [Reopened] (KAFKA-4263) QueryableStateIntegrationTest.concurrentAccess is failing occasionally in jenkins builds

2017-12-18 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-4263: Assignee: Matthias J. Sax (was: Damian Guy) Reopening this. Happened again:

[jira] [Created] (KAFKA-6382) Make ProducerConfig and ConsumerConfig constructors public

2017-12-18 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-6382: -- Summary: Make ProducerConfig and ConsumerConfig constructors public Key: KAFKA-6382 URL: https://issues.apache.org/jira/browse/KAFKA-6382 Project: Kafka

[jira] [Created] (KAFKA-6381) Improve KafkaStreamsTest for localThreadMetadata

2017-12-18 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-6381: -- Summary: Improve KafkaStreamsTest for localThreadMetadata Key: KAFKA-6381 URL: https://issues.apache.org/jira/browse/KAFKA-6381 Project: Kafka Issue

[jira] [Created] (KAFKA-6377) Flaky test BufferPoolTest.testBlockTimeout

2017-12-16 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-6377: -- Summary: Flaky test BufferPoolTest.testBlockTimeout Key: KAFKA-6377 URL: https://issues.apache.org/jira/browse/KAFKA-6377 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-6376) Improve Streams metrics for skipped recrods

2017-12-16 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-6376: -- Summary: Improve Streams metrics for skipped recrods Key: KAFKA-6376 URL: https://issues.apache.org/jira/browse/KAFKA-6376 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-6354) Update KStream JavaDoc with regard to KIP-182

2017-12-12 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-6354: -- Summary: Update KStream JavaDoc with regard to KIP-182 Key: KAFKA-6354 URL: https://issues.apache.org/jira/browse/KAFKA-6354 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-5551) StreamThread should not expose methods for testing

2017-12-11 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5551. Resolution: Fixed > StreamThread should not expose methods for testing >

[jira] [Created] (KAFKA-6318) StreamsResetter should return non-zero return code on error

2017-12-06 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-6318: -- Summary: StreamsResetter should return non-zero return code on error Key: KAFKA-6318 URL: https://issues.apache.org/jira/browse/KAFKA-6318 Project: Kafka

[jira] [Resolved] (KAFKA-6249) Interactive query downtime when node goes down even with standby replicas

2017-11-28 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6249. Resolution: Duplicate > Interactive query downtime when node goes down even with standby

[jira] [Created] (KAFKA-6256) Flaky Unit test: KStreamKTableJoinIntegrationTest.shouldCountClicksPerRegionWithNonZeroByteCache

2017-11-21 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-6256: -- Summary: Flaky Unit test: KStreamKTableJoinIntegrationTest.shouldCountClicksPerRegionWithNonZeroByteCache Key: KAFKA-6256 URL:

[jira] [Reopened] (KAFKA-6237) stream stopped working after exception: Cannot execute transactional method because we are in an error state

2017-11-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-6237: > stream stopped working after exception: Cannot execute transactional method > because we are

[jira] [Resolved] (KAFKA-6237) stream stopped working after exception: Cannot execute transactional method because we are in an error state

2017-11-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6237. Resolution: Duplicate Thanks for reporting this. It is a duplicate and the issue is fixed

[jira] [Resolved] (KAFKA-6230) KafkaConsumer.poll(0) should not block forever if coordinator is not available

2017-11-17 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6230. Resolution: Duplicate > KafkaConsumer.poll(0) should not block forever if coordinator is

[jira] [Resolved] (KAFKA-6213) Stream processor receives messages after close() is invoked

2017-11-16 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6213. Resolution: Not A Problem > Stream processor receives messages after close() is invoked >

[jira] [Resolved] (KAFKA-6162) Stream Store tries to create directory with invalid name on Windows

2017-11-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6162. Resolution: Duplicate > Stream Store tries to create directory with invalid name on Windows

[jira] [Resolved] (KAFKA-6031) Expose standby replicas endpoints in StreamsMetadata

2017-11-04 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6031. Resolution: Duplicate Closing this because title of KAFKA-6144 is more descriptive. >

[jira] [Created] (KAFKA-6138) Simplify StreamsBuilder#addGlobalStore

2017-10-27 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-6138: -- Summary: Simplify StreamsBuilder#addGlobalStore Key: KAFKA-6138 URL: https://issues.apache.org/jira/browse/KAFKA-6138 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-6127) Streams should never block infinitely

2017-10-25 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-6127: -- Summary: Streams should never block infinitely Key: KAFKA-6127 URL: https://issues.apache.org/jira/browse/KAFKA-6127 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-6126) Reduce rebalance time by not checking if created topics are available

2017-10-25 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-6126: -- Summary: Reduce rebalance time by not checking if created topics are available Key: KAFKA-6126 URL: https://issues.apache.org/jira/browse/KAFKA-6126 Project:

[jira] [Created] (KAFKA-6125) Avoid third party exception to flow through streams code base

2017-10-25 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-6125: -- Summary: Avoid third party exception to flow through streams code base Key: KAFKA-6125 URL: https://issues.apache.org/jira/browse/KAFKA-6125 Project: Kafka

[jira] [Created] (KAFKA-6124) Revisit default config for internal client with regard to resilience

2017-10-25 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-6124: -- Summary: Revisit default config for internal client with regard to resilience Key: KAFKA-6124 URL: https://issues.apache.org/jira/browse/KAFKA-6124 Project:

[jira] [Resolved] (KAFKA-6047) Allow retries configuration for InternalTopicManager

2017-10-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6047. Resolution: Duplicate The new {{KafkaAdminClient}} allows to configure number of retries.

[jira] [Resolved] (KAFKA-5313) Improve exception handling on coordinator interactions

2017-10-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5313. Resolution: Duplicate This is contained by all other exception handling tasks of this

[jira] [Resolved] (KAFKA-5302) Improve exception handling on streams client (communication with brokers)

2017-10-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5302. Resolution: Duplicate After we replaced our internal client with new {{KafkaAdminClient}}

[jira] [Resolved] (KAFKA-5217) Improve Streams internal exception handling

2017-10-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5217. Resolution: Duplicate This JIRA should be covered by multiple different once. Thus closing

[jira] [Resolved] (KAFKA-5301) Improve exception handling on consumer path

2017-10-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5301. Resolution: Duplicate This issue is contained by KAFKA-6121 and KAFKA-6122, thus I am

[jira] [Created] (KAFKA-6122) Global Consumer should handle TimeoutException

2017-10-25 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-6122: -- Summary: Global Consumer should handle TimeoutException Key: KAFKA-6122 URL: https://issues.apache.org/jira/browse/KAFKA-6122 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-6121) Restore and global consumer should not use auto.offset.reset

2017-10-25 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-6121: -- Summary: Restore and global consumer should not use auto.offset.reset Key: KAFKA-6121 URL: https://issues.apache.org/jira/browse/KAFKA-6121 Project: Kafka

[jira] [Created] (KAFKA-6120) RecordCollectorImpl should not retry sending

2017-10-25 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-6120: -- Summary: RecordCollectorImpl should not retry sending Key: KAFKA-6120 URL: https://issues.apache.org/jira/browse/KAFKA-6120 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-6115) TaskManager should be type aware

2017-10-24 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-6115: -- Summary: TaskManager should be type aware Key: KAFKA-6115 URL: https://issues.apache.org/jira/browse/KAFKA-6115 Project: Kafka Issue Type: Bug

[jira] [Reopened] (KAFKA-5842) QueryableStateIntegrationTest may fail with JDK 7

2017-10-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-5842: Happened again:

[jira] [Created] (KAFKA-6108) Synchronizing on commits and StandbyTasks can be improved

2017-10-23 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-6108: -- Summary: Synchronizing on commits and StandbyTasks can be improved Key: KAFKA-6108 URL: https://issues.apache.org/jira/browse/KAFKA-6108 Project: Kafka

[jira] [Created] (KAFKA-6058) Add "describe consumer group" to KafkaAdminClient

2017-10-12 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-6058: -- Summary: Add "describe consumer group" to KafkaAdminClient Key: KAFKA-6058 URL: https://issues.apache.org/jira/browse/KAFKA-6058 Project: Kafka Issue

[jira] [Created] (KAFKA-6048) Support negative record timestamps

2017-10-10 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-6048: -- Summary: Support negative record timestamps Key: KAFKA-6048 URL: https://issues.apache.org/jira/browse/KAFKA-6048 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-5569) Document any changes from this task

2017-10-04 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5569. Resolution: Not A Problem There is nothing to document for 1.0 release, besides KIP-161

[jira] [Resolved] (KAFKA-5989) disableLogging() causes an initialization loop

2017-09-28 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5989. Resolution: Duplicate \cc [~damianguy] It this is not a duplicate, please reopen. >

[jira] [Created] (KAFKA-5974) Removed unused parameter in public interface

2017-09-25 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5974: -- Summary: Removed unused parameter in public interface Key: KAFKA-5974 URL: https://issues.apache.org/jira/browse/KAFKA-5974 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-5499) Double check how we handle exceptions when commits fail

2017-09-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5499. Resolution: Duplicate This should be covered by KAFKA-4593 as commit failed exception can

[jira] [Created] (KAFKA-5958) User StoreListener not available for global stores

2017-09-21 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5958: -- Summary: User StoreListener not available for global stores Key: KAFKA-5958 URL: https://issues.apache.org/jira/browse/KAFKA-5958 Project: Kafka Issue

[jira] [Created] (KAFKA-5949) User Callback Exceptions need to be handled properly

2017-09-20 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5949: -- Summary: User Callback Exceptions need to be handled properly Key: KAFKA-5949 URL: https://issues.apache.org/jira/browse/KAFKA-5949 Project: Kafka Issue

[jira] [Created] (KAFKA-5948) EosIntegrationTest fails with TopicAlreadyMarkedForDeletionException

2017-09-20 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5948: -- Summary: EosIntegrationTest fails with TopicAlreadyMarkedForDeletionException Key: KAFKA-5948 URL: https://issues.apache.org/jira/browse/KAFKA-5948 Project:

[jira] [Created] (KAFKA-5937) Improve ProcessorStateManager exception handling

2017-09-19 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5937: -- Summary: Improve ProcessorStateManager exception handling Key: KAFKA-5937 URL: https://issues.apache.org/jira/browse/KAFKA-5937 Project: Kafka Issue

[jira] [Created] (KAFKA-5936) KafkaProducer should not wrap InterruptedException in close() with KafkaException

2017-09-19 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5936: -- Summary: KafkaProducer should not wrap InterruptedException in close() with KafkaException Key: KAFKA-5936 URL: https://issues.apache.org/jira/browse/KAFKA-5936

[jira] [Created] (KAFKA-5893) ResetIntegrationTest fails

2017-09-14 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5893: -- Summary: ResetIntegrationTest fails Key: KAFKA-5893 URL: https://issues.apache.org/jira/browse/KAFKA-5893 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-5876) IQ should throw different exceptions for different errors

2017-09-12 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5876: -- Summary: IQ should throw different exceptions for different errors Key: KAFKA-5876 URL: https://issues.apache.org/jira/browse/KAFKA-5876 Project: Kafka

[jira] [Created] (KAFKA-5862) Remove ZK dependency from Streams reset tool

2017-09-08 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5862: -- Summary: Remove ZK dependency from Streams reset tool Key: KAFKA-5862 URL: https://issues.apache.org/jira/browse/KAFKA-5862 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-5848) KafkaConsumer should validate topics/TopicPartitions on subscribe/assign

2017-09-06 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5848: -- Summary: KafkaConsumer should validate topics/TopicPartitions on subscribe/assign Key: KAFKA-5848 URL: https://issues.apache.org/jira/browse/KAFKA-5848 Project:

[jira] [Resolved] (KAFKA-3856) Cleanup Kafka Streams builder API

2017-09-05 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-3856. Resolution: Fixed > Cleanup Kafka Streams builder API > - >

[jira] [Created] (KAFKA-5823) Update Docs

2017-09-01 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5823: -- Summary: Update Docs Key: KAFKA-5823 URL: https://issues.apache.org/jira/browse/KAFKA-5823 Project: Kafka Issue Type: Sub-task Reporter:

[jira] [Created] (KAFKA-5818) Kafka Stream state transitions not correct

2017-08-31 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5818: -- Summary: Kafka Stream state transitions not correct Key: KAFKA-5818 URL: https://issues.apache.org/jira/browse/KAFKA-5818 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-5786) Yet another exception is causing that streamming app is zombie

2017-08-30 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5786. Resolution: Duplicate > Yet another exception is causing that streamming app is zombie >

[jira] [Resolved] (KAFKA-5779) Single message may exploit application based on KStream

2017-08-29 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5779. Resolution: Not A Problem > Single message may exploit application based on KStream >

[jira] [Resolved] (KAFKA-5070) org.apache.kafka.streams.errors.LockException: task [0_18] Failed to lock the state directory: /opt/rocksdb/pulse10/0_18

2017-08-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5070. Resolution: Duplicate > org.apache.kafka.streams.errors.LockException: task [0_18] Failed

[jira] [Created] (KAFKA-5671) Add StreamsBuilder and deprecate KStreamBuilder

2017-07-27 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5671: -- Summary: Add StreamsBuilder and deprecate KStreamBuilder Key: KAFKA-5671 URL: https://issues.apache.org/jira/browse/KAFKA-5671 Project: Kafka Issue

[jira] [Created] (KAFKA-5670) Add Topology and deprecate TopologyBuilder

2017-07-27 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5670: -- Summary: Add Topology and deprecate TopologyBuilder Key: KAFKA-5670 URL: https://issues.apache.org/jira/browse/KAFKA-5670 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-5660) Don't throw TopologyBuilderException during runtime

2017-07-26 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5660: -- Summary: Don't throw TopologyBuilderException during runtime Key: KAFKA-5660 URL: https://issues.apache.org/jira/browse/KAFKA-5660 Project: Kafka Issue

[jira] [Created] (KAFKA-5603) Streams should not abort transaction when closing zombie task

2017-07-17 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5603: -- Summary: Streams should not abort transaction when closing zombie task Key: KAFKA-5603 URL: https://issues.apache.org/jira/browse/KAFKA-5603 Project: Kafka

[jira] [Created] (KAFKA-5577) WindowedStreamPartitioner does not provide topic name to serializer

2017-07-10 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5577: -- Summary: WindowedStreamPartitioner does not provide topic name to serializer Key: KAFKA-5577 URL: https://issues.apache.org/jira/browse/KAFKA-5577 Project: Kafka

[jira] [Resolved] (KAFKA-5577) WindowedStreamPartitioner does not provide topic name to serializer

2017-07-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5577. Resolution: Fixed Fixed via https://github.com/apache/kafka/pull/2776 >

[jira] [Resolved] (KAFKA-4726) ValueMapper should have (read) access to key

2017-07-06 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4726. Resolution: Duplicate See

[jira] [Resolved] (KAFKA-3745) Consider adding join key to ValueJoiner interface

2017-07-06 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-3745. Resolution: Duplicate See

[jira] [Created] (KAFKA-5566) Instable test QueryableStateIntegrationTest.shouldAllowToQueryAfterThreadDied

2017-07-06 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5566: -- Summary: Instable test QueryableStateIntegrationTest.shouldAllowToQueryAfterThreadDied Key: KAFKA-5566 URL: https://issues.apache.org/jira/browse/KAFKA-5566

<    5   6   7   8   9   10   11   12   13   14   >