GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/1940
HOTFIX: recreate state.dir after cleanup
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka hotfix-resetTool
Alternatively you can
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/1992
KAFKA-4275: Check of State-Store-assignment to Processor-Nodes is not
enabled
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka kafka
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2039
HOTFIX: follow up on KAFKA-4275
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka hotfix-ktableLeftJoin
Alternatively you can review
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2049
[WIP] Do not merge
Opening PR to trigger travis build.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka improveResetTool
Alternatively
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2056
KAFAK-4058: Failure in
org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterReset
- fixed consumer group dead condition
- disabled state store cache
You
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2065
KAFKA-4302: Simplify KTableSource
KTableSource is always materialized since IQ:
- removed flag KTableSource#materialized
- removed MaterializedKTableSourceProcessor
You can merge this
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2068
MINOR: improve JavaDoc for Streams window retention time
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2076
HOTFIX: improve error message on invalid input record timestamp
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka hotfixTSExtractor
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2079
HOTFIX: improve error message on invalid input record timestamp
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka hotfixTSExtractor
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2080
KAFKA-4302: Simplify KTableSource
KTableSource is always materialized since IQ:
- removed flag KTableSource#materialized
- removed MaterializedKTableSourceProcessor
You can merge this
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2082
KAFKA-4352: instable ResetTool integration test
- increased timeout to stabelize test
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
Github user mjsax closed the pull request at:
https://github.com/apache/kafka/pull/2080
---
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 is
Github user mjsax closed the pull request at:
https://github.com/apache/kafka/pull/2079
---
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 is
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2909
MINOR: adding global store must ensure unique names
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka minor-fix-add-global-store
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2917
Kafka 5111 code cleanup follow up
- mainly moving methods
- also improved logging
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2931
KAFKA-5140: Flaky ResetIntegrationTest
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
kafka-5140-flaky-reset-integration-test
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2945
KAFKA-4923: Add Exactly-Once Semantics to Streams
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka kafka-4923-add-eos-to-streams
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2951
KAFKA-5126: Implement KIP-98 transactional methods in the MockProducer
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
kafka-5126
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2968
KAFKA-5169: KafkaConsumer.close should be idempotent
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka kafka-5169-consumer-close
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2974
KAFKA-4923: Add Exaclty-Once Semantics to Streams (testing)
- add broker compatibility system tests
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3001
KAFKA-5167: streams task gets stuck after re-balance due to LockException
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
kafka-5167
Github user mjsax closed the pull request at:
https://github.com/apache/kafka/pull/3001
---
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 is
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3077
KAFKA-4923: Add Streams EOS integration tests
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
kafka-4923-stream-eos-integration
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3104
MINOR: improve EmbeddedKafkaCluster test utility for deleting topics
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
minor-improve
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3107
MINOR: improve descriptions of Streams reset tool options
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka minor-reset-tool-options
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3134
Kafka-5315: should not subtract for empty key is KTable.aggregate/reduce
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
kafka-5315
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3140
KAFKA-5309: Stores not queryable after one thread died
- introduces a new thread state DEAD
- ignores DEAD threads when querying
You can merge this pull request into a Git repository by running
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3193
KAFKA-5361: Add EOS integration tests for Streams api
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
kafka-5361-add-eos-integration
Github user mjsax closed the pull request at:
https://github.com/apache/kafka/pull/3077
---
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 is
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3194
MINOR: update Streams docs for KIP-123
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka minor-update-docs-for-kip-123
Alternatively
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3201
KAFKA-5362: Add EOS system tests for Streams API
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
kafka-5362-add-eos-system-tests-for
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3232
MINOR: update docs with regard to KIP-123
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka minor-update-docs-for-kip-123
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3264
MINOR: improve JavaDocs for TimestampExtractor interface
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka minor-javadocs-timestamp
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3272
MINOR: disable flaky Streams EOS integration tests
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka minor-disable-eos-tests
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3273
HOTFIX: for flaky Streams EOS integration tests
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka hotfix-flaky-stream-eos-test
Github user mjsax closed the pull request at:
https://github.com/apache/kafka/pull/3272
---
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 is
GitHub user mjsax reopened a pull request:
https://github.com/apache/kafka/pull/3272
MINOR: disable flaky Streams EOS integration tests
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka minor-disable-eos-tests
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3276
KAFKA-5361: Add more integration tests for Streams EOS
- multi-subtopology tests
- fencing test
You can merge this pull request into a Git repository by running:
$ git pull https
201 - 238 of 238 matches
Mail list logo
