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
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:
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
[
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
[
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
[
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
John Roesler created KAFKA-7080:
---
Summary: WindowStoreBuilder incorrectly initializes
CachingWindowStore
Key: KAFKA-7080
URL: https://issues.apache.org/jira/browse/KAFKA-7080
Project: Kafka
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
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
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
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:
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
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
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
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
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
[
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
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
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:
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:
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:
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
[
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
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
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
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
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
[
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
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:
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
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
John Roesler created KAFKA-7541:
---
Summary: Transient Failure:
kafka.server.DynamicBrokerReconfigurationTest.testUncleanLeaderElectionEnable
Key: KAFKA-7541
URL: https://issues.apache.org/jira/browse/KAFKA-7541
[
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
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
John Roesler created KAFKA-7544:
---
Summary: Transient Failure:
org.apache.kafka.streams.integration.EosIntegrationTest.shouldNotViolateEosIfOneTaskFails
Key: KAFKA-7544
URL:
John Roesler created KAFKA-7542:
---
Summary: Transient Failure:
kafka.server.GssapiAuthenticationTest.testServerAuthenticationFailure
Key: KAFKA-7542
URL: https://issues.apache.org/jira/browse/KAFKA-7542
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
[
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
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
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
[
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
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:
[
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
>
[
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
>
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
[
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
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:
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
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
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
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
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
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
[
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
> --
>
>
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
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:
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
[
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
>
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:
[
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
>
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
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
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
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
[
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
> --
>
>
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:
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
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
[
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
>
[
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
>
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
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
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
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
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
John Roesler created KAFKA-8260:
---
Summary: Flaky test
ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup
Key: KAFKA-8260
URL: https://issues.apache.org/jira/browse/KAFKA-8260
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
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
John Roesler created KAFKA-8280:
---
Summary: Flaky Test
DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable
Key: KAFKA-8280
URL: https://issues.apache.org/jira/browse/KAFKA-8280
Project:
[
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
>
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
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
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:
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:
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
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:
[
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
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:
[
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
John Roesler created KAFKA-9263:
---
Summary: Reocurrence: Transient failure in
kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpointkafka.api.AdminClientIntegrationTest.testAlterReplicaLogDirs
Key: KAFKA-9263
John Roesler created KAFKA-9264:
---
Summary: Reocurrence: Flaky Test
DelegationTokenEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl
Key: KAFKA-9264
URL:
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
[
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
[
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
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
[
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.
>
[
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
>
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:
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
[
https://issues.apache.org/jira/browse/KAFKA-8902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-8902.
-
Resolution: Fixed
I wrote a simple Streams application using the Processor API to update 10
1 - 100 of 274 matches
Mail list logo
