Commits

Branch selector

 trunk

User selector

lindong28

Datepicker

All time

Commit History

Commits on Jun 26, 2018

• KAFKA-6949; alterReplicaLogDirs() should grab partition lock when accessing log of the future replica

  lindong28

  committedJun 26, 2018
  9ea81ba

Commits on Jun 20, 2018

• KAFKA-6697: Broker should not die if getCanonicalPath fails (apache#4752)

  

  lindong28

  authored and

  ijuma

  committedJun 20, 2018
  fd969be

Commits on Jun 12, 2018

• MINOR: Remove deprecated per-partition lag metrics

  lindong28

  committedJun 12, 2018
  4580d9f

Commits on May 15, 2018

• KAFKA-3473; More Controller Health Metrics (KIP-237)

  lindong28

  committedMay 15, 2018
  0bb48a1

Commits on Mar 18, 2018

• MINOR: Use log start offset as high watermark if current value is out of range (apache#4722)

  

  lindong28

  authored and

  hachikuji

  committedMar 18, 2018
  4391a42

Commits on Mar 14, 2018

• KAFKA-6640; Improve efficiency of KafkaAdminClient.describeTopics() (apache#4694)

  

  lindong28

  authored and

  hachikuji

  committedMar 14, 2018
  d935699

• KAFKA-3978; Ensure high watermark is always positive (apache#4695)

  

  lindong28

  authored and

  hachikuji

  committedMar 14, 2018
  6b08905

Commits on Mar 13, 2018

• KAFKA-6624; Prevent concurrent log flush and log deletion (apache#4663)

  

  lindong28

  authored and

  junrao

  committedMar 13, 2018
  1ea07b9

Commits on Dec 20, 2017

• KAFKA-6331; Fix transient failure in AdminClientIntegrationTest.testAlterReplicaLogDirs

  

  lindong28

  authored and

  ijuma

  committedDec 20, 2017
  cdb3955

Commits on Dec 18, 2017

• KAFKA-6258; SSLTransportLayer should keep reading from socket until either the buffer is full or the socket has no more data

  

  lindong28

  authored and

  hachikuji

  committedDec 18, 2017
  066bfc3

Commits on Dec 6, 2017

• KAFKA-6174; Add methods in AdminClient Options classes to restore binary compatibility with 0.11

  

  lindong28

  authored and

  ijuma

  committedDec 6, 2017
  078fd21

Commits on Nov 10, 2017

• KAFKA-6175; AbstractIndex should cache index file to avoid unnecessary disk access during resize()

  

  lindong28

  authored and

  becketqin

  committedNov 10, 2017
  12af521

Commits on Nov 6, 2017

• KAFKA-6172; Cache lastEntry in TimeIndex to avoid unnecessary disk access

  

  lindong28

  authored and

  becketqin

  committedNov 6, 2017
  0c89570

Commits on Oct 17, 2017

• KAFKA-5163; Support replicas movement between log directories (KIP-113)

  

  lindong28

  authored and

  junrao

  committedOct 17, 2017
  5cc162f

Commits on Oct 10, 2017

• KAFKA-6027; Access to log should throw KafkaStorageException after the log has been marked offline

  

  lindong28

  authored and

  junrao

  committedOct 10, 2017
  29c46dd

Commits on Oct 5, 2017

• KAFKA-5879; Controller should read the latest IsrChangeNotification znodes when handling IsrChangeNotification event

  

  lindong28

  authored and

  junrao

  committedOct 5, 2017
  b5b266e

• KAFKA-5767; Kafka server should halt if IBP < 1.0.0 and there is log directory failure

  

  lindong28

  authored and

  junrao

  committedOct 5, 2017
  20d9adb

Commits on Oct 4, 2017

• KAFKA-5864; ReplicaFetcherThread should not die due to replica in offline log directory

  

  lindong28

  authored and

  junrao

  committedOct 4, 2017
  cbef33f

Commits on Oct 3, 2017

• KAFKA-5843; Mx4jLoader.maybeLoad should only be executed if kafka_mx4jenable is set to true

  

  lindong28

  authored and

  ijuma

  committedOct 3, 2017
  716330a

• KAFKA-5995; Rename AlterReplicaDir to AlterReplicaDirs

  

  lindong28

  authored and

  junrao

  committedOct 3, 2017
  a1a5e93

Commits on Sep 26, 2017

• MINOR: Improve documentation of AdminClient and fix exception thrown

  

  lindong28

  authored and

  ijuma

  committedSep 26, 2017
  4e43a72

• KAFKA-5695; Test DeleteRecordsRequest in AuthorizerIntegrationTest

  

  lindong28

  authored and

  ijuma

  committedSep 26, 2017
  51611b1

Commits on Sep 3, 2017

• KAFKA-5694; Add AlterReplicaDirRequest and DescribeReplicaDirRequest (KIP-113 part-1)

  

  lindong28

  authored and

  becketqin

  committedSep 3, 2017
  adefc8e

Commits on Sep 1, 2017

• KAFKA-5759; Allow user to specify relative path as log directory

  

  lindong28

  authored and

  becketqin

  committedSep 1, 2017
  bc99998

Commits on Aug 2, 2017

• KAFKA-5663; Pass non-null logDirFailureChannel to Log.apply

  

  lindong28

  authored and

  ijuma

  committedAug 2, 2017
  fb21209

Commits on Jul 28, 2017

• KAFKA-5341; Add UnderMinIsrPartitionCount and per-partition UnderMinIsr metrics (KIP-164)

  

  lindong28

  authored and

  ewencp

  committedJul 28, 2017
  4003c93

Commits on Jul 26, 2017

• KAFKA-5627; Reduce classes needed for LeaderAndIsrPartitionState and MetadataPartitionState

  

  lindong28

  authored and

  becketqin

  committedJul 26, 2017
  f15cdbc

Commits on Jul 22, 2017

• KAFKA-4763; Handle disk failure for JBOD (KIP-112)

  

  lindong28

  authored and

  becketqin

  committedJul 22, 2017
  fc93fb4

Commits on Jun 30, 2017

• KAFKA-5544; The LastStableOffsetLag metric should be removed when partition is deleted

  

  lindong28

  authored and

  ijuma

  committedJun 30, 2017
  a16475e

Commits on May 12, 2017

• KAFKA-5078; PartitionRecords.fetchRecords(...) should defer exception to the next call if iterator has already moved across any valid record

  

  lindong28

  authored and

  becketqin

  committedMay 12, 2017
  911c768

Commits on Apr 27, 2017

• KAFKA-5086: Update topic expiry time in Metadata every time the topic metadata is requested

  

  lindong28

  authored and

  rajinisivaram

  committedApr 27, 2017
  5b5efd4

Commits on Apr 17, 2017

• KAFKA-5075; Defer exception to the next pollOnce() if consumer's fetch position has already increased

  

  lindong28

  authored and

  becketqin

  committedApr 17, 2017
  17ce2a7

Commits on Mar 30, 2017

• KAFKA-4973; Fix transient failure of AdminClientTest.testDeleteRecordsWithException

  

  lindong28

  authored and

  becketqin

  committedMar 30, 2017
  4b3ea06

Commits on Mar 28, 2017

• KAFKA-4586; Add purgeDataBefore() API (KIP-107)

  

  lindong28

  authored and

  becketqin

  committedMar 28, 2017
  8b05ad4

Commits on Mar 8, 2017

• KAFKA-4841; NetworkClient should only consider a connection to have failed after attempt to connect

  

  lindong28

  authored and

  ijuma

  committedMar 8, 2017
  c6bccdd

Pagination

PreviousNext