Linked Applications
Loading…
Dashboards
Projects
Issues
Help
Jira Core help
Keyboard Shortcuts
About Jira
Jira Credits
Log In
Kafka
KAFKA-2590
KIP-28: Kafka Streams Checklist
Log In
Export
XML
Word
Printable
JSON
Details
Type:
New Feature
Status:
Resolved
Priority:
Major
Resolution:
Fixed
Affects Version/s:
None
Fix Version/s:
0.11.0.0
Component/s:
streams
Labels:
None
Description
This is an umbrella story for the processor client and Kafka Streams feature implementation.
Attachments
Options
Show All
Show Open
Bulk operation
Open issue navigator
Sub-Tasks
1.
Remove Persistent Data before Restoringafter a Fault
Resolved
Guozhang Wang
2.
Stop Writing the Change-log in store.put() / delete() for Non-transactional Store
Resolved
Yasuhiro Matsuda
3.
KeyValueStores should not require use of the context's default serializers and deserializers
Resolved
Randall Hauch
4.
Add a key-value store that is a fixed-capacity in-memory LRU cache
Resolved
Randall Hauch
5.
Make KStream interfaces compatible with Java 8 java.util.function
Resolved
Randall Hauch
6.
Add support for custom partitioner in sink nodes
Resolved
Randall Hauch
7.
Incorporate the new consumer protocol with partition-group interface
Resolved
Yasuhiro Matsuda
8.
Stateful operations in the KStream DSL layer
Resolved
Guozhang Wang
9.
Avoid calling Consumer.poll(0) in each iteration
Resolved
Yasuhiro Matsuda
10.
Make a task id be a composite id of a topic group id and a partition id
Resolved
Yasuhiro Matsuda
11.
Make state stores first class citizens in the processor DAG
Resolved
Yasuhiro Matsuda
12.
Make KStream processor names deterministic
Resolved
Yasuhiro Matsuda
13.
initialize only the part of the topology relevant to the task
Resolved
Yasuhiro Matsuda
14.
Distinguish metric names inside the sensor registry
Resolved
Guozhang Wang
15.
Reduce stream task migrations and initialization costs
Resolved
Yasuhiro Matsuda
16.
Add integration tests for Kafka Streams
Resolved
Yasuhiro Matsuda
17.
Create / Update changelog topics upon state store initialization
Resolved
Guozhang Wang
18.
Add standby tasks
Resolved
Yasuhiro Matsuda
19.
add KTable
Resolved
Yasuhiro Matsuda
20.
Add Simple Join API
Resolved
Yasuhiro Matsuda
21.
KTable should send old values along with new values to downstreams
Resolved
Yasuhiro Matsuda
22.
Add KStream-KStream window joins
Resolved
Yasuhiro Matsuda
23.
Refactor MeteredXXStore
Resolved
Guozhang Wang
24.
Add Demo Examples for Kafka Streams
Resolved
Guozhang Wang
25.
KTable Aggregation Implementation
Resolved
Guozhang Wang
26.
Windowed Stream Aggregation Implementation
Resolved
Guozhang Wang
27.
KStream custom StreamPartitioner for windowed key
Resolved
Yasuhiro Matsuda
28.
KStream DSL API Improvement
Resolved
Guozhang Wang
29.
Exception Hierarchy for Streams
Resolved
Guozhang Wang
30.
Add putIfAbsent function to KeyValueStore
Resolved
Kim Christensen
31.
Rename KafkaStreaming to KafkaStreams
Resolved
Guozhang Wang
32.
Improve error message in kstreams
Resolved
Guozhang Wang
33.
Serializer/Deserializer Registration and Type inference
Resolved
Yasuhiro Matsuda
34.
Add implicit unlimited windowed aggregation for KStream
Resolved
Guozhang Wang
35.
Wait for producer message acks in StreamTask.commit()
Resolved
Unassigned
36.
Race Condition for Repartition Topics
Resolved
Unassigned
37.
need a way to specify the number of replicas for change log topics
Resolved
Yasuhiro Matsuda
38.
Move co-partition checking to PartitionAssignor and auto-create internal topics
Resolved
Guozhang Wang
39.
Unify ser/de pair classes into one serde class
Resolved
Guozhang Wang
40.
Extract selector as a separate groupBy operator for KTable aggregations
Resolved
Matthias J. Sax
41.
Add print and writeAsText functions to the Streams DSL
Resolved
Bill Bejeck
42.
prefix job id to internal topic names
Resolved
Yasuhiro Matsuda
43.
Add overloading functions for each operator not requiring serialization
Resolved
Guozhang Wang
44.
Allow users to set key in KTable.toStream() and KStream
Resolved
Bill Bejeck
45.
Document possible exception thrown in public APIs
Resolved
Eno Thereska
46.
Add Javadoc for KTable (changelog stream) and KStream (record stream)
Resolved
Matthias J. Sax
47.
Support regex topics in addSource() and stream()
Resolved
Bill Bejeck
48.
Rename filterOut() to filterNot() to achieve better terminology
Resolved
Andrea Cosentino
49.
Connect custom processors with the streams DSL
Resolved
Unassigned
50.
Add customizable StreamPartition into #to functions of Streams DSL
Resolved
Matthias J. Sax
51.
Finer Stream Flow Control
Resolved
Unassigned
52.
Streams ProcessorContext should support forward() based on child name
Resolved
Eno Thereska
53.
Changelog partition configured to enable log compaction
Resolved
Eno Thereska
54.
Set curRecord in punctuate() functions
Resolved
Guozhang Wang
55.
byte[] should not be used as Map key nor Set member
Resolved
Guozhang Wang
56.
Add missing @returns tags for JavaDoc
Closed
Matthias J. Sax
57.
Unify KStream and KTable API
Resolved
Damian Guy
58.
Improve JavaDoc of public API
Resolved
Matthias J. Sax
59.
Move WindowStoreUtils to package "internals"
Resolved
Matthias J. Sax
60.
Add initial set of integration tests
Resolved
Eno Thereska
61.
Allow for different "auto.offset.reset" strategies for different input streams
Resolved
Bill Bejeck
Activity
People
Assignee:
Guozhang Wang
Reporter:
Guozhang Wang
Votes:
0
Vote for this issue
Watchers:
4
Start watching this issue
Dates
Created:
28/Sep/15 17:00
Updated:
23/Aug/17 00:41
Resolved:
23/Aug/17 00:40