GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/4313
MINOR: broker down for significant amt of time system test
System test where a broker is offline more than the configured timeouts.
In this case:
- Max poll interval set to 45 secs
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/4300
KAFKA-6269[WIP] DO NOT MERGE attempts to recreate original error
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/4291
Minor increase request timeout for streams bounce test
Increase `REQUEST_TIMOUT_MS` to improve a flaky test until KIP-91 merged
### Committer Checklist (excluded from commit message
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/4286
Minor fix broker compatibility tests
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/4168
MINOR: update producer client request timeout in system test
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bbejeck/kafka
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/4068
MINOR: Update JavaDoc to use new API
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bbejeck/kafka
MINOR_fix_java_doc_example_for_1_0_API
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/4060
MINOR: Add Kafka Streams upgrade workflow
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bbejeck/kafka MINOR_add_upgrade_workflow
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/3994
KAFKA-5985: update javadoc regarding closing iterators
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bbejeck/kafka
KAFKA
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/3978
KAFKA-5932: Avoid call to fetchPrevious in FlushListeners
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bbejeck/kafka
KAFKA
Github user bbejeck closed the pull request at:
https://github.com/apache/kafka/pull/3974
---
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/3974
Kafka 5932[WIP] DON'T Merge avoid fetch previous in flush listeners
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bbejeck/kafka
KAFKA
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/3973
Kafka-5958: Global stores access state restore listener
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bbejeck/kafka
KAFKA
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/3927
KAFKA-5862: Remove ZK dependency from Streams reset tool
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bbejeck/kafka
KAFKA
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/3915
MINOR: add punctuate calls to test driver
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bbejeck/kafka
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/3833
MINOR: refactor build method to extract methods from if statements
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bbejeck/kafka
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/3828
Minor update processor topology test driver
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bbejeck/kafka
Github user bbejeck closed the pull request at:
https://github.com/apache/kafka/pull/3664
---
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 bbejeck opened a pull request:
https://github.com/apache/kafka/pull/3664
KAFKA-5733: ensure clean RocksDB directory before setting prepareForBâ¦
â¦ulkload settings
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/3644
KAFKA-5711: batch restore should handle deletes
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bbejeck/kafka
KAFKA
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/3640
Kafka 5701 fix flaky unit test
1. Remove separate thread from test failing periodically due to race
condition.
2. Remove anonymous `AbstractNotifyingBatchingRestoreCallback` and set as
package
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/3629
First cut at porting State Store docs to AK
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bbejeck/kafka docs-updates-for-kip-167
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/3625
fix for standby tasks using batching restore
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bbejeck/kafka
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/3569
MINOR: enforce setting listeners in CREATE state.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bbejeck/kafka
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/3568
updated configs to use one try/catch for serdes
removed `try/catch` from `keySerde` and `valueSerde` methods so only the
`try\catch` blocks in `defaultKeySerde` and `defaultValueSerde` perform
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/3461
MINOR: need to be backwards compatible with deprecated default configâ¦
â¦s until removed
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/3325
KAFKA-5363 [WIP] : Initial cut at implementing bulk load for persistent
statâ¦
â¦e stores
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/3244
MINOR: expose commit interval config for testing
Expose the streams commit interval config for different testing scenarios.
You can merge this pull request into a Git repository by running
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/3215
Adding deprecated KTable methods to docs from KIP-114
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bbejeck/kafka kip114-doc
Alternatively
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/3211
Minor: make flush no-op as we don't need to call flush on commit.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bbejeck/kafka
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/3157
KAFKA-5226: Fixes issue where adding topics matching a regex
subscribed stream may not be detected by all followers until
onJoinComplete returns.
You can merge this pull request into a Git
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/2783
HOTFIX: fix potentially hanging test shouldAddStateStoreToRegexDefineâ¦
â¦dSource
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bbejeck
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/2654
KAFKA-3989_follow_up PR: update script to run from kafka root eg ./jmâ¦
â¦h-benchmarks/jmh.sh
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/2618
KAFKA-4791: unable to add state store with regex matched topics
Fix for adding state stores with regex defined sources
You can merge this pull request into a Git repository by running:
$ git
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/2597
KAFKA-4652: Added tests for KStreamBuilder
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bbejeck/kafka
KAFKA
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/2464
KAFKA-4662: adding test coverage for addSource methods with AutoOffseâ¦
â¦tReset
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bbejeck/kafka
Github user bbejeck closed the pull request at:
https://github.com/apache/kafka/pull/2090
---
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 bbejeck opened a pull request:
https://github.com/apache/kafka/pull/2090
KAFKA-4269: Follow up for 0.10.1 branch -update topic subscriptions for
regex
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bbejeck/kafka
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/2042
KAFKA-4312: If filePath is empty string writeAsText should have more mâ¦
â¦eaningful error message
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/2007
Kafka 4114 allow different offset reset strategies
@mjsax
Here's my first pass at finer grained auto offset reset strategies.
I've left TODO comments about whether we want
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/2005
KAFKA-4269 extracted code updating topics when regex pattern specifieâ¦
â¦d out of topicGroups method. The topicGroups method only called from
StreamPartitionAssignor when KafkaStreams object
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/1843
KAFKA-4131: moved updates for topics matching regex subscription methâ¦
â¦od, allows for followers to get subscribed topics
You can merge this pull request into a Git repository by running
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/1803
KAFKA-4023: add thread/task id for logging prefix
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bbejeck/kafka
KAFKA
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/1712
KAFKA-3989: initial support for adding a JMH benchmarking module.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bbejeck/kafka
KAFKA
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/1668
Kafka 3973 feasibility caching bytes vs records
@enothereska
Added the benchmark test per comments.
Thanks
You can merge this pull request into a Git repository by running
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/1590
KAFKA-3926: confirm all expected topics added/removed in createStreamâ¦
â¦Tasks call versus simply asserting createStreamTasks method called.
You can merge this pull request into a Git repository
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/1577
KAFKA-3794: added stream / table names as prefix to functions that prâ¦
â¦int to the console.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/1554
MINOR: Follow-up from KAFKA-3842 with suggested fixes to creating temâ¦
â¦p directories, waitForCondition
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/1532
KAFKA-3482: consolidate utility methods to TestUtils, added StreamsTeâ¦
â¦stUtils, added method for pausing tests to TestUtils
Changes made:
1. Added utility method for creating
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/1477
KAFKA-3443 [Kafka Stream] support for adding sources to KafkaStreams via
Pattern
This PR is the follow on to the closed PR #1410.
You can merge this pull request into a Git repository by running
Github user bbejeck closed the pull request at:
https://github.com/apache/kafka/pull/1410
---
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 bbejeck opened a pull request:
https://github.com/apache/kafka/pull/1410
KAFKA-3443 added support for subscribing to topics via regex
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bbejeck/kafka KAFKA
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/1222
KAFKA-3420 Allow users to set key in KTable.toStream and in KStream. â¦
⦠With KStream the method selectKey was added to enable getting a key
from values before perfoming aggregation-by-key
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/1209
Kafka-3338 [Kafka Streams] Add print and writeAsText to KStream/KTable
Addresses comments from previous PR [#1187]
Changed print and writeAsText method return signature to void
Github user bbejeck closed the pull request at:
https://github.com/apache/kafka/pull/1187
---
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 bbejeck opened a pull request:
https://github.com/apache/kafka/pull/1187
KAFKA-3338 [WIP]: Add print and writeAsText to KStream and KTable interfaces
This is the first pass at implementing the print and writeAsText
functionality for KStream and KTable. I have some
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/596
Kafka 2902 streaming config use get base consumer configs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bbejeck/kafka
KAFKA-2902
GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/572
KAFKA-2872 Fixed addSink method connecting sink with parent source(s)â¦
Starting a KafkaStream was getting an error due to the fact that the
TopologyBuilder.addSink method was not connecting
57 matches
Mail list logo
