src-kafka

Commit Graph

Author	SHA1	Message	Date
Manjula K	1fd70c7c94	MINOR - Adding New York Times logo to streams page Author: Manjula K <manjula@kafka-summit.org> Author: manjuapu <manjula@confluent.io> Reviewers: Guozhang Wang <wangguoz@gmail.com> Closes #3950 from manjuapu/customer-logo-stream	7 years ago
Manjula K	36afd1095c	MINOR: Adding LINE corp logo to streams page Author: Manjula K <manjula@kafka-summit.org> Author: manjuapu <manjula@confluent.io> Reviewers: Guozhang Wang <wangguoz@gmail.com> Closes #3940 from manjuapu/customer-logo-stream	7 years ago
Damian Guy	f29391c490	MINOR: add upgrade note for KIP-173 topic configs Author: Damian Guy <damian.guy@gmail.com> Reviewers: Matthias J. Sax <matthias@confluent.io>, Guozhang Wang <wangguoz@gmail.com> Closes #3921 from dguy/minor-kip-173-docs	7 years ago
manjuapu	c82be0f303	MINOR: Adding See how Kafka Streams is being used section to Streams page Author: manjuapu <manjula@confluent.io> Author: Manjula K <manjula@kafka-summit.org> Reviewers: Ewen Cheslack-Postava <ewen@confluent.io> Closes #3914 from manjuapu/customer-logo-stream	7 years ago
Florian Hussonnois	398714b758	KAFKA-5839: Upgrade Guide doc changes for KIP-130 Author: Florian Hussonnois <florian.hussonnois@gmail.com> Reviewers: Matthias J. Sax <matthias@confluent.io>, Guozhang Wang <wangguoz@gmail.com> Closes #3811 from fhussonnois/KAFKA-5839 minor fixes	7 years ago
Jakub Scholz	a64fe2ed88	KAFKA-5918: Fix minor typos and errors in the Kafka Streams turotial I found several minor issues with the Kafka Streams tutorial: * Some typos * "As shown above, it illustrate that the constructed ..." instead of "As shown above, it illustrate_s_ that the constructed ..." * "same as Pipe.java below" instead of "same as Pipe.java _above_" * Wrong class name in the `LineSplit` example * Incorrect imports for the code examples * Missing `import org.apache.kafka.streams.kstream.KStream;` in `LineSplit` and `WordCount` example * Unnecessary (and potentially confusing) split by whitespaces in the `WorkCount` class (the split into words happened already in `LineSplit`) Author: Jakub Scholz <www@scholzj.com> Reviewers: Matthias J. Sax <matthias@confluent.io>, Guozhang Wang <wangguoz@gmail.com> Closes #3883 from scholzj/stream-tutorial-typos	7 years ago
Damian Guy	f7b1add686	MINOR: update tutorial doc to match ak-site Author: Damian Guy <damian.guy@gmail.com> Reviewers: Guozhang Wang <wangguoz@gmail.com> Closes #3847 from dguy/minor-doc-update	7 years ago
Guozhang Wang	9d2437a464	MINOR: Un-hide the tutorial buttons on web docs Author: Guozhang Wang <wangguoz@gmail.com> Reviewers: Damian Guy <damian.guy@gmail.com> Closes #3850 from guozhangwang/KMinor-unhide-button	7 years ago
Damian Guy	2db1e4423f	KAFKA-5852: Add filter, filterNot, mapValues and Materialized to KTable Add overloads of `filter`, `filterNot`, `mapValues` that take `Materialized` as a param to `KTable`. Deprecate overloads using `storeName` and `storeSupplier` Author: Damian Guy <damian.guy@gmail.com> Reviewers: Matthias J. Sax <matthias@confluent.io>, Guozhang Wang <wangguoz@gmail.com> Closes #3807 from dguy/ktable-filter-map	7 years ago
Damian Guy	4769e3d92a	KAFKA-5815; add Printed class and KStream#print(printed) Part of KIP-182 - Add `Printed` class and `KStream#print(Printed)` - deprecate all other `print` and `writeAsText` methods Author: Damian Guy <damian.guy@gmail.com> Reviewers: Bill Bejeck <bill@confluent.io>, Matthias J. Sax <matthias@confluent.io>, Guozhang Wang <wangguoz@gmail.com> Closes #3768 from dguy/kafka-5652-printed	7 years ago
Damian Guy	e16b9143df	KAFKA-5853; implement WindowedKStream Add the `WindowedKStream` interface and implementation of methods that don't require `Materialized` Author: Damian Guy <damian.guy@gmail.com> Reviewers: Bill Bejeck <bill@confluent.io>, Matthias J. Sax <matthias@confluent.io>, Guozhang Wang <wangguoz@gmail.com> Closes #3809 from dguy/kgrouped-stream-windowed-by	7 years ago
Damian Guy	d0ee6ed36b	KAFKA-5832; add Consumed and change StreamBuilder to use it Added `Consumed` class. Updated `StreamBuilder#stream`, `StreamBuilder#table`, `StreamBuilder#globalTable` Author: Damian Guy <damian.guy@gmail.com> Reviewers: Matthias J. Sax <matthias@confluent.io>, Guozhang Wang <wangguoz@gmail.com> Closes #3784 from dguy/kip-182-stream-builder	7 years ago
Damian Guy	9cbb9f0939	KAFKA-5650; add StateStoreBuilder interface and implementations Part of KIP-182 - Add `StateStoreBuilder` interface and `WindowStateStoreBuilder`, `KeyValueStateStoreBuilder`, and `SessionStateStoreBuilder` implementations - Add `StoreSupplier`, `WindowBytesStoreSupplier`, `KeyValueBytesStoreSupplier`, `SessionBytesStoreSupplier` interfaces and implementations - Add new methods to `Stores` to create the newly added `StoreSupplier` and `StateStoreBuilder` implementations - Update `Topology` and `InternalTopology` to use the interfaces Author: Damian Guy <damian.guy@gmail.com> Reviewers: Bill Bejeck <bill@confluent.io>, Matthias J. Sax <matthias@confluent.io>, Guozhang Wang <wangguoz@gmail.com> Closes #3767 from dguy/kafka-5650	7 years ago
Damian Guy	667cd60dc6	KAFKA-5816; add Produced class, KStream#to(topic, Produced), and KStream#through(topic, Produced) Add the `Produced` class and `KStream` overloads that use it: `KStream#to(String, Produced)` `KStream#through(String, Produced)` Deprecate all other to and through methods accept the single param methods that take a topic param Author: Damian Guy <damian.guy@gmail.com> Reviewers: Bill Bejeck <bill@confluent.io>, Matthias J. Sax <matthias@confluent.io>, Guozhang Wang <wangguoz@gmail.com> Closes #3770 from dguy/kafka-5652-produced	7 years ago
Boyang Chen	b041c8d87d	MINOR: close iterator on doc example The iterator interface usage has some examples missing explicit close operation after usage. We should remind the user to do so because un-closed iterator will leave the underlying file descriptor open, thus eating up memory. guozhangwang Ishiihara Author: Boyang Chen <bychen@pinterest.com> Author: Boyang Chen <bchen11@outlook.com> Reviewers: Guozhang Wang <wangguoz@gmail.com> Closes #3714 from abbccdda/add_iterator_close_on_doc minor fixes	7 years ago
Guozhang Wang	9b85cf9ed0	MINOR: KIP-138 renaming of string names Author: Guozhang Wang <wangguoz@gmail.com> Reviewers: Bill Bejeck <bill@confluent.io>, Matthias J. Sax <matthias@confluent.io>, Damian Guy <damian.guy@gmail.com> Closes #3796 from guozhangwang/kip-138-minor-renames	7 years ago
Matthias J. Sax	212bce6e3f	MINOR: fix typos on web doc's upgrade guide Author: Matthias J. Sax <matthias@confluent.io> Reviewers: Guozhang Wang <wangguoz@gmail.com> Closes #3804 from mjsax/hotfix	7 years ago
Damian Guy	b687c06800	KAFKA-5817; Add Serialized class and overloads to KStream#groupBy and KStream#groupByKey Part of KIP-182 - Add the `Serialized` class - implement overloads of `KStream#groupByKey` and KStream#groupBy` - deprecate existing methods that have more than default arguments Author: Damian Guy <damian.guy@gmail.com> Reviewers: Bill Bejeck <bill@confluent.io>, Matthias J. Sax <matthias@confluent.io>, Guozhang Wang <wangguoz@gmail.com> Closes #3772 from dguy/kafka-5817	7 years ago
Matthias J. Sax	cd59976eea	KAFKA-5823: Extend upgrade section for KIP-120 Author: Matthias J. Sax <matthias@confluent.io> Reviewers: Sharon Liu <sharonliu.cup@gmail.com>, Damian Guy <damian.guy@gmail.com>, Guozhang Wang <wangguoz@gmail.com> Closes #3787 from mjsax/kafka-5823-kip120-docs	7 years ago
Eno Thereska	493c2aad59	MINOR: add table of contents Added a simple table of contents for the developer section. Author: Eno Thereska <eno.thereska@gmail.com> Reviewers: Damian Guy <damian.guy@gmail.com> Closes #3760 from enothereska/minor-docs-toc	7 years ago
Guozhang Wang	ce04b14358	MINOR: KIP-160 docs Author: Guozhang Wang <wangguoz@gmail.com> Reviewers: Damian Guy <damian.guy@gmail.com> Closes #3733 from guozhangwang/KMinor-kip160-docs	7 years ago
Guozhang Wang	f5310d645c	MINOR: doc changes for KIP-138 1. Core concepts (added the stream time definition), upgrade guide and developer guide. 2. Related Java docs changes. Author: Guozhang Wang <wangguoz@gmail.com> Reviewers: Bill Bejeck <bill@confluent.io>, Damian Guy <damian.guy@gmail.com> Closes #3732 from guozhangwang/KMinor-kip138-docs	7 years ago
Eno Thereska	bd54d2e3e0	MINOR: stateful docs for aggregates Author: Eno Thereska <eno.thereska@gmail.com> Reviewers: Damian Guy <damian.guy@gmail.com> Closes #3730 from enothereska/minor-docs-aggregates	7 years ago
Michal Borowiecki	5648dcc3e5	MINOR: Fix doc typos and grammar This is contributed by mihbor on various doc fixes including: https://github.com/apache/kafka/pull/3224 https://github.com/apache/kafka/pull/3226 https://github.com/apache/kafka/pull/3229 Author: Guozhang Wang <wangguoz@gmail.com> Reviewers: Guozhang Wang <wangguoz@gmail.com> Closes #3746 from guozhangwang/KMinor-doc-typos	7 years ago
Guozhang Wang	21fea170d8	MINOR: add upgrade section for 1.0.0 1. Add upgrade section for 1.0.0, including Streams API changes section. 2. Add metrics name changes section. Author: Guozhang Wang <wangguoz@gmail.com> Reviewers: Eno Thereska <eno.thereska@gmail.com>, Damian Guy <damian.guy@gmail.com> Closes #3687 from guozhangwang/KMinor-metrics-upgrade-guide	7 years ago
Eno Thereska	5e65c0da45	MINOR: Stateless transformation documentation Needs to come after https://github.com/apache/kafka/pull/3701 Originally reviewed as part of #3490. Author: Eno Thereska <eno.thereska@gmail.com> Reviewers: Damian Guy <damian.guy@gmail.com> Closes #3711 from enothereska/minor-docs-stateless	7 years ago
Eno Thereska	ecea150bde	MINOR: Document how to create source streams and tables Originally reviewed as part of https://github.com/apache/kafka/pull/3490. Author: Eno Thereska <eno.thereska@gmail.com> Reviewers: Damian Guy <damian.guy@gmail.com> Closes #3701 from enothereska/minor-docs-create-source-streams	7 years ago
Guozhang Wang	b6102cf4b2	HOTFIX: missing imports and version on web docs	7 years ago
Guozhang Wang	d2774e302f	KAFKA-5727: Add Streams quickstart tutorial as an archetype project 0. Minor fixes on the existing examples to merge all on a single input topic; also do not use `common.utils.Exit` as it is for internal usage only. 1. Add the archetype project for the quickstart. Steps to try it out: a. `mvn install` on the quickstart directory. b. `mvn archetype:generate \ -DarchetypeGroupId=org.apache.kafka \ -DarchetypeArtifactId=streams-quickstart-java \ -DarchetypeVersion=1.0.0-SNAPSHOT \ -DgroupId=streams-quickstart \ -DartifactId=streams-quickstart \ -Dversion=0.1 \ -Dpackage=StreamsQuickstart \ -DinteractiveMode=false` at any directory to create the project. c. build the streams jar with version `1.0.0-SNAPSHOT` to local maven repository with `./gradlew installAll`; `cd streams-quickstart; mvn clean package` d. create the input / output topics, start the console producer and consumer. e. start the program: `mvn exec:java -Dexec.mainClass=StreamsQuickstart.Pipe/LineSplit/WordCount`. f. type data on console producer and observe data on console consumer. Author: Guozhang Wang <wangguoz@gmail.com> Reviewers: Damian Guy <damian.guy@gmail.com>, Bill Bejeck <bbejeck@gmail.com>, Ewen Cheslack-Postava <me@ewencp.org>, Eno Thereska <eno.thereska@gmail.com> Closes #3630 from guozhangwang/KMinor-streams-quickstart-tutorial	7 years ago
Bill Bejeck	b2b529522d	MINOR: First cut at porting State Store docs to AK Author: Bill Bejeck <bill@confluent.io> Reviewers: Eno Thereska <eno.thereska@gmail.com>, Damian Guy <damian.guy@gmail.com> Closes #3629 from bbejeck/docs-updates-for-kip-167	7 years ago
Damian Guy	2010aa067f	MINOR: add memory management section to streams docs Author: Damian Guy <damian.guy@gmail.com> Reviewers: Guozhang Wang <wangguoz@gmail.com>, Eno Thereska <eno.thereska@gmail.com> Closes #3604 from dguy/memory-management-docs	7 years ago
Guozhang Wang	125d69caee	KAFKA-5671 Followup: Remove reflections in unit test classes 1. Remove rest deprecation warnings in streams:jar. 2. Consolidate all unit test classes' reflections to access internal topology builder from packages other than `o.a.k.streams`. We need to refactor the hierarchies of StreamTask, StreamThread and KafkaStreams to remove these hacky reflections. 3. Minor fixes such as reference path, etc. 4. Minor edits on web docs for the describe function under developer-guide. Author: Guozhang Wang <wangguoz@gmail.com> Reviewers: Bill Bejeck <bill@confluent.io>, Ismael Juma <ismael@juma.me.uk>, Damian Guy <damian.guy@gmail.com> Closes #3603 from guozhangwang/K5671-followup-comments	7 years ago
Matthias J. Sax	da2205578b	KAFKA-5671: Add StreamsBuilder and Deprecate KStreamBuilder Author: Matthias J. Sax <matthias@confluent.io> Reviewers: Damian Guy <damian.guy@gmail.com>, Bill Bejeck <bill@confluent.io>, Guozhang Wang <wangguoz@gmail.com> Closes #3602 from mjsax/kafka-5671-add-streamsbuilder	7 years ago
Matthias J. Sax	1844bf2b2f	KAFKA-5670: (KIP-120) Add Topology and deprecate TopologyBuilder Author: Matthias J. Sax <matthias@confluent.io> Reviewers: Damian Guy <damian.guy@gmail.com>, Bill Bejeck <bill@confluent.io>, Guozhang Wang <wangguoz@gmail.com> Closes #3590 from mjsax/kafka-3856-replace-topology-builder-by-topology	7 years ago
Guozhang Wang	91c207c2c6	MINOR: Make streams quick start more interactive 1. Make the WordCountDemo application to not stop automatically but via "ctrl-C". 2. Update the quickstart html file to let users type input messages one-by-one, and observe added output in an interactive manner. 3. Some minor fixes on the parent documentation page pointing to streams sub-pages, added a new recommended Scala version number. Author: Guozhang Wang <wangguoz@gmail.com> Reviewers: Michael G. Noll <michael@confluent.io>, Damian Guy <damian.guy@gmail.com> Closes #3515 from guozhangwang/KMinor-interactive-quickstart	7 years ago
Derrick Or	300f48018c	MINOR: Add Streams landing page Content and assets for the updated Streams API landing page Author: Derrick Or <derrickor@gmail.com> Reviewers: Michael G. Noll <michael@confluent.io>, Guozhang Wang <wangguoz@gmail.com> Closes #3540 from derrickdoo/streams-landing-page	7 years ago
Damian Guy	1110f66fa7	KAFKA-3741; allow users to specify default topic configs for internal topics Allow users to specify default topic configs for streams internal topics by supplying properties from `TopicConfig` with a prefix. Supplied defaults are used when creating the internal topics. They are overridden by the configs supplied along with the `InternalTopicConfig` Author: Damian Guy <damian.guy@gmail.com> Reviewers: Matthias J. Sax <matthias@confluent.io>, Guozhang Wang <wangguoz@gmail.com> Closes #3459 from dguy/kafka-3741	7 years ago
Guozhang Wang	6a5cd67b9b	HOTFIX: fix a few typos on streams quickstart Author: Guozhang Wang <wangguoz@gmail.com> Reviewers: Eno Thereska <eno.thereska@gmail.com>, Damian Guy <damian.guy@gmail.com> Closes #3510 from guozhangwang/KHotfix-streams-quickstart	7 years ago
Eno Thereska	7bfe008ae1	MINOR: Move quickstart under streams Author: Eno Thereska <eno.thereska@gmail.com> Reviewers: Michael G. Noll <michael@confluent.io>, Damian Guy <damian.guy@gmail.com>, Guozhang Wang <wangguoz@gmail.com> Closes #3494 from enothereska/minor-quickstart-docs rename section name and bold font for section names	7 years ago
Damian Guy	75f1b757e1	HOTFIX: fix paths in streams index Author: Damian Guy <damian.guy@gmail.com> Reviewers: Ismael Juma <ismael@juma.me.uk> Closes #3502 from dguy/doc-fixes	7 years ago
Damian Guy	6cae5ec668	MINOR: add IQ docs to streams documentation Author: Damian Guy <damian.guy@gmail.com> Reviewers: Matthias J. Sax <matthias@confluent.io>, Guozhang Wang <wangguoz@gmail.com> Closes #3484 from dguy/iq-doc	7 years ago
Guozhang Wang	2c6e9a9653	MINOR: Follow-up Streams doc changes to break into sub-pages Also fixed a bunch of broken links (details can be found in `34f8ecea0d`) Author: Guozhang Wang <wangguoz@gmail.com> Reviewers: Eno Thereska <eno.thereska@gmail.com>, Bill Bejeck <bbejeck@gmail.com>, Damian Guy <damian.guy@gmail.com> Closes #3473 from guozhangwang/KMinor-streams-doc-breakdown	7 years ago

42 Commits (1fd70c7c94b20b82299ac1004e0ee01777b7beab)