GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4342
KAFKA-4263: fix flaky test QueryableStateIntegrationTest.concurrentAccess
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka kafka-4263
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4341
KAFKA-6382: Make ProducerConfig and ConsumerConfig constructors public
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
kafka-6382
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4337
MINOR: fix race condition in KafkaStreamsTest.shouldReturnThreadMetadata
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka minor-fix
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4335
MINOR: improve JavaDocs for KafkaStreams, KafkaProducer, KafkaConsumer
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/4332
KAFKA-6302: Improve AdmintClient JavaDocs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
kafka-6302-update-admin-client-javadoc
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4329
MINOR: stabilize flaky system tests
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka hotfix-system-tests
Alternatively you can
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4322
KAFKA-6126: Remove unnecessary topics created check
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4284
MINOR: imporve EOS docs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka minor-improve-eos-docs
Alternatively you can review
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4255
KAFKA-6259: Make KafkaStreams.cleanup() clean global state directory
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test
Github user mjsax closed the pull request at:
https://github.com/apache/kafka/pull/4246
---
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4253
MINOR: improve error message for Streams test
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4246
MINOR: improve flaky Streams tests
Use TestUtil test directory for state directory instead of default
/tmp/kafka-streams
### Committer Checklist (excluded from commit message
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4244
MINOR: improve flaky Streams system test
Handle TimeoutException in Producer callback and retry sending input data
### Committer Checklist (excluded from commit message)
- [ ] Verify
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4242
KAFKA-4857: [WIP] Replace StreamsKafkaClient with AdminClient in Kafka
Streams
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4228
MINOR: improve StateStore JavaDocs
Clarify that state directory must use `storeName`
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4221
MINOR: fix instable KafkaStreamsTest
- set streams state.dir to test-dir (default /tmp is not reliable)
### Committer Checklist (excluded from commit message)
- [ ] Verify design
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4215
Kafka 6121 restore global consumer handle reset
- set auto.offset.reste to "none" for restore and global consumer
- handle InvalidOffsetException for restore and global consumer
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4210
KAFKA-6167: Timestamp on streams directory contains a colon, which is an
illegal character
- change segment delimiter to .
- added upgrade path
- added test for old and new upgrade path
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4206
KAFKA-6122: Global Consumer should handle TimeoutException
Implements KIP-224:
- adding new StreamsConfig `retires`
- uses `retires` and `retry.backoff.ms` to handle TimeoutException
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4148
KAFKA-6120: RecordCollector should not retry sending
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka kafka-6120-recordCollector
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4129
KAFKA-6115: TaskManager should be type aware
- remove type specific methods from Task interface
- add generics to preserve task type
- add sub classes for different task types
You can
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4128
MINOR: random cleanup and JavaDoc improvements for clients and Streams
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka minor-cleanup
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4104
MINOR: add hint for setting an uncaught exception handler to JavaDocs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka minor-uncaught
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4078
MINOR: update exception message for KIP-120
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka hotfix-streams
Alternatively you can
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4064
MINOR: add unit test for StateStoreSerdes
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka minor-add-state-serdes-test
Alternatively
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4063
MINOR: improve Store parameter checks
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
minor-improve-store-parameter-checks
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4051
MINOR: KIP-182 follow up
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka minor-kip-182-follow-up
Alternatively you can review
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4048
MINOR: fix EOS test race condition
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka fix-eos-test-race-condition
Alternatively you can
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4046
KAFKA-5541: minor follow-up
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka kafka-5541-minor-follow-up
Alternatively you can review
Github user mjsax closed the pull request at:
https://github.com/apache/kafka/pull/3953
---
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4037
KAFKA-5541: Streams should not re-throw if suspending/closing tasks fails
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
kafka-5541
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4006
MINOR: JavaDoc improvements for new state store API
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
minor-javadoc-improvments
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4005
MINOR: fix JavaDocs warnings
- add some missing annotations for deprecated methods
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/4003
MINOR: add suppress warnings annotations
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka minor-deprecated
Alternatively you can
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3986
KAFKA-5949: Follow-up after latest KIP-161 changes
- compare KAFKA-5958
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
kafka-5949
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3979
KAFKA-5979: Use single AtomicCounter to generate internal names
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka kafka-5979-kip-120
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3970
KAFKA-5225: StreamsResetter doesn't allow custom Consumer properties
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
kafka-5225
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3966
KAFKA-5980: FailOnInvalidTimestamp does not log error
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
kafka-5980
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3953
KAFKA-5541: Streams should not re-throw if suspending/closing tasks fails
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
kafka-5541
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3949
MINOR: Update Streams quickstart to create output topic with compactiâ¦
â¦on enabled
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/3948
KAFKA-4593: Don't throw IllegalStateException and die on task migration
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
kafka-4593
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3939
KAFKA-5949: User Callback Exceptions need to be handled properly
- catch user exception in user callback (TimestampExtractor,
DeserializationHandler, StateRestoreListener) and wrap
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3913
KAFKA-5937: Improve ProcessorStateManager exception handling
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
kafka-5937-exceptions
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3912
KAFKA-5936: KafkaProducer.close should throw InterruptException
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka kafka-5936-producer
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3893
KAFKA-5893: Preserve original System.out in PrintedTest
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka kafka-5893-reset-integration
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3884
MINOR: various random minor fixes and improve KafkaConsumer JavaDocs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
minor-fixed
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3859
KAFKA-5893: ResetIntegrationTest fails
- improve stderr output for better debugging
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/3841
KAFKA-5833: Reset thread interrupt state in case of InterruptedException
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka kafka-5833
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3804
MINOR: fixed typos
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 commented on the issue:
https://github.com/apache/kafka-site/pull/75
Call for review and merging @guozhangwang
---
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka-site/pull/75
Fix HTML markup
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka-site hotfix
Alternatively you can review and apply these changes
Github user mjsax closed the pull request at:
https://github.com/apache/kafka/pull/3328
---
Github user mjsax commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/73#discussion_r137037867
--- Diff: coding-guide.html ---
@@ -102,6 +102,47 @@
We should attempt to maintain API compatibility when
possible, though at this point
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3787
KAFKA-5823: Extend upgrade section for KIP-120
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka kafka-5823-kip120-docs
Alternatively
Github user mjsax commented on the issue:
https://github.com/apache/kafka-site/pull/73
Call for reviews, @guozhangwang @dguy @bbejeck
---
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka-site/pull/73
Add coding guidelines for Streams API
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka-site streams-coding-guidelines
Github user mjsax closed the pull request at:
https://github.com/apache/kafka/pull/3779
---
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3779
KAFKA-5818: KafkaStreams state transitions not correct
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
kafka-5818-kafkaStreams-state
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3775
KAFKA-5818: KafkaStreams state transitions not correct
- need to check that state is CRATED at startup
- some minor test cleanup
You can merge this pull request into a Git repository by running
Github user mjsax closed the pull request at:
https://github.com/apache/kafka/pull/3722
---
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/3722
KAFKA-5603: Don't abort TX for zombie tasks
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
kafka-5603-dont-abort-tx-for-zombie
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3719
KAFKA-5603: Don't abort TX for zombie tasks
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
kafka-5603-dont-abort-tx-for-zombie
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3602
KAFKA-5671: Add StreamsBuilder and Deprecate KStreamBuilder
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka kafka-5671-add
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3590
KAFKA-5670: (KIP-120) Add Topology and deprecate TopologyBuilder
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
kafka-3856-replace
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3542
KAFKA-5362: Follow up to Streams EOS system test
- improve tests to get rid of calls to `sleep` in Python
- fixed some flaky test conditions
- improve debugging
You can merge this pull
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3536
KAFKA-3856: Refactoring for KIP-120
- extract InternalTopologyBuilder from TopologyBuilder
- deprecate all "leaking" methods from public TopologyBuilder API
You can merge this pu
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3504
KAFKA-5566: fixed race condition between flush and commit
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka kafka-5566-queryable-state
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3497
HOTFIX: disable flaky system tests
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka disable-flaky-system-tests
Alternatively you can
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3496
KAFKA-5464: Follow up. Increase poll timeout
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka KAFKA-5464-follow-up
Alternatively you
Github user mjsax closed the pull request at:
https://github.com/apache/kafka/pull/3311
---
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/3449
KAFKA-5167: Release state locks in case of failure
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
kafka-5167-streams-task-gets
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3445
MINOR: remove unnecessary null check
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka minor-remove-null-check
Alternatively you can
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3439
KAFKA-5464: StreamsKafkaClient should not use StreamsConfig.POLL_MS_CONFIG
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka kafka-5464
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3416
MINOR: improve test README
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka minor-aws
Alternatively you can review and apply
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3414
HOTFIX: reduce log verbosity on commit
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka hotfix-commit-logging
Alternatively you can
Github user mjsax closed the pull request at:
https://github.com/apache/kafka/pull/3401
---
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/3401
MINOR: explain producer naming within Streams
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka minor-producer-naming-011
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3390
KAFKA-5485: Streams should not suspend tasks twice
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
kafka-5485-dont-suspend-tasks
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3378
MINOR: explain producer naming within Streams
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka minor-producer-naming
Alternatively
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3375
KAFKA-5474: Streams StandbyTask should no checkpoint on commit if EOS is
enabled
- actual fix for `StandbyTask#commit()`
Additionally (for debugging):
- EOS test, does not report "exp
Github user mjsax closed the pull request at:
https://github.com/apache/kafka/pull/3312
---
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/3329
KAFKA-5442: Streams producer client.id are not unique for EOS
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka kafka-5442-producer-id
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3328
HOTFIX: log level should be ERROR for conflicting metric names
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka hotfix-app-info-log
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3327
HOTFIX: Introduce max wait time for retry-and-backoff while creating tasks
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/3312
HOFIX: Introduce max wait time for retry-and-backoff while creating tasks
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/3311
MINOR: fix local Docker setup
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka colins-patch
Alternatively you can review and apply
GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/3310
KAFKA-5362: Add Streams EOS system test with repartitioning topic
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
kafka-5362-add-eos
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
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 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
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 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/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/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
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
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 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/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/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/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
1 - 100 of 234 matches
Mail list logo
