GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/3993
KAFKA-5995; Rename AlterReplicaDir to AlterReplicaDirs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka KAFKA-5995
Github user lindong28 closed the pull request at:
https://github.com/apache/kafka/pull/3839
---
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/4045
AbstractIndex.closeHandler() should grab lock before unmap the mmap
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka KAFKA
Github user lindong28 closed the pull request at:
https://github.com/apache/kafka/pull/3782
---
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/4100
KAFKA-6093; log.close() should not prevent log from being accessed
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka KAFKA-6093
Github user lindong28 closed the pull request at:
https://github.com/apache/kafka/pull/4100
---
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/4177
KAFKA-6172; Cache lastEntry in TimeIndex to avoid unnecessary disk access
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/4179
KAFKA-6175; AbstractIndex should cache index file to avoid unnecessary disk
access during resize()
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/4248
KAFKA-6258; SSLTransportLayer should keep reading from socket until either
the buffer is full or the socket has no more data
You can merge this pull request into a Git repository by running
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/4257
KAFKA-6174; Add methods in Options classes to keep binary compatibility
with 0.11
From 0.11 to 1.0, we moved `DescribeClusterOptions timeoutMs(Integer
timeoutMs)` from DescribeClusterOptions to
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/4306
KAFKA-6331; Fix transient failure in
AdminClientIntegrationTest.testAlterReplicaLogDirs
*More detailed description of your change,
if necessary. The PR title and PR message become
the
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/3463
KAFKA-5544; The LastStableOffsetLag metric should be removed when partition
is deleted
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/3498
Kafka-4763 (Used for triggering test only)
This patch is used only for triggering test. No need for review.
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user lindong28 reopened a pull request:
https://github.com/apache/kafka/pull/3498
Kafka-4763 (Used for triggering test only)
This patch is used only for triggering test. No need for review.
You can merge this pull request into a Git repository by running:
$ git pull
Github user lindong28 closed the pull request at:
https://github.com/apache/kafka/pull/3498
---
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 lindong28 reopened a pull request:
https://github.com/apache/kafka/pull/3498
Kafka-4763 (Used for triggering test only)
This patch is used only for triggering test. No need for review.
You can merge this pull request into a Git repository by running:
$ git pull
Github user lindong28 closed the pull request at:
https://github.com/apache/kafka/pull/3498
---
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 lindong28 reopened a pull request:
https://github.com/apache/kafka/pull/3498
Kafka-4763 (Used for triggering test only)
This patch is used only for triggering test. No need for review.
You can merge this pull request into a Git repository by running:
$ git pull
Github user lindong28 closed the pull request at:
https://github.com/apache/kafka/pull/3498
---
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 lindong28 closed the pull request at:
https://github.com/apache/kafka/pull/3498
---
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 lindong28 reopened a pull request:
https://github.com/apache/kafka/pull/3498
Kafka-4763 (Used for triggering test only)
This patch is used only for triggering test. No need for review.
You can merge this pull request into a Git repository by running:
$ git pull
Github user lindong28 closed the pull request at:
https://github.com/apache/kafka/pull/3498
---
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 lindong28 opened a pull request:
https://github.com/apache/kafka/pull/3528
Kafka-4763 (Used for triggering test only)
This patch is used only for triggering test. No need for review.
You can merge this pull request into a Git repository by running:
$ git
Github user lindong28 closed the pull request at:
https://github.com/apache/kafka/pull/3528
---
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 lindong28 opened a pull request:
https://github.com/apache/kafka/pull/3565
KAFKA-5627; Reduce classes needed for LeaderAndIsrPartitionState and
MetadataPartitionState
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/3583
KAFKA-5341; Add UnderMinIsrPartitionCount and per-partition UnderMinIsr
metrics (KIP-164)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/3594
KAFKA-5663; Fix LogDirFailureTest system test
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka KAFKA-5663
Alternatively you
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/3614
KAFKA-5695; Test DeleteRecordsRequest in AuthorizerIntegrationTest
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka KAFKA-5695
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/3621
KAFKA-5694; Add ChangeReplicaDirRequest and DescribeReplicaDirRequest
(KIP-113)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/3642
KafkaAdminClient should remove inflight call correctly after response is
received
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28
Github user lindong28 closed the pull request at:
https://github.com/apache/kafka/pull/3642
---
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 lindong28 opened a pull request:
https://github.com/apache/kafka/pull/3709
KAFKA-5759; Allow user to specify relative path as log directory
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka KAFKA-5759
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/3718
KAFKA-5767; Kafka server should halt if IBP < 1.0.0 and there is log
directory failure
You can merge this pull request into a Git repository by running:
$ git pull https://github.
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/3763
KAFKA-5812; Represent logDir with case class where absolute path is required
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/3781
MINOR: Improve documentation of AdminClient
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka minor-admin-client-comment
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/3782
KAFKA-5829; Speedup broker startup after unclean shutdown by reducing
unnecessary snapshot files deletion
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/3797
KAFKA-5843; Mx4jLoader.maybeLoad should only be executed if
kafka_mx4jenable is set to true
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/3803
KAFKA-5845; KafkaController should send LeaderAndIsrRequest to broker which
starts very soon after shutdown
You can merge this pull request into a Git repository by running:
$ git pull
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/3820
KAFKA-5864; ReplicaFetcherThread.processPartitionData() should throw
KafkaStorageException if replica is offline
You can merge this pull request into a Git repository by running:
$ git
Github user lindong28 closed the pull request at:
https://github.com/apache/kafka/pull/3803
---
GitHub user lindong28 reopened a pull request:
https://github.com/apache/kafka/pull/3803
KAFKA-5845; KafkaController should send LeaderAndIsrRequest to broker which
starts very soon after shutdown
You can merge this pull request into a Git repository by running:
$ git pull
Github user lindong28 closed the pull request at:
https://github.com/apache/kafka/pull/3803
---
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/3839
KAFKA-5877; Controller should only update reassignment znode if there is
change in the reassignment data
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/3840
KAFKA-5879; Controller should read the latest IsrChangeNotification znodes
when handling IsrChangeNotification event
â¦
You can merge this pull request into a Git repository by running
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/3874
KAFKA-5163; Support replicas movement between log directories (KIP-113)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka KAFKA
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/1562
KAFKA-3908; Set SendBufferSize for socket used by Processor
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka KAFKA-3908
Github user lindong28 closed the pull request at:
https://github.com/apache/kafka/pull/755
---
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 lindong28 closed the pull request at:
https://github.com/apache/kafka/pull/1562
---
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 lindong28 reopened a pull request:
https://github.com/apache/kafka/pull/1562
KAFKA-3908; Set ReceiveBufferSize for socket used by Processor
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka KAFKA-3908
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/2141
KAFKA-4415; Reduce time to create and send MetadataUpdateRequest
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka KAFKA-4415
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/2148
KAFKA-4420; Group StopReplicaRequests for partitions on the same broker
into one StopReplicaRequest
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/2155
KAFKA-4429; records-lag should be zero if FetchResponse is empty
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka KAFKA-4429
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/2167
KAFKA-4442; Controller should grab lock when it is being initialized to
avoid race condition
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/2169
KAFKA-4415; Reduce time to create and send MetadataUpdateRequest
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka KAFKA-4415
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/2168
KAFKA-4443; Controller should send UpdateMetadataRequest prior to
LeaderAndIsrRequest during failover
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/2170
KAFKA-4445; PreferredLeaderElectionCommand should query zookeeper only once
per topic
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
Github user lindong28 closed the pull request at:
https://github.com/apache/kafka/pull/2141
---
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 lindong28 opened a pull request:
https://github.com/apache/kafka/pull/2208
KAFKA-4485; Follower should be in the isr if its FetchRequest has fetched
up to the logEndOffset of leader
You can merge this pull request into a Git repository by running:
$ git pull
Github user lindong28 closed the pull request at:
https://github.com/apache/kafka/pull/2167
---
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 lindong28 opened a pull request:
https://github.com/apache/kafka/pull/2241
KAFKA-4521; MirrorMaker should flush all messages before releasing
partition ownership during rebalance
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/2619
KAFKA-4820; ConsumerNetworkClient.send() should not require global lock
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka KAFKA
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/2641
KAFKA-4586 followup; Fix testMaxPollIntervalMsDelayInRevocation test failure
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka
Github user lindong28 closed the pull request at:
https://github.com/apache/kafka/pull/1562
---
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 lindong28 opened a pull request:
https://github.com/apache/kafka/pull/2760
KAFKA-4973; Fix transient failure of
AdminClientTest.testDeleteRecordsWithException
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/2859
KAFKA-5075; Defer exception to the next pollOnce() if consumer's fetch
position has already increased
You can merge this pull request into a Git repository by running:
$ git pull
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/2864
PartitionRecords.fetchRecords(...) should defer exception to the next call
if iterator has already moved across any valid record
You can merge this pull request into a Git repository by running
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/2869
Update topic expiry time in Metadata every time the topic metadata is
requested
As of current implementation, KafkaProducer.waitOnMetadata() will first
reset topic expiry time of the topic
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/2476
KAFKA-4586; Add purgeDataBefore() API (KIP-107)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka KAFKA-4586
Alternatively you
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/2504
KAFKA-4735; Fix deadlock issue during MM shutdown
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka KAFKA-4735
Alternatively
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/651
Minor: Fix @link in MetricName comment
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka minor-fix-link-comment
Alternatively
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/731
KAFKA-3045; ZkNodeChangeNotificationListener shouldn't log
InterruptedException as error
You can merge this pull request into a Git repository by running:
$ git pull https://githu
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/755
KAFKA-3089; VerifiableProducer should do a clean shutdown in stop_node()
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka KAFKA
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/1009
KAFKA-3330; Truncate log cleaner offset checkpoint if the log is truncated
@becketqin Can you take a look?
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/118
KAFKA-2390; Seek() should take a callback
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka KAFKA-2390
Alternatively you can
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/142
KAFKA-2436; log.retention.hours should be honored by LogManager
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka KAFKA-2436
GitHub user lindong28 reopened a pull request:
https://github.com/apache/kafka/pull/142
KAFKA-2436; log.retention.hours should be honored by LogManager
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka KAFKA-2436
Github user lindong28 closed the pull request at:
https://github.com/apache/kafka/pull/142
---
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 lindong28 opened a pull request:
https://github.com/apache/kafka/pull/174
KAFKA-2485; Allow producer performance to take properties from a fileâ¦
⦠via --consumer.config command line parameter
You can merge this pull request into a Git repository by running
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/176
KAFKA-2332; Add quota metrics to old producer and consumer
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka KAFKA-2332
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/181
KAFKA-2278; JmxTool should support querying all objects when object-nâ¦
â¦ame is omitted
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/1851
KAFKA-4158; Reset quota to default value if quota override is deleted
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka KAFKA
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/2929
KAFKA-4763; Handle disk failure for JBOD (KIP-112)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka KAFKA-4763
Alternatively
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/239
add unit test for OffsetResetStrategyTest
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka KAFKA-2390-followup
Alternatively
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/246
MINOR: Fix Vagrant setup script for use on Fedora
I tested and verified that `vagrant --version | egrep -o "\d+\.\d+\.\d+"`
works on Mac but failed on RedHad 6.4, while `vagrant --versi
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/247
KAFKA-2585; ConsoleConsumer should not hang infinitely upon exception
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka KAFKA
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/275
KAFKA-2527; System Test for Quotas in Ducktape
@granders Can you take a look at this quota system test?
You can merge this pull request into a Git repository by running:
$ git pull https
Github user lindong28 closed the pull request at:
https://github.com/apache/kafka/pull/275
---
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 lindong28 reopened a pull request:
https://github.com/apache/kafka/pull/275
KAFKA-2527; System Test for Quotas in Ducktape
@granders Can you take a look at this quota system test?
You can merge this pull request into a Git repository by running:
$ git pull https
Github user lindong28 closed the pull request at:
https://github.com/apache/kafka/pull/275
---
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 lindong28 reopened a pull request:
https://github.com/apache/kafka/pull/275
KAFKA-2527; System Test for Quotas in Ducktape
@granders Can you take a look at this quota system test?
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/286
KAFKA-2621; nextOffsetMetadata should be changed after rolling a new log
segment
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28
Github user lindong28 closed the pull request at:
https://github.com/apache/kafka/pull/286
---
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 lindong28 opened a pull request:
https://github.com/apache/kafka/pull/316
KAFKA-2660; Correct cleanableRatio calculation
@onurkaraman Could you have a look? This is the patch I discussed with you.
You can merge this pull request into a Git repository by running
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/326
update the command to run a particular test method in readme
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka minor-readme
Github user lindong28 closed the pull request at:
https://github.com/apache/kafka/pull/326
---
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 lindong28 opened a pull request:
https://github.com/apache/kafka/pull/327
KAFKA-2669; Fix LogCleanerIntegrationTest
LogCleanerIntegrationTest calls LogCleaner.awaitCleaned() to wait until
cleaner has processed up to given offset. However, existing awaitCleaned
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/328
KAFKA-2668; Add a metric that records the total number of metrics
@onurkaraman @becketqin Do you have time to review this patch? It addresses
the ticket that @jjkoshy filed in KAFKA-2668.
You can
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/346
KAFKA-2678; partition level lag metrics can be negative
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka KAFKA-2678
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/436
KAFKA-2721; Avoid handling duplicate LeaderAndISR requests
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka KAFKA-2721
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/437
MINOR: KAFKA-2751 Improve documentation for log.retention.ms
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/kafka KAFKA-2751
1 - 100 of 103 matches
Mail list logo
