Bulk Operation

  1. Choose Issues
  2. Choose Operation
  3. Operation Details
  4. Confirmation

Step 1 of 4: Choose Issues

Cancel

T Patch Info Key Summary Assignee Reporter P Status Resolution Created Updated Due Development
Sub-task KAFKA-4114

KAFKA-2590 Allow for different "auto.offset.reset" strategies for different input streams

Bill Bejeck Matthias J. Sax Major Resolved Fixed  
Sub-task KAFKA-3612

KAFKA-2590 Add initial set of integration tests

Eno Thereska Eno Thereska Major Resolved Fixed  
Sub-task KAFKA-3599

KAFKA-2590 Move WindowStoreUtils to package "internals"

Matthias J. Sax Matthias J. Sax Minor Resolved Fixed  
Sub-task KAFKA-3598

KAFKA-2590 Improve JavaDoc of public API

Matthias J. Sax Matthias J. Sax Trivial Resolved Fixed  
Sub-task KAFKA-3576

KAFKA-2590 Unify KStream and KTable API

Damian Guy Matthias J. Sax Major Resolved Resolved  
Sub-task KAFKA-3574

KAFKA-2590 Add missing @returns tags for JavaDoc

Matthias J. Sax Matthias J. Sax Minor Closed Duplicate  
Sub-task KAFKA-3505

KAFKA-2590 Set curRecord in punctuate() functions

Guozhang Wang Guozhang Wang Major Resolved Fixed  
Sub-task KAFKA-3504

KAFKA-2590 Changelog partition configured to enable log compaction

Eno Thereska Guozhang Wang Major Resolved Fixed  
Sub-task KAFKA-3499

KAFKA-2590 byte[] should not be used as Map key nor Set member

Guozhang Wang josh gruenberg Major Resolved Fixed  
Sub-task KAFKA-3497

KAFKA-2590 Streams ProcessorContext should support forward() based on child name

Eno Thereska Yuto Kawamura Major Resolved Fixed  
Sub-task KAFKA-3478

KAFKA-2590 Finer Stream Flow Control

Unassigned Guozhang Wang Major Resolved Duplicate  
Sub-task KAFKA-3477

KAFKA-2590 Add customizable StreamPartition into #to functions of Streams DSL

Matthias J. Sax Guozhang Wang Major Resolved Fixed  
Sub-task KAFKA-3455

KAFKA-2590 Connect custom processors with the streams DSL

Unassigned Jonathan Bender Major Resolved Not A Problem  
Sub-task KAFKA-3449

KAFKA-2590 Rename filterOut() to filterNot() to achieve better terminology

Andrea Cosentino Michael Noll Major Resolved Fixed  
Sub-task KAFKA-3443

KAFKA-2590 Support regex topics in addSource() and stream()

Bill Bejeck Guozhang Wang Major Resolved Fixed  
Sub-task KAFKA-3440

KAFKA-2590 Add Javadoc for KTable (changelog stream) and KStream (record stream)

Matthias J. Sax Guozhang Wang Major Resolved Fixed  
Sub-task KAFKA-3439

KAFKA-2590 Document possible exception thrown in public APIs

Eno Thereska Guozhang Wang Major Resolved Fixed  
Sub-task KAFKA-3430

KAFKA-2590 Allow users to set key in KTable.toStream() and KStream

Bill Bejeck Guozhang Wang Major Resolved Fixed  
Sub-task KAFKA-3422

KAFKA-2590 Add overloading functions for each operator not requiring serialization

Guozhang Wang Guozhang Wang Blocker Resolved Fixed  
Sub-task KAFKA-3395

KAFKA-2590 prefix job id to internal topic names

Yasuhiro Matsuda Yasuhiro Matsuda Major Resolved Fixed  
Sub-task KAFKA-3338

KAFKA-2590 Add print and writeAsText functions to the Streams DSL

Bill Bejeck Guozhang Wang Major Resolved Fixed  
Sub-task KAFKA-3337

KAFKA-2590 Extract selector as a separate groupBy operator for KTable aggregations

Matthias J. Sax Guozhang Wang Major Resolved Fixed  
Sub-task KAFKA-3336

KAFKA-2590 Unify ser/de pair classes into one serde class

Guozhang Wang Guozhang Wang Blocker Resolved Fixed  
Sub-task KAFKA-3311

KAFKA-2590 Move co-partition checking to PartitionAssignor and auto-create internal topics

Guozhang Wang Guozhang Wang Major Resolved Fixed  
Sub-task KAFKA-3245

KAFKA-2590 need a way to specify the number of replicas for change log topics

Yasuhiro Matsuda Yasuhiro Matsuda Major Resolved Fixed  
Sub-task KAFKA-3212

KAFKA-2590 Race Condition for Repartition Topics

Unassigned Guozhang Wang Major Resolved Not A Problem  
Sub-task KAFKA-3193

KAFKA-2590 Wait for producer message acks in StreamTask.commit()

Unassigned Guozhang Wang Major Resolved Not A Problem  
Sub-task KAFKA-3192

KAFKA-2590 Add implicit unlimited windowed aggregation for KStream

Guozhang Wang Guozhang Wang Major Resolved Fixed  
Sub-task KAFKA-3153

KAFKA-2590 Serializer/Deserializer Registration and Type inference

Yasuhiro Matsuda Yasuhiro Matsuda Major Resolved Won't Fix  
Sub-task KAFKA-3142

KAFKA-2590 Improve error message in kstreams

Guozhang Wang Jay Kreps Major Resolved Fixed  
Sub-task KAFKA-3136

KAFKA-2590 Rename KafkaStreaming to KafkaStreams

Guozhang Wang Guozhang Wang Major Resolved Fixed  
Sub-task KAFKA-3133

KAFKA-2590 Add putIfAbsent function to KeyValueStore

Kim Christensen Guozhang Wang Major Resolved Fixed  
Sub-task KAFKA-3125

KAFKA-2590 Exception Hierarchy for Streams

Guozhang Wang Guozhang Wang Major Resolved Fixed  
Sub-task KAFKA-3121

KAFKA-2590 KStream DSL API Improvement

Guozhang Wang Guozhang Wang Major Resolved Fixed  
Sub-task KAFKA-3108

KAFKA-2590 KStream custom StreamPartitioner for windowed key

Yasuhiro Matsuda Yasuhiro Matsuda Minor Resolved Fixed  
Sub-task KAFKA-3104

KAFKA-2590 Windowed Stream Aggregation Implementation

Guozhang Wang Guozhang Wang Major Resolved Fixed  
Sub-task KAFKA-3081

KAFKA-2590 KTable Aggregation Implementation

Guozhang Wang Guozhang Wang Major Resolved Fixed  
Sub-task KAFKA-3066

KAFKA-2590 Add Demo Examples for Kafka Streams

Guozhang Wang Guozhang Wang Major Resolved Fixed  
Sub-task KAFKA-3060

KAFKA-2590 Refactor MeteredXXStore

Guozhang Wang Yasuhiro Matsuda Minor Resolved Fixed  
Sub-task KAFKA-3016

KAFKA-2590 Add KStream-KStream window joins

Yasuhiro Matsuda Yasuhiro Matsuda Major Resolved Fixed  
Sub-task KAFKA-2984

KAFKA-2590 KTable should send old values along with new values to downstreams

Yasuhiro Matsuda Yasuhiro Matsuda Major Resolved Fixed  
Sub-task KAFKA-2962

KAFKA-2590 Add Simple Join API

Yasuhiro Matsuda Yasuhiro Matsuda Major Resolved Fixed  
Sub-task KAFKA-2856

KAFKA-2590 add KTable

Yasuhiro Matsuda Yasuhiro Matsuda Major Resolved Fixed  
Sub-task KAFKA-2811

KAFKA-2590 Add standby tasks

Yasuhiro Matsuda Yasuhiro Matsuda Major Resolved Fixed  
Sub-task KAFKA-2804

KAFKA-2590 Create / Update changelog topics upon state store initialization

Guozhang Wang Guozhang Wang Major Resolved Fixed  
Sub-task KAFKA-2802

KAFKA-2590 Add integration tests for Kafka Streams

Yasuhiro Matsuda Guozhang Wang Major Resolved Fixed  
Sub-task KAFKA-2763

KAFKA-2590 Reduce stream task migrations and initialization costs

Yasuhiro Matsuda Yasuhiro Matsuda Major Resolved Fixed  
Sub-task KAFKA-2733

KAFKA-2590 Distinguish metric names inside the sensor registry

Guozhang Wang Guozhang Wang Major Resolved Fixed  
Sub-task KAFKA-2727

KAFKA-2590 initialize only the part of the topology relevant to the task

Yasuhiro Matsuda Yasuhiro Matsuda Major Resolved Fixed  
Sub-task KAFKA-2707

KAFKA-2590 Make KStream processor names deterministic

Yasuhiro Matsuda Yasuhiro Matsuda Major Resolved Fixed  
Sub-task KAFKA-2706

KAFKA-2590 Make state stores first class citizens in the processor DAG

Yasuhiro Matsuda Yasuhiro Matsuda Major Resolved Fixed  
Sub-task KAFKA-2694

KAFKA-2590 Make a task id be a composite id of a topic group id and a partition id

Yasuhiro Matsuda Yasuhiro Matsuda Major Resolved Fixed  
Sub-task KAFKA-2654

KAFKA-2590 Avoid calling Consumer.poll(0) in each iteration

Yasuhiro Matsuda Guozhang Wang Major Resolved Fixed  
Sub-task KAFKA-2653

KAFKA-2590 Stateful operations in the KStream DSL layer

Guozhang Wang Guozhang Wang Major Resolved Fixed  
Sub-task KAFKA-2652

KAFKA-2590 Incorporate the new consumer protocol with partition-group interface

Yasuhiro Matsuda Guozhang Wang Major Resolved Fixed  
Sub-task KAFKA-2649

KAFKA-2590 Add support for custom partitioner in sink nodes

Randall Hauch Randall Hauch Major Resolved Fixed  
Sub-task KAFKA-2600

KAFKA-2590 Make KStream interfaces compatible with Java 8 java.util.function

Randall Hauch Guozhang Wang Major Resolved Fixed  
Sub-task KAFKA-2594

KAFKA-2590 Add a key-value store that is a fixed-capacity in-memory LRU cache

Randall Hauch Randall Hauch Major Resolved Fixed  
Sub-task KAFKA-2593

KAFKA-2590 KeyValueStores should not require use of the context's default serializers and deserializers

Randall Hauch Randall Hauch Major Resolved Fixed  
Sub-task KAFKA-2592

KAFKA-2590 Stop Writing the Change-log in store.put() / delete() for Non-transactional Store

Yasuhiro Matsuda Guozhang Wang Major Resolved Won't Fix  
Sub-task KAFKA-2591

KAFKA-2590 Remove Persistent Data before Restoringafter a Fault

Guozhang Wang Guozhang Wang Major Resolved Fixed  

Cancel