[jira] [Created] (KAFKA-7072) Kafka Streams may drop rocksb window segments before they expire

2018-06-18 Thread John Roesler (JIRA)
John Roesler created KAFKA-7072: --- Summary: Kafka Streams may drop rocksb window segments before they expire Key: KAFKA-7072 URL: https://issues.apache.org/jira/browse/KAFKA-7072 Project: Kafka

[jira] [Created] (KAFKA-6978) Make Streams Window retention time strict

2018-05-31 Thread John Roesler (JIRA)
John Roesler created KAFKA-6978: --- Summary: Make Streams Window retention time strict Key: KAFKA-6978 URL: https://issues.apache.org/jira/browse/KAFKA-6978 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-7000) KafkaConsumer.position should wait for assignment metadata

2018-06-05 Thread John Roesler (JIRA)
John Roesler created KAFKA-7000: --- Summary: KafkaConsumer.position should wait for assignment metadata Key: KAFKA-7000 URL: https://issues.apache.org/jira/browse/KAFKA-7000 Project: Kafka Issue

[jira] [Reopened] (KAFKA-5697) StreamThread.shutdown() need to interrupt the stream threads to break the loop

2018-05-29 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reopened KAFKA-5697: - Assignee: John Roesler > StreamThread.shutdown() need to interrupt the stream threads to break

[jira] [Resolved] (KAFKA-6783) consumer poll(timeout) blocked infinitely when no available bootstrap server

2018-05-29 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-6783. - Resolution: Duplicate Hey [~koqizhao], We've merged

[jira] [Resolved] (KAFKA-6978) Make Streams Window retention time strict

2018-06-25 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-6978. - Resolution: Fixed Fix Version/s: 2.1.0 This feature was merged in 

[jira] [Created] (KAFKA-7080) WindowStoreBuilder incorrectly initializes CachingWindowStore

2018-06-20 Thread John Roesler (JIRA)
John Roesler created KAFKA-7080: --- Summary: WindowStoreBuilder incorrectly initializes CachingWindowStore Key: KAFKA-7080 URL: https://issues.apache.org/jira/browse/KAFKA-7080 Project: Kafka

[jira] [Created] (KAFKA-7106) Remove segment/segmentInterval from Window definition

2018-06-26 Thread John Roesler (JIRA)
John Roesler created KAFKA-7106: --- Summary: Remove segment/segmentInterval from Window definition Key: KAFKA-7106 URL: https://issues.apache.org/jira/browse/KAFKA-7106 Project: Kafka Issue

[jira] [Created] (KAFKA-7107) Ability to configure state store for JoinWindows in KStream-KStream join

2018-06-26 Thread John Roesler (JIRA)
John Roesler created KAFKA-7107: --- Summary: Ability to configure state store for JoinWindows in KStream-KStream join Key: KAFKA-7107 URL: https://issues.apache.org/jira/browse/KAFKA-7107 Project: Kafka

[jira] [Created] (KAFKA-7223) KIP-328: Add in-memory Suppression

2018-07-31 Thread John Roesler (JIRA)
John Roesler created KAFKA-7223: --- Summary: KIP-328: Add in-memory Suppression Key: KAFKA-7223 URL: https://issues.apache.org/jira/browse/KAFKA-7223 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-7224) KIP-328: Add spill-to-disk for Suppression

2018-07-31 Thread John Roesler (JIRA)
John Roesler created KAFKA-7224: --- Summary: KIP-328: Add spill-to-disk for Suppression Key: KAFKA-7224 URL: https://issues.apache.org/jira/browse/KAFKA-7224 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-7222) KIP-328: Add Window Grace Period (and deprecate Window Retention)

2018-07-31 Thread John Roesler (JIRA)
John Roesler created KAFKA-7222: --- Summary: KIP-328: Add Window Grace Period (and deprecate Window Retention) Key: KAFKA-7222 URL: https://issues.apache.org/jira/browse/KAFKA-7222 Project: Kafka

[jira] [Created] (KAFKA-7277) Migrate Streams API to Duration instead of longMs times

2018-08-10 Thread John Roesler (JIRA)
John Roesler created KAFKA-7277: --- Summary: Migrate Streams API to Duration instead of longMs times Key: KAFKA-7277 URL: https://issues.apache.org/jira/browse/KAFKA-7277 Project: Kafka Issue

[jira] [Created] (KAFKA-7275) Prototype lock-free metrics

2018-08-10 Thread John Roesler (JIRA)
John Roesler created KAFKA-7275: --- Summary: Prototype lock-free metrics Key: KAFKA-7275 URL: https://issues.apache.org/jira/browse/KAFKA-7275 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-7267) KafkaStreams Scala DSL process method should accept a ProcessorSupplier

2018-08-09 Thread John Roesler (JIRA)
John Roesler created KAFKA-7267: --- Summary: KafkaStreams Scala DSL process method should accept a ProcessorSupplier Key: KAFKA-7267 URL: https://issues.apache.org/jira/browse/KAFKA-7267 Project: Kafka

[jira] [Created] (KAFKA-7284) Producer getting fenced may cause Streams to shut down

2018-08-13 Thread John Roesler (JIRA)
John Roesler created KAFKA-7284: --- Summary: Producer getting fenced may cause Streams to shut down Key: KAFKA-7284 URL: https://issues.apache.org/jira/browse/KAFKA-7284 Project: Kafka Issue

[jira] [Resolved] (KAFKA-7222) KIP-328: Add Window Grace Period (and deprecate Window Retention)

2018-08-14 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-7222. - Resolution: Fixed Fix Version/s: 2.1.0 [https://github.com/apache/kafka/pull/5369] is

[jira] [Created] (KAFKA-7269) KStream.merge is not documented

2018-08-09 Thread John Roesler (JIRA)
John Roesler created KAFKA-7269: --- Summary: KStream.merge is not documented Key: KAFKA-7269 URL: https://issues.apache.org/jira/browse/KAFKA-7269 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-7270) Add latest releases to streams_upgrade_test.py

2018-08-09 Thread John Roesler (JIRA)
John Roesler created KAFKA-7270: --- Summary: Add latest releases to streams_upgrade_test.py Key: KAFKA-7270 URL: https://issues.apache.org/jira/browse/KAFKA-7270 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-7271) Fix ignored test in streams_upgrade_test.py: test_upgrade_downgrade_brokers

2018-08-09 Thread John Roesler (JIRA)
John Roesler created KAFKA-7271: --- Summary: Fix ignored test in streams_upgrade_test.py: test_upgrade_downgrade_brokers Key: KAFKA-7271 URL: https://issues.apache.org/jira/browse/KAFKA-7271 Project:

[jira] [Created] (KAFKA-7272) Fix ignored test in streams_upgrade_test.py: test_simple_upgrade_downgrade

2018-08-09 Thread John Roesler (JIRA)
John Roesler created KAFKA-7272: --- Summary: Fix ignored test in streams_upgrade_test.py: test_simple_upgrade_downgrade Key: KAFKA-7272 URL: https://issues.apache.org/jira/browse/KAFKA-7272 Project:

[jira] [Created] (KAFKA-7315) Streams serialization docs contain a broken link for Avro

2018-08-20 Thread John Roesler (JIRA)
John Roesler created KAFKA-7315: --- Summary: Streams serialization docs contain a broken link for Avro Key: KAFKA-7315 URL: https://issues.apache.org/jira/browse/KAFKA-7315 Project: Kafka Issue

[jira] [Resolved] (KAFKA-4988) JVM crash when running on Alpine Linux

2018-08-31 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-4988. - Resolution: Won't Fix I think this issue is out of our hands. If you think there is something

[jira] [Created] (KAFKA-7367) Verify that Streams never creates RocksDB stores unless they are needed

2018-08-31 Thread John Roesler (JIRA)
John Roesler created KAFKA-7367: --- Summary: Verify that Streams never creates RocksDB stores unless they are needed Key: KAFKA-7367 URL: https://issues.apache.org/jira/browse/KAFKA-7367 Project: Kafka

[jira] [Created] (KAFKA-7368) Support joining Windowed KTables

2018-08-31 Thread John Roesler (JIRA)
John Roesler created KAFKA-7368: --- Summary: Support joining Windowed KTables Key: KAFKA-7368 URL: https://issues.apache.org/jira/browse/KAFKA-7368 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-7386) Streams Scala wrapper should not cache serdes

2018-09-07 Thread John Roesler (JIRA)
John Roesler created KAFKA-7386: --- Summary: Streams Scala wrapper should not cache serdes Key: KAFKA-7386 URL: https://issues.apache.org/jira/browse/KAFKA-7386 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-7393) Consider making suppression node names independent of topologically numbered names.

2018-09-10 Thread John Roesler (JIRA)
John Roesler created KAFKA-7393: --- Summary: Consider making suppression node names independent of topologically numbered names. Key: KAFKA-7393 URL: https://issues.apache.org/jira/browse/KAFKA-7393

[jira] [Resolved] (KAFKA-7080) WindowStoreBuilder incorrectly initializes CachingWindowStore

2018-07-10 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-7080. - Resolution: Fixed Fixed in https://github.com/apache/kafka/pull/5257 > WindowStoreBuilder

[jira] [Created] (KAFKA-7161) KTable Reduce should check for invalid conditions

2018-07-13 Thread John Roesler (JIRA)
John Roesler created KAFKA-7161: --- Summary: KTable Reduce should check for invalid conditions Key: KAFKA-7161 URL: https://issues.apache.org/jira/browse/KAFKA-7161 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-7402) Kafka Streams should implement AutoCloseable where appropriate

2018-09-11 Thread John Roesler (JIRA)
John Roesler created KAFKA-7402: --- Summary: Kafka Streams should implement AutoCloseable where appropriate Key: KAFKA-7402 URL: https://issues.apache.org/jira/browse/KAFKA-7402 Project: Kafka

[jira] [Created] (KAFKA-7399) FunctionConversions in Streams-Scala should be private

2018-09-11 Thread John Roesler (JIRA)
John Roesler created KAFKA-7399: --- Summary: FunctionConversions in Streams-Scala should be private Key: KAFKA-7399 URL: https://issues.apache.org/jira/browse/KAFKA-7399 Project: Kafka Issue

[jira] [Created] (KAFKA-7539) ConsumerBounceTest.testClose transient failure

2018-10-24 Thread John Roesler (JIRA)
John Roesler created KAFKA-7539: --- Summary: ConsumerBounceTest.testClose transient failure Key: KAFKA-7539 URL: https://issues.apache.org/jira/browse/KAFKA-7539 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-7541) Transient Failure: kafka.server.DynamicBrokerReconfigurationTest.testUncleanLeaderElectionEnable

2018-10-24 Thread John Roesler (JIRA)
John Roesler created KAFKA-7541: --- Summary: Transient Failure: kafka.server.DynamicBrokerReconfigurationTest.testUncleanLeaderElectionEnable Key: KAFKA-7541 URL: https://issues.apache.org/jira/browse/KAFKA-7541

[jira] [Resolved] (KAFKA-7539) ConsumerBounceTest.testClose transient failure

2018-10-24 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-7539. - Resolution: Invalid Reviewer: (was: Jason Gustafson) Cloning to create this issue was a

[jira] [Created] (KAFKA-7540) Transient failure: kafka.api.ConsumerBounceTest.testClose

2018-10-24 Thread John Roesler (JIRA)
John Roesler created KAFKA-7540: --- Summary: Transient failure: kafka.api.ConsumerBounceTest.testClose Key: KAFKA-7540 URL: https://issues.apache.org/jira/browse/KAFKA-7540 Project: Kafka Issue

[jira] [Created] (KAFKA-7544) Transient Failure: org.apache.kafka.streams.integration.EosIntegrationTest.shouldNotViolateEosIfOneTaskFails

2018-10-24 Thread John Roesler (JIRA)
John Roesler created KAFKA-7544: --- Summary: Transient Failure: org.apache.kafka.streams.integration.EosIntegrationTest.shouldNotViolateEosIfOneTaskFails Key: KAFKA-7544 URL:

[jira] [Created] (KAFKA-7542) Transient Failure: kafka.server.GssapiAuthenticationTest.testServerAuthenticationFailure

2018-10-24 Thread John Roesler (JIRA)
John Roesler created KAFKA-7542: --- Summary: Transient Failure: kafka.server.GssapiAuthenticationTest.testServerAuthenticationFailure Key: KAFKA-7542 URL: https://issues.apache.org/jira/browse/KAFKA-7542

[jira] [Created] (KAFKA-7553) Jenkins PR tests hung

2018-10-25 Thread John Roesler (JIRA)
John Roesler created KAFKA-7553: --- Summary: Jenkins PR tests hung Key: KAFKA-7553 URL: https://issues.apache.org/jira/browse/KAFKA-7553 Project: Kafka Issue Type: Bug Reporter: John

[jira] [Resolved] (KAFKA-7393) Consider making suppression node names independent of topologically numbered names.

2018-10-03 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-7393. - Resolution: Won't Fix We realized that Suppressed needs to support a name parameter in keeping

[jira] [Created] (KAFKA-7477) Improve Streams close timeout semantics

2018-10-03 Thread John Roesler (JIRA)
John Roesler created KAFKA-7477: --- Summary: Improve Streams close timeout semantics Key: KAFKA-7477 URL: https://issues.apache.org/jira/browse/KAFKA-7477 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-7493) Rewrite test_broker_type_bounce_at_start

2018-10-09 Thread John Roesler (JIRA)
John Roesler created KAFKA-7493: --- Summary: Rewrite test_broker_type_bounce_at_start Key: KAFKA-7493 URL: https://issues.apache.org/jira/browse/KAFKA-7493 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-6033) Kafka Streams does not work with musl-libc (alpine linux)

2018-08-31 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-6033. - Resolution: Won't Fix This is unfortunately out of our hands. If you think I'm wrong about

[jira] [Created] (KAFKA-7435) Consider standardizing the config object pattern on interface/implementation.

2018-09-24 Thread John Roesler (JIRA)
John Roesler created KAFKA-7435: --- Summary: Consider standardizing the config object pattern on interface/implementation. Key: KAFKA-7435 URL: https://issues.apache.org/jira/browse/KAFKA-7435 Project:

[jira] [Resolved] (KAFKA-7852) Add public version of EmbeddedKafkaCluster

2019-01-23 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-7852. - Resolution: Duplicate > Add public version of EmbeddedKafkaCluster >

[jira] [Reopened] (KAFKA-7741) Bad dependency via SBT

2019-01-10 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reopened KAFKA-7741: - > Bad dependency via SBT > -- > > Key: KAFKA-7741 >

[jira] [Created] (KAFKA-7806) Windowed Aggregations should wrap default key serde if none is specified

2019-01-09 Thread John Roesler (JIRA)
John Roesler created KAFKA-7806: --- Summary: Windowed Aggregations should wrap default key serde if none is specified Key: KAFKA-7806 URL: https://issues.apache.org/jira/browse/KAFKA-7806 Project: Kafka

[jira] [Resolved] (KAFKA-4325) Improve processing of late records for window operations

2019-01-14 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-4325. - Resolution: Fixed Fix Version/s: 2.1.0 As [~mjsax] noted, this need was satisfied by

[jira] [Created] (KAFKA-7852) Add public version of EmbeddedKafkaCluster

2019-01-22 Thread John Roesler (JIRA)
John Roesler created KAFKA-7852: --- Summary: Add public version of EmbeddedKafkaCluster Key: KAFKA-7852 URL: https://issues.apache.org/jira/browse/KAFKA-7852 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-8167) Document named stateful operators

2019-03-27 Thread John Roesler (JIRA)
John Roesler created KAFKA-8167: --- Summary: Document named stateful operators Key: KAFKA-8167 URL: https://issues.apache.org/jira/browse/KAFKA-8167 Project: Kafka Issue Type: Task

[jira] [Created] (KAFKA-8189) Streams should have an option to require names for stateful components

2019-04-04 Thread John Roesler (JIRA)
John Roesler created KAFKA-8189: --- Summary: Streams should have an option to require names for stateful components Key: KAFKA-8189 URL: https://issues.apache.org/jira/browse/KAFKA-8189 Project: Kafka

[jira] [Created] (KAFKA-8155) Update Streams system tests for 2.2.0 and 2.1.1 releases

2019-03-25 Thread John Roesler (JIRA)
John Roesler created KAFKA-8155: --- Summary: Update Streams system tests for 2.2.0 and 2.1.1 releases Key: KAFKA-8155 URL: https://issues.apache.org/jira/browse/KAFKA-8155 Project: Kafka Issue

[jira] [Created] (KAFKA-8040) Streams needs to retry initTransactions

2019-03-04 Thread John Roesler (JIRA)
John Roesler created KAFKA-8040: --- Summary: Streams needs to retry initTransactions Key: KAFKA-8040 URL: https://issues.apache.org/jira/browse/KAFKA-8040 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-8111) KafkaProducer can't produce data

2019-03-15 Thread John Roesler (JIRA)
John Roesler created KAFKA-8111: --- Summary: KafkaProducer can't produce data Key: KAFKA-8111 URL: https://issues.apache.org/jira/browse/KAFKA-8111 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-8080) Remove streams_eos_test system test

2019-03-08 Thread John Roesler (JIRA)
John Roesler created KAFKA-8080: --- Summary: Remove streams_eos_test system test Key: KAFKA-8080 URL: https://issues.apache.org/jira/browse/KAFKA-8080 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-7944) Add more natural Suppress test

2019-03-12 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-7944. - Resolution: Fixed > Add more natural Suppress test > -- > >

[jira] [Created] (KAFKA-7944) Add more natural Suppress test

2019-02-18 Thread John Roesler (JIRA)
John Roesler created KAFKA-7944: --- Summary: Add more natural Suppress test Key: KAFKA-7944 URL: https://issues.apache.org/jira/browse/KAFKA-7944 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-7943) Add Suppress system test with caching disabled.

2019-02-18 Thread John Roesler (JIRA)
John Roesler created KAFKA-7943: --- Summary: Add Suppress system test with caching disabled. Key: KAFKA-7943 URL: https://issues.apache.org/jira/browse/KAFKA-7943 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-7928) Deprecate WindowStore.put(key, value)

2019-02-13 Thread John Roesler (JIRA)
John Roesler created KAFKA-7928: --- Summary: Deprecate WindowStore.put(key, value) Key: KAFKA-7928 URL: https://issues.apache.org/jira/browse/KAFKA-7928 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-7917) Streams store cleanup: collapse layers

2019-02-13 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-7917. - Resolution: Won't Fix > Streams store cleanup: collapse layers >

[jira] [Created] (KAFKA-7932) Streams needs to handle new Producer exceptions

2019-02-14 Thread John Roesler (JIRA)
John Roesler created KAFKA-7932: --- Summary: Streams needs to handle new Producer exceptions Key: KAFKA-7932 URL: https://issues.apache.org/jira/browse/KAFKA-7932 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-7916) Streams store cleanup: unify wrapping

2019-02-14 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-7916. - Resolution: Fixed > Streams store cleanup: unify wrapping >

[jira] [Created] (KAFKA-7916) Streams store cleanup: unify wrapping

2019-02-11 Thread John Roesler (JIRA)
John Roesler created KAFKA-7916: --- Summary: Streams store cleanup: unify wrapping Key: KAFKA-7916 URL: https://issues.apache.org/jira/browse/KAFKA-7916 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-7917) Streams store cleanup: collapse layers

2019-02-11 Thread John Roesler (JIRA)
John Roesler created KAFKA-7917: --- Summary: Streams store cleanup: collapse layers Key: KAFKA-7917 URL: https://issues.apache.org/jira/browse/KAFKA-7917 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-7918) Streams store cleanup: inline byte-store generic parameters

2019-02-11 Thread John Roesler (JIRA)
John Roesler created KAFKA-7918: --- Summary: Streams store cleanup: inline byte-store generic parameters Key: KAFKA-7918 URL: https://issues.apache.org/jira/browse/KAFKA-7918 Project: Kafka

[jira] [Created] (KAFKA-7919) Reorganize Stores builders

2019-02-11 Thread John Roesler (JIRA)
John Roesler created KAFKA-7919: --- Summary: Reorganize Stores builders Key: KAFKA-7919 URL: https://issues.apache.org/jira/browse/KAFKA-7919 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-7223) KIP-328: Add in-memory Suppression

2019-01-24 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-7223. - Resolution: Fixed > KIP-328: Add in-memory Suppression > -- > >

[jira] [Created] (KAFKA-8478) Poll for more records before forced processing

2019-06-04 Thread John Roesler (JIRA)
John Roesler created KAFKA-8478: --- Summary: Poll for more records before forced processing Key: KAFKA-8478 URL: https://issues.apache.org/jira/browse/KAFKA-8478 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-8452) Possible Suppress buffer optimization: de-duplicate prior value

2019-05-30 Thread John Roesler (JIRA)
John Roesler created KAFKA-8452: --- Summary: Possible Suppress buffer optimization: de-duplicate prior value Key: KAFKA-8452 URL: https://issues.apache.org/jira/browse/KAFKA-8452 Project: Kafka

[jira] [Created] (KAFKA-8455) Add NothingSerde to Serdes

2019-05-31 Thread John Roesler (JIRA)
John Roesler created KAFKA-8455: --- Summary: Add NothingSerde to Serdes Key: KAFKA-8455 URL: https://issues.apache.org/jira/browse/KAFKA-8455 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-7991) Add StreamsUpgradeTest for 2.2 release

2019-05-28 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-7991. - Resolution: Duplicate Yep. Closing as a duplicate. > Add StreamsUpgradeTest for 2.2 release >

[jira] [Resolved] (KAFKA-8452) Possible Suppress buffer optimization: de-duplicate prior value

2019-06-20 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-8452. - Resolution: Fixed > Possible Suppress buffer optimization: de-duplicate prior value >

[jira] [Created] (KAFKA-8582) Consider adding an ExpiredWindowRecordHandler to Suppress

2019-06-21 Thread John Roesler (JIRA)
John Roesler created KAFKA-8582: --- Summary: Consider adding an ExpiredWindowRecordHandler to Suppress Key: KAFKA-8582 URL: https://issues.apache.org/jira/browse/KAFKA-8582 Project: Kafka Issue

[jira] [Created] (KAFKA-8410) Strengthen the types of Processors, at least in the DSL, maybe in the PAPI as well

2019-05-22 Thread John Roesler (JIRA)
John Roesler created KAFKA-8410: --- Summary: Strengthen the types of Processors, at least in the DSL, maybe in the PAPI as well Key: KAFKA-8410 URL: https://issues.apache.org/jira/browse/KAFKA-8410

[jira] [Created] (KAFKA-8403) Suppress needs a Materialized variant

2019-05-21 Thread John Roesler (JIRA)
John Roesler created KAFKA-8403: --- Summary: Suppress needs a Materialized variant Key: KAFKA-8403 URL: https://issues.apache.org/jira/browse/KAFKA-8403 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-8396) Clean up Transformer API

2019-05-20 Thread John Roesler (JIRA)
John Roesler created KAFKA-8396: --- Summary: Clean up Transformer API Key: KAFKA-8396 URL: https://issues.apache.org/jira/browse/KAFKA-8396 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-8307) Kafka Streams should provide some mechanism to determine topology equality and compatibility

2019-04-30 Thread John Roesler (JIRA)
John Roesler created KAFKA-8307: --- Summary: Kafka Streams should provide some mechanism to determine topology equality and compatibility Key: KAFKA-8307 URL: https://issues.apache.org/jira/browse/KAFKA-8307

[jira] [Created] (KAFKA-8260) Flaky test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

2019-04-18 Thread John Roesler (JIRA)
John Roesler created KAFKA-8260: --- Summary: Flaky test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup Key: KAFKA-8260 URL: https://issues.apache.org/jira/browse/KAFKA-8260

[jira] [Created] (KAFKA-8254) Suppress incorrectly passes a null topic to the serdes

2019-04-18 Thread John Roesler (JIRA)
John Roesler created KAFKA-8254: --- Summary: Suppress incorrectly passes a null topic to the serdes Key: KAFKA-8254 URL: https://issues.apache.org/jira/browse/KAFKA-8254 Project: Kafka Issue

[jira] [Created] (KAFKA-8318) Session Window Aggregations generate an extra tombstone

2019-05-03 Thread John Roesler (JIRA)
John Roesler created KAFKA-8318: --- Summary: Session Window Aggregations generate an extra tombstone Key: KAFKA-8318 URL: https://issues.apache.org/jira/browse/KAFKA-8318 Project: Kafka Issue

[jira] [Created] (KAFKA-8280) Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable

2019-04-23 Thread John Roesler (JIRA)
John Roesler created KAFKA-8280: --- Summary: Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable Key: KAFKA-8280 URL: https://issues.apache.org/jira/browse/KAFKA-8280 Project:

[jira] [Reopened] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

2019-04-10 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reopened KAFKA-7895: - > Ktable supress operator emitting more than one record for the same key per > window >

[jira] [Created] (KAFKA-8204) Streams may flush state stores in the incorrect order

2019-04-09 Thread John Roesler (JIRA)
John Roesler created KAFKA-8204: --- Summary: Streams may flush state stores in the incorrect order Key: KAFKA-8204 URL: https://issues.apache.org/jira/browse/KAFKA-8204 Project: Kafka Issue

[jira] [Created] (KAFKA-8868) Consider auto-generating Streams binary protocol messages

2019-09-04 Thread John Roesler (Jira)
John Roesler created KAFKA-8868: --- Summary: Consider auto-generating Streams binary protocol messages Key: KAFKA-8868 URL: https://issues.apache.org/jira/browse/KAFKA-8868 Project: Kafka Issue

[jira] [Created] (KAFKA-8770) Either switch to or add an option for emit-on-change

2019-08-08 Thread John Roesler (JIRA)
John Roesler created KAFKA-8770: --- Summary: Either switch to or add an option for emit-on-change Key: KAFKA-8770 URL: https://issues.apache.org/jira/browse/KAFKA-8770 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-8769) Consider computing stream time independently per key

2019-08-08 Thread John Roesler (JIRA)
John Roesler created KAFKA-8769: --- Summary: Consider computing stream time independently per key Key: KAFKA-8769 URL: https://issues.apache.org/jira/browse/KAFKA-8769 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-8696) Clean up Sum/Count/Total metrics

2019-07-22 Thread John Roesler (JIRA)
John Roesler created KAFKA-8696: --- Summary: Clean up Sum/Count/Total metrics Key: KAFKA-8696 URL: https://issues.apache.org/jira/browse/KAFKA-8696 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-9138) Add system test covering Foreign Key joins (KIP-213)

2019-11-04 Thread John Roesler (Jira)
John Roesler created KAFKA-9138: --- Summary: Add system test covering Foreign Key joins (KIP-213) Key: KAFKA-9138 URL: https://issues.apache.org/jira/browse/KAFKA-9138 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-9169) Standby Tasks point ask for incorrect offsets on resuming post suspension

2019-11-13 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9169. - Resolution: Fixed This was fixed in https://github.com/apache/kafka/pull/7681/ and merged to

[jira] [Created] (KAFKA-9268) Follow-on: Streams Threads may die from recoverable errors with EOS enabled

2019-12-04 Thread John Roesler (Jira)
John Roesler created KAFKA-9268: --- Summary: Follow-on: Streams Threads may die from recoverable errors with EOS enabled Key: KAFKA-9268 URL: https://issues.apache.org/jira/browse/KAFKA-9268 Project:

[jira] [Reopened] (KAFKA-8937) Flaky Test SaslPlainSslEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

2019-12-03 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reopened KAFKA-8937: - This test has just failed again for me. Apparently, it is not fixed. Unfortunately, Jenkins didn't

[jira] [Created] (KAFKA-9263) Reocurrence: Transient failure in kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpointkafka.api.AdminClientIntegrationTest.testAlterReplicaLogDirs

2019-12-03 Thread John Roesler (Jira)
John Roesler created KAFKA-9263: --- Summary: Reocurrence: Transient failure in kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpointkafka.api.AdminClientIntegrationTest.testAlterReplicaLogDirs Key: KAFKA-9263

[jira] [Created] (KAFKA-9264) Reocurrence: Flaky Test DelegationTokenEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

2019-12-03 Thread John Roesler (Jira)
John Roesler created KAFKA-9264: --- Summary: Reocurrence: Flaky Test DelegationTokenEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl Key: KAFKA-9264 URL:

[jira] [Created] (KAFKA-9310) StreamThread may die from recoverable UnknownProducerId exception

2019-12-17 Thread John Roesler (Jira)
John Roesler created KAFKA-9310: --- Summary: StreamThread may die from recoverable UnknownProducerId exception Key: KAFKA-9310 URL: https://issues.apache.org/jira/browse/KAFKA-9310 Project: Kafka

[jira] [Resolved] (KAFKA-9138) Add system test covering Foreign Key joins (KIP-213)

2019-12-11 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9138. - Resolution: Fixed Added the system test in

[jira] [Resolved] (KAFKA-9231) Streams Threads may die from recoverable errors with EOS enabled

2019-12-03 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9231. - Resolution: Fixed Fixed in 2.4 by

[jira] [Created] (KAFKA-9289) consolidate all the streams smoke system tests

2019-12-10 Thread John Roesler (Jira)
John Roesler created KAFKA-9289: --- Summary: consolidate all the streams smoke system tests Key: KAFKA-9289 URL: https://issues.apache.org/jira/browse/KAFKA-9289 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-9022) Flaky Test KTableKTableForeignKeyJoinIntegrationTest. doInnerJoinFilterOutRapidlyChangingForeignKeyValues

2019-10-15 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9022. - Resolution: Duplicate > Flaky Test KTableKTableForeignKeyJoinIntegrationTest. >

[jira] [Resolved] (KAFKA-9006) Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFilterOutRapidlyChangingForeignKeyValues

2019-10-14 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9006. - Resolution: Duplicate > Flaky Test >

[jira] [Created] (KAFKA-9103) KIP-441: Add TaskLags to SubscriptionInfo

2019-10-24 Thread John Roesler (Jira)
John Roesler created KAFKA-9103: --- Summary: KIP-441: Add TaskLags to SubscriptionInfo Key: KAFKA-9103 URL: https://issues.apache.org/jira/browse/KAFKA-9103 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-9058) Foreign Key Join should not require a queriable store

2019-10-16 Thread John Roesler (Jira)
John Roesler created KAFKA-9058: --- Summary: Foreign Key Join should not require a queriable store Key: KAFKA-9058 URL: https://issues.apache.org/jira/browse/KAFKA-9058 Project: Kafka Issue

  1   2   >