guozhangwang
Follow
guozhangwang
Follow
Achievements
Achievements
Popular repositories
-
Forked from manuzhang/awesome-streaming
a curated list of awsome streaming frameworks, applications, etc
-
Forked from confluentinc/kafka-streams-examples
Demo applications and code examples for Apache Kafka's Streams API.
-
-
-
-
549 contributions in the last year
Less
More
Activity overview
Contribution activity
July 2021
Created 4 commits in 1 repository
Created a pull request in apache/kafka that received 32 comments
MINOR: Default GRACE with Old API should set as 24H minus window-size / inactivity-gap
Committer Checklist (excluded from commit message) Verify design and implementation Verify test coverage and CI build status Verify documentati…
+44
−13
•
32
comments
Opened 2 other pull requests in 1 repository
Reviewed 29 pull requests in 3 repositories
confluentinc/ksql 14 pull requests
- feat: shared runtimes
- chore: improve error message for pull query failure
- docs: add changelog for 0.20
- Refactor pull query execution
- chore: suppress EI_EXPOSE_REP on PersistentQueryCleanupImpl
- feat: add storage utilization metrics
- POC: Pull Queries over Streams
- feat: Add implementation of MetricsReporter for Confluent's telemetry
- feat: make SchemaRegistry permission validations on KSQL requests
- feat: add interface for metrics reporter
- feat: don't start queries when corruption is detected during startup
- feat: add observability metric skeleton
- [KCI-612] Clean up a terminated query's state stores
- feat: pull query bandwidth based throttling
apache/kafka 14 pull requests
- KAFKA-12648: Pt. 2 - Introduce TopologyMetadata to wrap InternalTopologyBuilders of named topologies
- KAFKA-13099; Transactional expiration should account for max batch size
- MINOR: Add test to verify behavior of grace API
- MINOR: remove unneeded comments to avoid misleading message
- KAFKA-13021: clarify KIP-633 javadocs and address remaining feedback
- KAFKA-13008: Try to refresh end offset when partitionLag returns empty
- MINOR: reduce debug log spam and busy loop during shutdown
- KAFKA-13094: Session windows do not consider user-specified grace when computing retention time for changelog
- MINOR: Add test for verifying retention on changelog topics
- HOTFIX: Init stream-stream left/outer join emit interval correctly
- KAFKA-10847: Remove internal config for enabling the fix
- MINOR: Default GRACE with Old API should set as 24H minus window-size / inactivity-gap
- KAFKA-12984: make AbstractStickyAssignor resilient to invalid input, utilize generation in cooperative, and fix assignment bug
- KAFKA-12983: reset needsJoinPrepare flag before rejoining the group
confluentinc/kafka 1 pull request
Created an issue in confluentinc/ksql that received 2 comments
Consider making retries in CommandRunner configurable
Today we always pass in Integer.MAX_VALUE all the way down to CommandRunner, which would be used as executeStatement:
RetryUtil.retryWithBackoff( m…
2
comments