GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/4348
MINOR: Fix race condition in Streams EOS system test
We should start the process only within the `with` block, otherwise the
bytes parameter would cause a race condition that result in false
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/113
Merged to asf-site.
---
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/112
LGTM. Merged to asf-site.
---
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/4338
[WIP] MINOR: web docs for KIP-220
1. added functions for KafkaStreams and KafkaClientSupplier.
2. added prefix for admin client in StreamsConfig.
### Committer Checklist (excluded
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/4331
[WIP] MINOR: Improve Join integration test coverage, PART I
1. Merge `KStreamRepartitionJoinTest.java` into `JoinIntegrationTest.java`
with augmented stream-stream join.
2. Make
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/111
LGTM. Merged to asf-site.
---
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/4315
KAFKA-6150: KIP-204 part III; Change repartition topic segment size and ms
1. Create default internal topic configs in StreamsConfig, especially for
repartition topics change the segment size
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/4270
[WIP] KAFKA-6150: Purge repartition topics
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/4268
KAFKA-6274: Use topic plus dash as prefix of auto-generated state store
names
Use `topic-` as the prefix of the auto-generated state store name.
Also add a unit test
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/109
LGTM. Merged to asf-site.
---
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/4224
[WIP] KAFKA-6170; KIP-220 Part 2: Break dependency of Assignor on
StreamThread
This refactoring is discussed in
https://github.com/apache/kafka/pull/3624#discussion_r132614639. More
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/4211
[WIP] KAFKA-6170: Add AdminClient to Streams
1. Add The AdminClient into Kafka Streams, which is shared among all the
threads.
2. Refactored mutual dependency between
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/4208
MINOR: Not enough replica exception should never happen for delete records
When reviewing https://github.com/apache/kafka/pull/4132, I felt that
NOT_ENOUGH_REPLICAS should never happen
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/4186
[WIP] KAFKA-6179: Clear min timestamp tracker upon partition queue cleanup
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/guozhangwang
Github user guozhangwang closed the pull request at:
https://github.com/apache/kafka/pull/4085
---
Github user guozhangwang closed the pull request at:
https://github.com/apache/kafka/pull/4130
---
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/4184
MINOR: Remove FanoutIntegrationTest.java
This test has been completely subsumed by the coverage of reset integration
test, and hence can be removed.
You can merge this pull request into a Git
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/4171
MINOR: Change version format in release notes python code
@ijuma @ewencp
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/guozhangwang
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/4169
MINOR: Update docs for new version
1. Update the Streams hello world examples with the new API.
2. Update the version references in various places.
3. Update version templates to 1.1.x
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/107
Merged to asf-site
---
Github user guozhangwang commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/107#discussion_r148394602
--- Diff: 10/documentation.html ---
@@ -69,15 +69,15 @@
8. Kafka Connect
-9. Kafka
Streams
+9. Kafka
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/107
@ijuma addressed your comments.
Will submit another PR for kafka repo for the same necessary changes.
---
Github user guozhangwang commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/107#discussion_r148321476
--- Diff: downloads.html ---
@@ -9,48 +9,75 @@
You can verify your download by following these http://www.apache.org/info
Github user guozhangwang commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/107#discussion_r148321409
--- Diff: 10/documentation.html ---
@@ -0,0 +1,83 @@
+
+
+<!--#include virtual="js/templat
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka-site/pull/107
MINOR: Follow-up Update on 1.0.0 release
1. Replaced 100 folder with 10 folder.
2. Update Streams/index.html file with a couple follow-up PRs that went in
post RC4.
3. Add
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/105
LGTM. Merged to asf-site.
---
Github user guozhangwang commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/105#discussion_r147801292
--- Diff: 0110/streams/index.html ---
@@ -17,20 +17,20 @@
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/104
Merged to asf-site.
---
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/104
LGTM. Could you submit a PR for changes in ` 0110/streams` as well in
`kafka` repo?
---
Github user guozhangwang commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/104#discussion_r147261460
--- Diff: powered-by.html ---
@@ -2,453 +2,452 @@
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/4136
KAFKA-6100: Down-grade RocksDB to 5.7.3
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/guozhangwang/kafka
K6100-rocksdb-580-regression
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/4130
HOTFIX: Remove sysout logging
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/guozhangwang/kafka KHotfix-0110-remove-logging
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/103
LGTM. Merged to `asf-site`.
---
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/103
Could you submit a patch to `kafka` repo under `docs/streams/index.html` as
well?
---
Github user guozhangwang closed the pull request at:
https://github.com/apache/kafka/pull/4085
---
GitHub user guozhangwang reopened a pull request:
https://github.com/apache/kafka/pull/4085
HOTFIX: poll with zero millis during restoration
Mirror of #4096 for 0.11.01.
During the restoration phase, when thread state is still in
PARTITION_ASSIGNED not RUNNING yet, call
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/100
LGTM. Merged to asf-site.
---
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/4096
HOTFIX: Poll with zero milliseconds during restoration phase
1. After the poll call, re-check if the state has been changed or not; if
yes, initialize the tasks again.
2. Cherry-pick
Github user guozhangwang closed the pull request at:
https://github.com/apache/kafka/pull/4086
---
Github user guozhangwang closed the pull request at:
https://github.com/apache/kafka/pull/4086
---
GitHub user guozhangwang reopened a pull request:
https://github.com/apache/kafka/pull/4086
[WIP] KAFKA-6085: Pause all partitions before tasks are initialized
Mirror of #4085 against trunk. This PR contains two fixes (one major and
one minor):
Major: on rebalance, pause
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/4095
KAFKA-5140: Fix reset integration test
The MockTime was incorrectly used across multiple test methods within the
class, as a class rule. Instead we set it on each test case; also remove
Github user guozhangwang commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/100#discussion_r145530925
--- Diff: 0110/streams/index.html ---
@@ -82,26 +82,8 @@ The easiest way to write
mission-critical real-time ap
Streams API use cases
Github user guozhangwang commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/100#discussion_r145531542
--- Diff: 0110/streams/index.html ---
@@ -111,23 +93,41 @@ Streams API use cases
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/4086
HOTFIX: Normal poll with zero during restoration
Mirror of #4085 against trunk.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/4085
HOTFIX: poll with zero millis during restoration
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/guozhangwang/kafka KHotfix-0110-restore
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/98
LGTM. Merged to asf-site.
---
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/4071
MINOR: a few web doc and javadoc fixes
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/guozhangwang/kafka KMinor-javadoc-gaps
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/96
LGTM. Merged to `asf-site`.
---
Github user guozhangwang commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/96#discussion_r144150407
--- Diff: css/styles.css ---
@@ -1074,7 +1074,6 @@ nav .btn {
.sticky-top {
white-space: nowrap;
overflow-y: hidden
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/4054
HOTFIX: Updates on release.py before 1.0.0
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/guozhangwang/kafka KMinor-pre-1.0-release
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/95
LGTM. Merged to asf-site.
---
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/95
@manjuapu I cannot tell what's changed in the image, could you point it out
for me?
---
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/92
Merged to asf-site.
---
Github user guozhangwang commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/92#discussion_r143525624
--- Diff: 0110/streams/index.html ---
@@ -1,275 +1,311 @@
-
-<!--#include virtual="../js/templateData.js" -->
-
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/4036
MINOR: KIP-161 upgrade docs change
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/guozhangwang/kafka KMinor-kip-161-docs
Alternatively
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/4031
MINOR: log4j improvements on assigned tasks and store changelog reader
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/guozhangwang/kafka
Github user guozhangwang closed the pull request at:
https://github.com/apache/kafka/pull/3607
---
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/77
LGTM. Merged to asf-site.
---
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/85
Merged to trunk with some minor tweaks.
---
Github user guozhangwang commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/85#discussion_r140623361
--- Diff: 0110/streams/index.html ---
@@ -201,39 +201,41 @@ The easiest way to
write mission-critical real-tim
Github user guozhangwang commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/85#discussion_r140623385
--- Diff: 0110/streams/index.html ---
@@ -201,39 +201,41 @@ The easiest way to
write mission-critical real-tim
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/84
LGTM Merged to trunk.
---
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/83
LGTM. Merged to asf-site.
---
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/82
@manjuapu Only the PR submitter can close her own PRs unfortunately.
---
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/79
Some meta comments:
1. The `.DS_Store` should not be included.
2. As @ewencp mentioned, these files under `0110/` should be in `kafka`
repo as well. You would need to file
Github user guozhangwang commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/77#discussion_r139275915
--- Diff: index.html ---
@@ -7,17 +7,17 @@
Publish subscribe
Github user guozhangwang commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/77#discussion_r139275946
--- Diff: index.html ---
@@ -7,17 +7,17 @@
Publish subscribe
Github user guozhangwang commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/77#discussion_r139275996
--- Diff: index.html ---
@@ -7,17 +7,17 @@
Publish subscribe
Github user guozhangwang commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/77#discussion_r139275998
--- Diff: includes/_nav.htm ---
@@ -11,6 +11,12 @@
getting started
APIs
kafka streams
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/3850
MINOR: Un-hide the tutorial buttons on web docs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/guozhangwang/kafka KMinor-unhide-button
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/3819
[DO NOT MERGE] KAFKA-5576: RocksDB upgrade to 5.7.3
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/guozhangwang/kafka KMinor-rocksDB-573
Github user guozhangwang closed the pull request at:
https://github.com/apache/kafka/pull/3806
---
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/3796
MINOR: KIP-138 renaming of string names
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/guozhangwang/kafka kip-138-minor-renames
Github user guozhangwang closed the pull request at:
https://github.com/apache/kafka/pull/3771
---
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/73
LGTM. Merged to `asf-site`.
---
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/3771
MINOR: logging improvements
This is a manual cherry-pick of https://github.com/apache/kafka/pull/3769
for 0.11.0
You can merge this pull request into a Git repository by running:
$ git
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/3769
MINOR: Log encountered exception during rebalance
Some other minor changes:
1. Do not throw the exception form callback as it would only be swallowed
by consumer coordinator
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/72
LGTM.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/3757
KAFKA-5379 follow up: reduce redundant mock processor context
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/guozhangwang/kafka K5379
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/3748
KAFKA-5797: Delay checking of partition existence in StoreChangelogReader
1. Remove timeout-based validatePartitionExists from StoreChangelogReader;
instead only try to refresh metadata once
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/3746
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
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/63
Merged to asf-site.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/56
@wushujames This is already resolved, could you close this PR?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/3733
[WIP] MINOR: KIP-160 docs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/guozhangwang/kafka KMinor-kip160-docs
Alternatively you can
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/3732
MINOR: doc changes for KIP-138
1. Core concepts (added the stream time definition), upgrade guide and
developer guide.
2. Related Java docs changes.
You can merge this pull request
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/3720
[DO NOT MERGE] KAFKA-3705: non-key joins
This is just for reviewing the diff easily to see how it is done by
@jfillipiak.
You can merge this pull request into a Git repository by running
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/3713
MINOR: simplify state transition for Kafka Streams and stream threads
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/guozhangwang/kafka
Github user guozhangwang closed the pull request at:
https://github.com/apache/kafka/pull/3660
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/3687
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.
You can merge this pull request
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/3681
KAFKA-5733: RocksDB bulk load with lower number of levels.
This is to complete Bill's PR on KAFKA-5733, incorporating the suggestion
in https://github.com/facebook/rocksdb/issues/2734
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/3660
KAFKA-5727: Archetype project for Streams quickstart and tutorial web docs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/guozhangwang
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/70
LGTM. Merged to `asf-site`.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/3630
MINOR: 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
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/3618
KAFKA-5698: Sort processor nodes based on its sub-tree size
1. Sort processor nodes within a sub-topology by its sub-tree size: nodes
with largest sizes are source nodes and hence printed
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/3617
HOTFIX add the hyper link for storage
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/guozhangwang/kafka
KHotfix-introduction-hyperlink
Github user guozhangwang commented on the issue:
https://github.com/apache/kafka-site/pull/69
LGTM. Merged to asf-site.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/3607
[DO NOT MERGE] Existing StreamThread exception handling issues
This is for @dguy as a reference while working on the first step of
KAFKA-5152, as a list of existing issues that need
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/3603
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
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/3574
HOTFIX: handle commit failed exception on stream thread's suspend task
1. Capture `CommitFailedException` in `StreamThread#suspendTasksAndState`;
also fix log4j outputs for error and warn
1 - 100 of 341 matches
Mail list logo
