root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 3 Packages Projects Releases Wiki Activity
5,890 Commits 84 Branches 277 Tags 602 MiB
Commit Graph

18 Commits

Author SHA1 Message Date
A. Sophie Blee-Goldman ff603c63bb KAFKA-4730: Streams does not have an in-memory windowed store (#6239) 
Implemented an in-memory window store allowing for range queries. A finite retention period defines how long records will be kept, ie the window of time for fetching, and the grace period defines the window within which late-arriving data may still be written to the store.

Unit tests were written to test the functionality of the window store, including its insert/update/delete and fetch operations. Single-record, all records, and range fetch were tested, for both time ranges and key ranges. The logging and metrics for late-arriving (dropped)records were tested as well as the ability to restore from a changelog.

Reviewers: John Roesler <john@confluent.io>, Matthias J. Sax <matthias@confluent.io>, Bill Bejeck <bill@confluent.io>, Guozhang Wang <wangguoz@gmail.com>
 2019-02-20 19:09:50 -08:00
John Roesler 8ae985705f KAFKA-7768: Use absolute paths for javadoc (#6100) 
Reviewers: Guozhang Wang <wangguoz@gmail.com>
 2019-01-07 13:30:49 -08:00
slim 6a20e3cd4c KAFKA-7768: Add version to java html urls (#6094) 
Reviewers: Guozhang Wang <wangguoz@gmail.com>
 2019-01-07 09:21:33 -08:00
Matthias J. Sax 0b417b8331
MINOR: updates docs for KIP-358 (#5796) 
Reviewers: Guozhang Wang <guozhang@confluent.io>, Jim Galasyn <jim.galasyn@confluent.io>
 2018-10-15 17:22:03 -07:00
Bill Bejeck 862e09f994 HOTFIX: Fix broken links (#5676) 
Reviewers: Joel Hamill <11722533+joel-hamill@users.noreply.github.com>, Guozhang Wang <wangguoz@gmail.com>
 2018-10-03 18:27:15 -07:00
Guozhang Wang 7bd8ada8e2
MINOR: Docs on state store instantiation (#5698) 
Reviewers: Bill Bejeck <bill@confluent.io>, Matthias J. Sax <matthias@confluent.io>
 2018-10-03 11:20:47 -07:00
Guozhang Wang 2d877631cd
MINOR: web docs fixes on message header (#5381) 
Reviewers: Matthias J. Sax <matthias@confluent.io>
 2018-07-17 17:31:32 -07:00
Jorge Quilcate Otoya e8ddb76573 KAFKA-6938: Add documentation for accessing Headers on Kafka Streams Processor API (#5128) 
Reviewers: Guozhang Wang <wangguoz@gmail.com>
 2018-06-04 15:39:20 -07:00
Guozhang Wang f33e9a346e KAFKA-4936: Add dynamic routing in Streams (#5018) 
implements KIP-303

Reviewers: Bill Bejeck <bill@confluent.io>, John Roesler <john@confluent.io>, Matthias J. Sax <matthias@confluent.io>
 2018-05-30 11:54:53 -07:00
David Glasser e9154b7960 KAFKA-6905: Document that Processors may be re-used by Streams (#5022) 
Reviewers: Guozhang Wang <wangguoz@gmail.com>
 2018-05-16 13:10:21 -07:00
John Roesler adbf31ab1d KAFKA-6473: Add MockProcessorContext to public test-utils (#4736) 
Reviewers: Matthias J. Sax <matthias@confluent.io>, Guozhang Wang <guozhang@confluent.io>, Bill Bejeck <bill@confluent.io>
 2018-03-27 14:03:24 -07:00
Matthias J. Sax 394aa74261
KAFKA-6454: Allow timestamp manipulation in Processor API (#4519) 
Reviewers: Bill Bejeck <bill@confluent.io>, Damian Guy <damian@confluent.io>, Guozhang Wang <guozhang@confluent.io>
 2018-03-16 16:02:11 -07:00
Matthias J. Sax 0c00aa0983
MINOR: Streams doc example should not close store (#4667) 
Author: Matthias J. Sax <matthias@confluent.io>

Reviewers: Bill Bejeck <bill@confluent.io>, Guozhang Wang <guozhang@confluent.io>
 2018-03-13 00:42:40 -07:00
Guozhang Wang 077fd9ced3
HOTFIX: Fix broken javadoc links on web docs(#4543) 
Reviewers: Matthias J. Sax <matthias@confluent.io>
 2018-02-08 09:31:58 -08:00
Yu f6bbec4af2 KAFKA-6354: Update KStream JavaDoc using new State Store API (#4456) 
Updates KStream JavaDoc and web page documentations using new State Store API

Author: Yu Liu <yu.liu003@gmail.com>

Reviewers: Guozhang Wang <guozhang@confluent.io>, Matthias J. Sax <matthias@confluent.io>
 2018-02-02 11:24:20 -08:00
Joel Hamill 6ea53d22e2 MINOR: Fix some streams web doc nits (#4411) 
Reviewers: Derrick Or <derrickor@gmail.com>, Guozhang Wang <wangguoz@gmail.com>
 2018-01-29 10:09:32 -08:00
Joel Hamill 26270983cd MINOR: Fix menu ordering in streams docs 
https://issues.apache.org/jira/browse/KAFKA-6419

Related: https://github.com/apache/kafka-site/pull/115

Author: Joel Hamill <joel-hamill@users.noreply.github.com>

Reviewers: Guozhang Wang <wangguoz@gmail.com>

Closes #4390 from joel-hamill/fix-streams-menu-order
 2018-01-08 11:43:38 -08:00
Joel Hamill 3e2fe17c08 MINOR: Improve Streams Dev Guide content on web docs 
This PR migrates content from CP Streams Dev Guide.

Here is the top-level page:
![image](https://user-images.githubusercontent.com/11722533/33904945-df9cf804-df31-11e7-93aa-52385961522c.png)

Here is a child page:
![image](https://user-images.githubusercontent.com/11722533/33904976-f2eafabe-df31-11e7-918c-fbf95db0f76b.png)

See related: https://github.com/apache/kafka-site/pull/112

Author: Joel Hamill <joel-hamill@users.noreply.github.com>

Reviewers: Guozhang Wang <wangguoz@gmail.com>

Closes #4252 from joel-hamill/20171122-migrate-cp-dev-guide
 2017-12-21 11:15:54 -08:00