Export - CSV (All fields)
Export - CSV (Current fields)
- KAFKA-4114
Allow for different "auto.offset.reset" strategies for different input streams - KAFKA-3612
Add initial set of integration tests - KAFKA-3599
Move WindowStoreUtils to package "internals" - KAFKA-3598
Improve JavaDoc of public API - KAFKA-3576
Unify KStream and KTable API - KAFKA-3574
Add missing @returns tags for JavaDoc - KAFKA-3505
Set curRecord in punctuate() functions - KAFKA-3504
Changelog partition configured to enable log compaction - KAFKA-3499
byte[] should not be used as Map key nor Set member - KAFKA-3497
Streams ProcessorContext should support forward() based on child name - KAFKA-3478
Finer Stream Flow Control - KAFKA-3477
Add customizable StreamPartition into #to functions of Streams DSL - KAFKA-3455
Connect custom processors with the streams DSL - KAFKA-3449
Rename filterOut() to filterNot() to achieve better terminology - KAFKA-3443
Support regex topics in addSource() and stream() - KAFKA-3440
Add Javadoc for KTable (changelog stream) and KStream (record stream) - KAFKA-3439
Document possible exception thrown in public APIs - KAFKA-3430
Allow users to set key in KTable.toStream() and KStream - KAFKA-3422
Add overloading functions for each operator not requiring serialization - KAFKA-3395
prefix job id to internal topic names - KAFKA-3338
Add print and writeAsText functions to the Streams DSL - KAFKA-3337
Extract selector as a separate groupBy operator for KTable aggregations - KAFKA-3336
Unify ser/de pair classes into one serde class - KAFKA-3311
Move co-partition checking to PartitionAssignor and auto-create internal topics - KAFKA-3245
need a way to specify the number of replicas for change log topics - KAFKA-3212
Race Condition for Repartition Topics - KAFKA-3193
Wait for producer message acks in StreamTask.commit() - KAFKA-3192
Add implicit unlimited windowed aggregation for KStream - KAFKA-3153
Serializer/Deserializer Registration and Type inference - KAFKA-3142
Improve error message in kstreams - KAFKA-3136
Rename KafkaStreaming to KafkaStreams - KAFKA-3133
Add putIfAbsent function to KeyValueStore - KAFKA-3125
Exception Hierarchy for Streams - KAFKA-3121
KStream DSL API Improvement - KAFKA-3108
KStream custom StreamPartitioner for windowed key - KAFKA-3104
Windowed Stream Aggregation Implementation - KAFKA-3081
KTable Aggregation Implementation - KAFKA-3066
Add Demo Examples for Kafka Streams - KAFKA-3060
Refactor MeteredXXStore - KAFKA-3016
Add KStream-KStream window joins - KAFKA-2984
KTable should send old values along with new values to downstreams - KAFKA-2962
Add Simple Join API - KAFKA-2856
add KTable - KAFKA-2811
Add standby tasks - KAFKA-2804
Create / Update changelog topics upon state store initialization - KAFKA-2802
Add integration tests for Kafka Streams - KAFKA-2763
Reduce stream task migrations and initialization costs - KAFKA-2733
Distinguish metric names inside the sensor registry - KAFKA-2727
initialize only the part of the topology relevant to the task - KAFKA-2707
Make KStream processor names deterministic
{"errorMessages":["jqlTooComplex"],"errors":{}}
[{"id":-1,"name":"My open issues","jql":"assignee = currentUser() AND resolution = Unresolved order by updated DESC","isSystem":true,"sharePermissions":[],"requiresLogin":true},{"id":-2,"name":"Reported by me","jql":"reporter = currentUser() order by created DESC","isSystem":true,"sharePermissions":[],"requiresLogin":true},{"id":-4,"name":"All issues","jql":"order by created DESC","isSystem":true,"sharePermissions":[],"requiresLogin":false},{"id":-5,"name":"Open issues","jql":"resolution = Unresolved order by priority DESC,updated DESC","isSystem":true,"sharePermissions":[],"requiresLogin":false},{"id":-9,"name":"Done issues","jql":"statusCategory = Done order by updated DESC","isSystem":true,"sharePermissions":[],"requiresLogin":false},{"id":-3,"name":"Viewed recently","jql":"issuekey in issueHistory() order by lastViewed DESC","isSystem":true,"sharePermissions":[],"requiresLogin":false},{"id":-6,"name":"Created recently","jql":"created >= -1w order by created DESC","isSystem":true,"sharePermissions":[],"requiresLogin":false},{"id":-7,"name":"Resolved recently","jql":"resolutiondate >= -1w order by updated DESC","isSystem":true,"sharePermissions":[],"requiresLogin":false},{"id":-8,"name":"Updated recently","jql":"updated >= -1w order by updated DESC","isSystem":true,"sharePermissions":[],"requiresLogin":false}]
0.3
0