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
Compon
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 Typ
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-8280:
---
Summary: Flaky Test
DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable
Key: KAFKA-8280
URL: https://issues.apache.org/jira/browse/KAFKA-8280
Project: Kafk
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 Type
[
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 Type:
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-8167:
---
Summary: Document named stateful operators
Key: KAFKA-8167
URL: https://issues.apache.org/jira/browse/KAFKA-8167
Project: Kafka
Issue Type: Task
Comp
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 Ty
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
Compon
[
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-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
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-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: Impro
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: Impro
[
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-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-7919:
---
Summary: Reorganize Stores builders
Key: KAFKA-7919
URL: https://issues.apache.org/jira/browse/KAFKA-7919
Project: Kafka
Issue Type: Improvement
Comp
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
Issu
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-7916:
---
Summary: Streams store cleanup: unify wrapping
Key: KAFKA-7916
URL: https://issues.apache.org/jira/browse/KAFKA-7916
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
> --
>
>
[
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
>
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: Improvemen
[
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 KAFKA
[
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
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
John Roesler created KAFKA-7544:
---
Summary: Transient Failure:
org.apache.kafka.streams.integration.EosIntegrationTest.shouldNotViolateEosIfOneTaskFails
Key: KAFKA-7544
URL: https://issues.apache.org/jira/browse/KAFK
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-7541:
---
Summary: Transient Failure:
kafka.server.DynamicBrokerReconfigurationTest.testUncleanLeaderElectionEnable
Key: KAFKA-7541
URL: https://issues.apache.org/jira/browse/KAFKA-7541
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 T
[
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 m
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: Sub-ta
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-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 wi
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-7435:
---
Summary: Consider standardizing the config object pattern on
interface/implementation.
Key: KAFKA-7435
URL: https://issues.apache.org/jira/browse/KAFKA-7435
Project: Ka
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
I
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 Type
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
Proje
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-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-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
[
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 fo
[
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 this,
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 T
[
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 merg
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 Type
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 Typ
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
Com
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: Kafka
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: Kafk
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: Improv
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-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-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: Improvemen
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-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-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: Imp
[
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 incorr
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-7106:
---
Summary: Remove segment/segmentInterval from Window definition
Key: KAFKA-7106
URL: https://issues.apache.org/jira/browse/KAFKA-7106
Project: Kafka
Issue Type:
[
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
https://github.com/apac
John Roesler created KAFKA-7080:
---
Summary: WindowStoreBuilder incorrectly initializes
CachingWindowStore
Key: KAFKA-7080
URL: https://issues.apache.org/jira/browse/KAFKA-7080
Project: Kafka
Is
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-7000:
---
Summary: KafkaConsumer.position should wait for assignment metadata
Key: KAFKA-7000
URL: https://issues.apache.org/jira/browse/KAFKA-7000
Project: Kafka
Issue
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: Improvement
[
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://github.com/apache/kafka/commit/c47
[
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
201 - 275 of 275 matches
Mail list logo