Github user becketqin closed the pull request at:
https://github.com/apache/kafka/pull/3628
---
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 becketqin opened a pull request:
https://github.com/apache/kafka/pull/3628
KAFKA-5681; jarAll should build all scala versions.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA-5681
Alternatively
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/3573
KAFKA-5630; The consumer should block on courrupt records and keeping throw
exception
This patch handles the case that a CorruptRecordException is thrown from
the iterator directly.
You can
Github user becketqin closed the pull request at:
https://github.com/apache/kafka/pull/2828
---
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 becketqin opened a pull request:
https://github.com/apache/kafka/pull/3163
KAFKA-5344: set message.timestamp.difference.max.ms back to Long.MaxValue
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/3114
KAFKA-5211: Do not skip a corrupted record in consumer
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA-5211
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/2828
KAFKA-5011: down convert the message on replication if necessary
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA-5011
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/2705
KAFKA-4907: message.timestamp.difference.max.ms should not be applied to
log compacted topic if user did not set the property.
You can merge this pull request into a Git repository by running
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/2638
KAFKA-3995: fix compression ratio estimation.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA-3995
Alternatively you
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/2544
KFKA-4340: update the upgrade.html
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA-4340_follow_up
Alternatively you
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/2501
KAFKA-4734; Trim the time index on old segments
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA-4734
Alternatively you
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/2329
KAFKA-4381: Add per partition lag metrics to the consumer
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA-4381
Github user becketqin closed the pull request at:
https://github.com/apache/kafka/pull/2251
---
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 becketqin closed the pull request at:
https://github.com/apache/kafka/pull/660
---
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 becketqin opened a pull request:
https://github.com/apache/kafka/pull/2260
KAFKA-4529; LogCleaner should not delete the tombstone too early.
cc @junrao
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka
Github user becketqin closed the pull request at:
https://github.com/apache/kafka/pull/2242
---
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 becketqin opened a pull request:
https://github.com/apache/kafka/pull/2251
KAFKA-4529; Fix the issue that tombstone can be deleted too early.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA-4529
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/2243
KAFKA-4497: LogCleaner appended the wrong offset to time index. Backport
the fix to 0.10.1.
The code in trunk has been changed, so we need to provide a different fix
for this problem in 0.10.1
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/2242
KAFKA-4497: Fix the ByteBufferMessageSet.filterInto
There seems a few bugs in `ByteBufferMessageSet.filterInto`, including
incorrect offsets, messages read and retained. This patch fixes them and
Github user becketqin commented on the issue:
https://github.com/apache/kafka-site/pull/29
@ijuma Thanks for the review. Merged to the asf-site.
---
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
Github user becketqin commented on the issue:
https://github.com/apache/kafka-site/pull/29
@ijuma Does the updated page look good to you?
---
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
Github user becketqin commented on the issue:
https://github.com/apache/kafka-site/pull/29
@ijuma That's fair. I updated the page. The thing I found confusing is that
we have documentation in three places: 1) Kafka code repo 2) kafka-site repo 3)
some documentation are just a
Github user becketqin commented on the issue:
https://github.com/apache/kafka-site/pull/29
@ijuma The github site has stated that it is mirrored from the Apache repo.
I added the link anyways.
---
If your project is set up for it, you can reply to this email and have your
reply
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka-site/pull/29
Update the website repo link in code.html to point to github.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka-site asf
Github user becketqin commented on the issue:
https://github.com/apache/kafka-site/pull/28
I'll try to merge this myself :)
---
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 fe
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka-site/pull/28
Add Becket to the committers page
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka-site asf-site
Alternatively you can
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/2071
KAFKA-4340: Change default message.timestamp.difference.max.ms to the same
as log.retention.ms
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/1993
KAFKA-4274: offsetsForTimes() hang on empty map.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA-4274
Alternatively
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/1939
KAFKA-4235: Fix the race condition in Sender.initiateClose() that may
result in missing some callbacks.
You can merge this pull request into a Git repository by running:
$ git pull https
Github user becketqin closed the pull request at:
https://github.com/apache/kafka/pull/1935
---
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 becketqin opened a pull request:
https://github.com/apache/kafka/pull/1935
KAFKA-4232: make MemoryRecords.writable volatile.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA-4232
Alternatively
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/1915
KAFKA-3965 mirror maker should not commit offset when exception is thrown
from producer.send()
You can merge this pull request into a Git repository by running:
$ git pull https
Github user becketqin closed the pull request at:
https://github.com/apache/kafka/pull/1897
---
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 becketqin reopened a pull request:
https://github.com/apache/kafka/pull/1897
KAFKA-4194 follow up patch for KIP-79
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA-4194
Alternatively you can
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/1897
KAFKA-4148 follow up patch for KIP-79
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA-4194
Alternatively you can
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/1852
KAFKA-4148: KIP-79 ListOffsetRequest v1 and add search offsets by timestamp
in consumer
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/1809
KAFKA-4099: Fix the potential frequent log rolling
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA-4099
Alternatively
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/1769
Minor follow up for KAFKA-3163 (KIP-33)
@junrao Could you take a look when get a chance? Thanks.
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/1400
KAFKA-3721: Put UpdateMetadataRequest V2 in 0.10.0-IV1
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA-3721
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/1399
KAFKA-3554 Improve ProducerPerformance test
1. Added multiple thread support.
2. Added value-bound to make compressed data more realistic.
3. Print out the producer metrics.
You can merge
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/1375
KAFKA-3698: Update the message format section.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA-3698
Alternatively you
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/1372
KAFKA-3565: Add documentation to warn user about the potential messagâ¦
â¦e throughput drop due to the addition of timestamp field.
You can merge this pull request into a Git repository by
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/1215
KAFKA-3163: Add time based index to Kafka.
This is patch for KIP-33.
https://cwiki.apache.org/confluence/display/KAFKA/KIP-33+-+Add+a+time+based+log+index
You can merge this pull request
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/1149
KAFKA-3436: Speed up controlled shutdown.
This patch does the followings:
1. Batched LeaderAndIsrRequest and UpdateMetadataRequest during controlled
shutdown.
2. Added async read and
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/1112
KAFKA-3442: Fix FileMessageSet iterator.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA-3442
Alternatively you can
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/1056
KAFKA-3388: Fix expiration of batches sitting in the accumulator
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA-3388
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/1049
KAFKA-3373 add 'log' prefix to configurations in KIP-31/32
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/1023
KAFKA-3343: Use NoTimestamp in GroupMetadataManager when message v0 iâ¦
â¦s used.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/1018
KAFKA-2960: Clear purgatory for partitions before becoming follower
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/983
KAFKA-3300: Avoid over allocating disk space and memory for index files.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/949
KAFKA-3256: Add print.timestamp option to console consumer.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA-3256
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/880
KAFKA-3190 Producer should not fire callback in Send() method
@guozhangwang Would you mind take a look? This was originally introduced in
KAFKA-1260. I did not find specific reason in the original
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/857
KAFKA-3197 Fix producer sending records out of order
This patch adds a new configuration to the producer to enforce the maximum
in flight batch for each partition. The patch itself is small, but
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/842
KAFKA-3179 Fix seek on compressed messages
The fix itself is simple.
Some explanation on unit tests. Currently we the vast majority of unit test
is running with uncompressed messages. I
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/841
KAFKA-3174: Change Crc32 to use java.util.zip.CRC32
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA-3174
Alternatively
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/764
KAFKA-3025 Added timetamp to Message and use relative offset.
See KIP-31 and KIP-32 for details.
A few notes on the patch:
1. This patch only implements the server side message format
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/688
KAFKA-3003 Update the replica.highWatermark correctly
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA-3003
GitHub user becketqin reopened a pull request:
https://github.com/apache/kafka/pull/660
KAFKA-2980 Fix deadlock when ZookeeperConsumerConnector create messagâ¦
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka
Github user becketqin closed the pull request at:
https://github.com/apache/kafka/pull/660
---
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 becketqin opened a pull request:
https://github.com/apache/kafka/pull/660
KAKFA-2980 Fix deadlock when ZookeeperConsumerConnector create messagâ¦
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/478
KAFKA-2784: swallow exceptions when mirror maker exits.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA-2784
GitHub user becketqin reopened a pull request:
https://github.com/apache/kafka/pull/402
KAFKA-2722: Improve ISR change propagation.
The patch has two changes:
1. fixed a bug in controller that it sends UpdateMetadataRequest of all the
partitions in the cluster.
2. Uses the
Github user becketqin closed the pull request at:
https://github.com/apache/kafka/pull/402
---
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 becketqin reopened a pull request:
https://github.com/apache/kafka/pull/402
Improve ISR change propagation.
The patch has two changes:
1. fixed a bug in controller that it sends UpdateMetadataRequest of all the
partitions in the cluster.
2. Uses the following
Github user becketqin closed the pull request at:
https://github.com/apache/kafka/pull/402
---
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 becketqin opened a pull request:
https://github.com/apache/kafka/pull/402
Improve ISR change propagation.
The patch has two changes:
1. fixed a bug in controller that it sends UpdateMetadataRequest of all the
partitions in the cluster.
2. Uses the following
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/266
KAFKA-2452: Add new consumer option to mirror maker.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA-2452
Alternatively
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/221
KAFKA-2555: Infinite recursive function call when call commitSync in â¦
@hachikuji @ewencp I found this problem when adding new consumer to mirror
maker which commits offset in the rebalance
Github user becketqin closed the pull request at:
https://github.com/apache/kafka/pull/204
---
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 becketqin reopened a pull request:
https://github.com/apache/kafka/pull/204
KAFKA-2477: Fix a race condition between log append and fetch that causes
OffsetOutOfRangeException.
Tried two fixes. I prefer the second approach because it saves an
additional offset search
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/204
Kafka 2477
Tried two fixes. I prefer the second approach because it saves an
additional offset search.
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/200
KAFKA-2512: Add version check to broker and clients.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA-2512
Alternatively
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/189
KAFKA-2437: Fix ZookeeperLeaderElector to handle node deletion correctly.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/153
KAFKA-2454: Deadlock between log segment deletion and server shutdown.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA
Github user becketqin closed the pull request at:
https://github.com/apache/kafka/pull/108
---
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 becketqin opened a pull request:
https://github.com/apache/kafka/pull/134
KAFKA-2389: remove commit type from new consumer.
A shot to remove commit type from new consumer. The coordinator constructor
takes a default offset commit callback mainly for testing purpose
Github user becketqin closed the pull request at:
https://github.com/apache/kafka/pull/104
---
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 becketqin opened a pull request:
https://github.com/apache/kafka/pull/129
KAFKA-2143: fix replica offset truncate to beginning during leader
migration.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/121
KAFKA-2415: Fix transient failure in LogRecoveryTest
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA-2415
Alternatively
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/120
KAFKA-1997: Follow-up patch, hardcode key/value serializer in mirror maker
to byte serializer.
Hardcode the key/value serializer to ByteArraySerializer according to
Junâs comments.
You can
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/114
KAFKA-2406[WIP]: Throttle ISR propagation
This is a follow up patch for KAFKA-2406. Further test to verify if this
change alone is enough to solve the problem or not.
You can merge this pull
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/113
KAFKA-2401: fix transient failure in
ProducerSendTest.testCloseWithZeroTimeoutFromSenderThread
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/108
KAFKA-2402: Create IsrChangeNotificationPath when server statrs.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/becketqin/kafka KAFKA-2402
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/104
Fix for KAFKA-2134, fix replica offset truncate to beginning during leader
migration.
Fix replica truncate log to beginning during leader migration.
You can merge this pull request into a Git
84 matches
Mail list logo
