GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/1450
HOTFIX: updated JavaDoc example for 0.9 tech-prev to 0.10
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka hotfix
Alternatively you
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/1517
[Kafka Streams] Clean-up script [WIP]
Anyof: @guozhangwang @enothereska @dguy @miguno
Two variants:
1. python client + bash script (seems not to be the right way, due to
external
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/1529
Kafka-3880: Disallow Join Window with size zero
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka kafka-3880-join-windows
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/954
[MINOR] Fixed documenation of parameter "block.on.buffer.full"
default value is "false" and not "true"
See:
https://stackoverflow.com/questions/35578519/kafk
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/1180
[KAFKA-3477] [Kafka Streams] extended KStream/KTable API to specify câ¦
â¦ustom partitioner for sinks
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/1181
[TRIVIAL] fix typo in JavaDoc
I could also include this in https://github.com/apache/kafka/pull/1180
(just wanted to keep PR-1180 "clean")
You can merge this pull request into a Git
Github user mjsax closed the pull request at:
https://github.com/apache/kafka/pull/1181
---
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 mjsax opened a pull request:
https://github.com/apache/kafka/pull/1266
KAKFA-3599: Minor code cleanup
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka kafka-3599-minorCodeCleanup
Alternatively you can
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/1287
KAFKA-3440: update JavaDoc
- add class doc for KTable, KStream, JoinWindows
- add missing @return tags
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/1231
KAFKA-3337: [WIP] Extract selector as a separate groupBy operator for
KTable aggregations
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/1250
KAFKA-3598: Improve JavaDoc of public API
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka JavaDoc-publicAPI
Alternatively you can
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/1673
Hotfix: fixed instable Streams application reset integration test
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka hotfix
Github user mjsax closed the pull request at:
https://github.com/apache/kafka/pull/1673
---
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 mjsax opened a pull request:
https://github.com/apache/kafka/pull/1685
hotfix: move streams application reset tool from tools to core
=> required to remove core dependency from tools
You can merge this pull request into a Git repository by running:
$ git pull ht
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/1671
KAFKA-3185: [Streams] Added Kafka Streams Application Reset Tool
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka resetTool-0.10.0.1
Github user mjsax closed the pull request at:
https://github.com/apache/kafka/pull/1671
---
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 mjsax opened a pull request:
https://github.com/apache/kafka/pull/1636
KAFKA-3185: Allow users to cleanup internal Kafka Streams data
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka kafka-3185
Github user mjsax closed the pull request at:
https://github.com/apache/kafka/pull/1517
---
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 mjsax opened a pull request:
https://github.com/apache/kafka/pull/1575
hotfix: check join window boundaries
@guozhangwang
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka hotfix2
Alternatively you can
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/1573
hotfix: check join window boundaries
@guozhangwang Might need to rebase after
https://github.com/apache/kafka/commit/b669b2786c69d2dfa719033eb7c02ac444f115f4
got dropped...
You can merge this pull
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/1580
Hotfix: auto-repartitioing for merge and code simplication
follow-up to auto-through feature:
- add sourceNode to transform()
- enable auto-repartitioning in merge()
- null check
GitHub user mjsax reopened a pull request:
https://github.com/apache/kafka/pull/2461
MINOR: added upgrade and API changes to docs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka addStreamsUpdateSecton
Alternatively
Github user mjsax closed the pull request at:
https://github.com/apache/kafka/pull/2461
---
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 mjsax opened a pull request:
https://github.com/apache/kafka/pull/2492
HOTFIX: update incorrect docs and broken links
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka hotfixDocs
Alternatively you can
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2497
[MINOR] fixed some JavaDoc typos
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka hofixJavaDocs0102
Alternatively you can review
Github user mjsax closed the pull request at:
https://github.com/apache/kafka/pull/2497
---
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 mjsax opened a pull request:
https://github.com/apache/kafka/pull/2428
HOTIFX: streams system test do not start up correctly
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka hotfixSystemTests
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2468
KAFKA-4613: Follow-up to fix JavaDocs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka kafka-4613-null-keys-follow-up
Alternatively
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2461
MINOR: added upgrade and API changes to docs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka addStreamsUpdateSecton
Alternatively
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2462
MINOR: JavaDoc markup cleanup
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka javaDocImprovements9
Alternatively you can review
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2437
MINOR: Streams API JavaDoc improvements
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka javaDocImprovements7
Alternatively you can
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2438
MINOR: update KTable JavaDoc
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka ktableJavaDocs
Alternatively you can review and apply
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2413
MINOR: update JavaDoc for DSL PAPI-API
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka javaDocImprovements6
Alternatively you can
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2418
HOTFIX: KAFKA-4060 and KAFKA-4476 follow up
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka kafka-4060-zk-test-follow-up
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2459
MINOR: update JavaDocs for Kafka Streams DSL helpers
- also deprecate ZK config for Streams
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/2575
MINOR: update AWS test setup guide
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka minor-update-system-test-readme
Alternatively you
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2553
MINOR: fix indention in tags
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka hotfixDocs2
Alternatively you can review and apply
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2403
MINOR: add Streams system test for broker backwards compatibility
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/2404
KAFKA-4060 and KAFKA-4476 follow up
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka kafka-4060-zk-test-follow-up
Alternatively you
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2392
MINOR: refactor streams system test class hierachy
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka minor-system-test-rework
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2391
MINOR: remove ZK from system tests
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
kafka-4060-zk-follow-up-system-tests
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2401
KAFKA-4671: Fix Streams window retention policy
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka kafka-4671-window-retention-policy
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/1765
Improve reset tool 0.10.0
@guozhangwang @miguno @dguy @enothereska @hjafarpour
See #1764
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/1764
MINOR: improve Streams application reset tool to make sure application is
down
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/1766
KAFKA-4058: Failure in
org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterReset
see #1765
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/1767
KAFKA-4058: Failure in
org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterReset
You can merge this pull request into a Git repository by running:
$ git
Github user mjsax closed the pull request at:
https://github.com/apache/kafka/pull/1765
---
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 mjsax closed the pull request at:
https://github.com/apache/kafka/pull/1766
---
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 mjsax opened a pull request:
https://github.com/apache/kafka/pull/1756
KAFKA-4058: Failure in
org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterReset
- added retry on ResetTool error
You can merge this pull request into a Git
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/1808
MINOR: changes embedded broker time to MockTime
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka mockTime
Alternatively you can
Github user mjsax closed the pull request at:
https://github.com/apache/kafka/pull/1756
---
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 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/1869
HOTFIX: changed quickstart donwload from 0.10.0.0 to 0.10.0.1
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka hotfix-doc
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/1785
HOTFIX: disabled application-reset-tool integration test
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka disableTest
Alternatively
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/1777
KAFKA-4001: Improve Kafka Streams Join Semantics (KIP-76) [WiP]
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka kafka-4001-joins
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
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/2117
KAFKA-4393: Improve invalid/negative TS handling
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
kafka-4393-improveInvalidTsHandling
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2114
MINOR: add upgrade guide for Kafka Streams API
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka updateDocUpgradeSection
Alternatively
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2118
MINOR: improve exception message for incompatible Serdes to actual
key/value data types
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/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/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/2185
MINOR: added logging to debug test
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka hotfixResetToolTest
Alternatively you can review
Github user mjsax closed the pull request at:
https://github.com/apache/kafka/pull/2147
---
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 mjsax opened a pull request:
https://github.com/apache/kafka/pull/2147
revert corrupted commit 10cfc1628df024f7596d3af5c168fa90f59035ca
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka hotfixBadCommit
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2138
KAFKA-4331: Kafka Streams resetter is slow because it joins the same group
for each topic
- bug-fix follow up
- Resetter fails if no intermediate topic is used because seekToEnd()
commit ALL
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2153
MINOR: Update JavaDoc of KStream interface
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka javaDocKStreams
Alternatively you can
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
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 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 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
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
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2258
MINOR: update KStream JavaDocs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka minorKStreamJavaDoc
Alternatively you can review
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2233
KAFKA-4509: Task reusage on rebalance fails for threads on same host
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka kafka-4509-task
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2227
KAFKA-4510: StreamThread must finish rebalance in state PENDING_SHUTDOWN
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
kafka-4510
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2342
KAFKA-3452: follow-up -- introduce SesssionWindows
- TimeWindows represent half-open time intervals while SessionWindows
represent closed time intervals
You can merge this pull request into a Git
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2337
MINOR: rework JavaDoc for windowing related public API
- also some code refactoring and bug fixes
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2364
MINOR: fix JavaDoc
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka hotfix
Alternatively you can review and apply these changes
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2358
WIP -- DO NOT MERGE -- KAFKA-4222: Transient failure in
QueryableStateIntegrationTest.queryOnRebalance
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/2346
KAFKA-4619: Dissallow to output records with unknown keys in TransformValues
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/2209
KAFKA-4476: Kafka Streams gets stuck if metadata is missing
- break loop in StreamPartitionAssigner.assign() in case partition
metadata is missing
- fit state transition issue (follow up
Github user mjsax closed the pull request at:
https://github.com/apache/kafka/pull/2185
---
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 mjsax opened a pull request:
https://github.com/apache/kafka/pull/2321
MINOR: update JavaDoc for simple helper interfaces of KStream and KTable
operators
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/2303
MINOR: improve license header check by providing head file instead of
(prefix) header regex
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2314
MINOR: cleanup Kafka Streams exception classes
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka javaDocImprovements
Alternatively you
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2315
MINOR: Update JavaDoc for KTable helper interfaces
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka javaDocImprovements2
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2301
[WIP] [KAFKA-3856] Move inner classes accessible only functions in
TopologyBuilder out of public APIs
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/2332
MINOR: some public JavaDoc cleanup
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka javaDocImprovements5
Alternatively you can review
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2284
MINOR: KStream JavaDoc fix
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka javaDoc
Alternatively you can review and apply
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2773
Add exactly-once config to StreamsConfig
Enable producer per task if exactly-once config is enabled.
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/2757
MINOR: stabelize flaky ResetIntegrationTest
We got test error `org.apache.kafka.common.errors.TopicExistsException:
Topic 'inputTopic' already exists.` in some builds. Can reproduce reliably
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2756
KAFKA-4818: Implement transactional producer
add public API for transactions
- add new Producer methods to interface
- add new Producer and Consumer config parameters
We want to add
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2747
MINOR: StreamThread should catch InvalidTopicException
We should catch `InvalidTopicException` and not just
`NoOffsetForPartitionException`. Also, we need to step through all partitions
that might
Github user mjsax closed the pull request at:
https://github.com/apache/kafka/pull/2756
---
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 mjsax opened a pull request:
https://github.com/apache/kafka/pull/2777
HOTFIX: WindowedStreamPartitioner does not provide topic name to serializer
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka hotfix
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2778
MINOR: fix cleanup phase for KStreamWindowAggregateTest
fixes:
```
java.nio.file.NoSuchFileException:
/tmp/test7863510415433793941/topic2-Canonized/topic2-Canonized-19700101/15.sst
Github user mjsax closed the pull request at:
https://github.com/apache/kafka/pull/2358
---
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 mjsax opened a pull request:
https://github.com/apache/kafka/pull/2788
MINOR: imporve test cleanup
- call close() on Metrics to join created threads
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka minor
1 - 100 of 234 matches
Mail list logo
