| jun...@apache.org |
[1/4] kafka git commit: KAFKA-4954; Request handler utilization quotas |
Mon, 01 May, 16:13 |
| jun...@apache.org |
[2/4] kafka git commit: KAFKA-4954; Request handler utilization quotas |
Mon, 01 May, 16:13 |
| jun...@apache.org |
[3/4] kafka git commit: KAFKA-4954; Request handler utilization quotas |
Mon, 01 May, 16:13 |
| jun...@apache.org |
[4/4] kafka git commit: KAFKA-4954; Request handler utilization quotas |
Mon, 01 May, 16:13 |
| j...@apache.org |
kafka git commit: KAFKA-5091; ReassignPartitionsCommand should protect against empty replica list assignment |
Mon, 01 May, 19:24 |
| ij...@apache.org |
[1/3] kafka git commit: KAFKA-3265; Add a public AdminClient API in Java (KIP-117) |
Mon, 01 May, 23:24 |
| ij...@apache.org |
[2/3] kafka git commit: KAFKA-3265; Add a public AdminClient API in Java (KIP-117) |
Mon, 01 May, 23:24 |
| ij...@apache.org |
[3/3] kafka git commit: KAFKA-3265; Add a public AdminClient API in Java (KIP-117) |
Mon, 01 May, 23:24 |
| guozh...@apache.org |
kafka git commit: KAFKA-5059 Follow-up: Remove broken locking and fix handleAddPartitions |
Mon, 01 May, 23:47 |
| ij...@apache.org |
kafka git commit: MINOR: Some cleanups in the transactional producer |
Tue, 02 May, 00:11 |
| guozh...@apache.org |
[1/2] kafka git commit: KAFKA-5136: move coordinatorEpoch from WriteTxnMarkerRequest to TxnMarkerEntry |
Tue, 02 May, 00:16 |
| guozh...@apache.org |
[2/2] kafka git commit: HOTFIX: fix unit tests for KAFKA-5136 |
Tue, 02 May, 00:16 |
| ij...@apache.org |
kafka git commit: MINOR: Describe topics should describe, not delete |
Tue, 02 May, 11:43 |
| ij...@apache.org |
kafka git commit: KAFKA-4623; Default unclean.leader.election.enabled to false (KIP-106) |
Tue, 02 May, 15:28 |
| jun...@apache.org |
kafka git commit: KAFKA-5107; remove preferred replica election state from ControllerContext |
Tue, 02 May, 15:41 |
| ij...@apache.org |
kafka git commit: KAFKA-5131; WriteTxnMarkers and complete commit/abort on partition immigration |
Wed, 03 May, 00:17 |
| ij...@apache.org |
kafka git commit: KAFKA-5131; WriteTxnMarkers and complete commit/abort on partition immigration [Forced Update!] |
Wed, 03 May, 00:18 |
| ij...@apache.org |
kafka git commit: KAFKA-5131; WriteTxnMarkers and complete commit/abort on partition immigration [Forced Update!] |
Wed, 03 May, 00:18 |
| ij...@apache.org |
kafka git commit: MINOR: Serialize the real isolationLevel in FetchRequest |
Wed, 03 May, 00:19 |
| ij...@apache.org |
kafka git commit: MINOR: Handle 0 futures in all() |
Wed, 03 May, 01:28 |
| ij...@apache.org |
kafka git commit: KAFA-4378: Fix Scala 2.12 "eta-expansion of zero-argument method" warnings |
Wed, 03 May, 09:17 |
| ij...@apache.org |
kafka git commit: KAFKA-3754; Add GC log retention policy to limit size of log |
Wed, 03 May, 09:51 |
| rsiva...@apache.org |
kafka git commit: KAFKA-4703: Test with two SASL_SSL listeners with different JAAS contexts |
Wed, 03 May, 20:09 |
| guozh...@apache.org |
kafka git commit: MINOR: Fix error logged if not enough alive brokers for transactions state topic |
Wed, 03 May, 20:26 |
| guozh...@apache.org |
kafka git commit: KAFKA-5144: renamed variables in MinTimestampTracker and added comments |
Wed, 03 May, 20:43 |
| guozh...@apache.org |
kafka git commit: KAFKA-5055: Fix Kafka Streams skipped-records-rate sensor bug |
Wed, 03 May, 21:19 |
| guozh...@apache.org |
[1/5] kafka git commit: KAFKA-5045: Clarify on KTable APIs for queryable stores |
Wed, 03 May, 23:15 |
| guozh...@apache.org |
[2/5] kafka git commit: KAFKA-5045: Clarify on KTable APIs for queryable stores |
Wed, 03 May, 23:15 |
| guozh...@apache.org |
[3/5] kafka git commit: KAFKA-5045: Clarify on KTable APIs for queryable stores |
Wed, 03 May, 23:16 |
| guozh...@apache.org |
[4/5] kafka git commit: KAFKA-5045: Clarify on KTable APIs for queryable stores |
Wed, 03 May, 23:16 |
| guozh...@apache.org |
[5/5] kafka git commit: KAFKA-5045: Clarify on KTable APIs for queryable stores |
Wed, 03 May, 23:16 |
| guozh...@apache.org |
kafka git commit: HOTFIX: fix potentially hanging test shouldAddStateStoreToRegexDefinedSource |
Thu, 04 May, 07:20 |
| guozh...@apache.org |
kafka git commit: KAFKA-4925: delay initial rebalance of consumer group |
Thu, 04 May, 18:14 |
| guozh...@apache.org |
kafka git commit: KAFKA-5118: Improve message for Kafka failed startup with non-Kafka data in data.dirs |
Thu, 04 May, 18:46 |
| guozh...@apache.org |
kafka git commit: KAFKA-5104: DumpLogSegments should not open index files with `rw` |
Thu, 04 May, 19:32 |
| ij...@apache.org |
kafka git commit: MINOR: Temporarily disable a few flaky tests |
Fri, 05 May, 03:52 |
| ij...@apache.org |
kafka git commit: KAFKA-4996; Fix findBugs warning in getOrCreateSegment |
Fri, 05 May, 03:59 |
| ij...@apache.org |
kafka git commit: KAFKA-5162; Add a reference to AdminClient to docs/api.html |
Fri, 05 May, 04:08 |
| ij...@apache.org |
kafka git commit: KAFKA-5137; Controlled shutdown timeout message improvement |
Fri, 05 May, 04:12 |
| guozh...@apache.org |
kafka git commit: KAFKA-5161: add code in reassign-partitions to check broker existence |
Fri, 05 May, 05:12 |
| ij...@apache.org |
kafka git commit: KAFKA-5170; KafkaAdminClientIntegrationTest should wait until metadata is propagated to all brokers |
Fri, 05 May, 07:48 |
| ij...@apache.org |
kafka git commit: KAFKA-5169; KafkaConsumer.close should be idempotent |
Fri, 05 May, 07:51 |
| guozh...@apache.org |
kafka git commit: KAFKA-5143: add kafka-broker-api-version.bat for Windows platform |
Fri, 05 May, 23:53 |
| j...@apache.org |
[1/6] kafka git commit: KAFKA-5121; Implement transaction index for KIP-98 |
Sat, 06 May, 18:51 |
| j...@apache.org |
[2/6] kafka git commit: KAFKA-5121; Implement transaction index for KIP-98 |
Sat, 06 May, 18:51 |
| j...@apache.org |
[3/6] kafka git commit: KAFKA-5121; Implement transaction index for KIP-98 |
Sat, 06 May, 18:51 |
| j...@apache.org |
[4/6] kafka git commit: KAFKA-5121; Implement transaction index for KIP-98 |
Sat, 06 May, 18:51 |
| j...@apache.org |
[5/6] kafka git commit: KAFKA-5121; Implement transaction index for KIP-98 |
Sat, 06 May, 18:51 |
| j...@apache.org |
[6/6] kafka git commit: KAFKA-5121; Implement transaction index for KIP-98 |
Sat, 06 May, 18:51 |
| guozh...@apache.org |
kafka git commit: KAFKA-5172: Fix fetchPrevious to find the correct session |
Mon, 08 May, 05:15 |
| guozh...@apache.org |
kafka git commit: KAFKA-5174: Have at least 2 threads for compaction and flushing in RocksDB |
Mon, 08 May, 16:40 |
| j...@apache.org |
kafka git commit: KAFKA-4839; Throw NoOffsetForPartitionException from poll once for all TopicPartitions affected |
Mon, 08 May, 16:44 |
| guozh...@apache.org |
kafka git commit: KAFKA-5174: Have at least 2 threads for compaction and flushing in RocksDB |
Mon, 08 May, 16:56 |
| j...@apache.org |
kafka git commit: KAFKA-3353; Remove deprecated producer configs |
Mon, 08 May, 17:00 |
| j...@apache.org |
kafka git commit: KAFKA-3763; Remove deprecated APIs for 0.11.0.0 |
Mon, 08 May, 17:39 |
| ij...@apache.org |
kafka git commit: KAFKA-5176; AdminClient: add controller and clusterId methods to DescribeClusterResults |
Tue, 09 May, 01:10 |
| guozh...@apache.org |
kafka git commit: KAFKA-4222: Adjust timeout in low resource environments |
Tue, 09 May, 16:23 |
| guozh...@apache.org |
kafka git commit: KAFKA-5126: Implement KIP-98 transactional methods in the MockProducer |
Tue, 09 May, 17:15 |
| j...@apache.org |
kafka git commit: HOTFIX: Increase kafkatest startup wait time on ConnectDistributed service |
Tue, 09 May, 21:03 |
| j...@apache.org |
kafka git commit: HOTFIX: Increase kafkatest startup wait time on ConnectDistributed service in 0.10.2 |
Tue, 09 May, 21:21 |
| guozh...@apache.org |
kafka git commit: KAFKA-4927: Fix KStreamsTestDriver to not throw NPE when KStream.to() sinks are used |
Tue, 09 May, 21:31 |
| guozh...@apache.org |
kafka git commit: KAFKA-5063: Fix flaky o.a.k.streams.integration.ResetIntegrationTest |
Tue, 09 May, 21:36 |
| gwens...@apache.org |
kafka git commit: MINOR: Add a release script that helps generate release candidates. |
Wed, 10 May, 20:09 |
| jun...@apache.org |
kafka git commit: KAFKA-5099; Replica Deletion Regression from KIP-101 |
Wed, 10 May, 20:45 |
| ij...@apache.org |
[1/2] kafka git commit: KAFKA-5184 KAFKA-5173; Various improvements to SASL tests |
Wed, 10 May, 21:38 |
| ij...@apache.org |
[2/2] kafka git commit: KAFKA-5184 KAFKA-5173; Various improvements to SASL tests |
Wed, 10 May, 21:38 |
| j...@apache.org |
kafka git commit: KAFKA-5213; Mark a MemoryRecordsBuilder as full as soon as the append stream is closed |
Thu, 11 May, 01:18 |
| ij...@apache.org |
kafka git commit: KAFKA-4422; Drop support for Scala 2.10 (KIP-119) |
Thu, 11 May, 07:08 |
| ij...@apache.org |
kafka git commit: KAFKA-5182; Close txn coordinator threads during broker shutdown |
Thu, 11 May, 12:37 |
| ij...@apache.org |
kafka git commit: HOTFIX: change compression codec in TransactionStateManager to UncompressedCodec |
Thu, 11 May, 12:59 |
| rsiva...@apache.org |
kafka git commit: MINOR: JoinGroupRequest V0 invalid rebalance timeout |
Thu, 11 May, 20:18 |
| ewe...@apache.org |
kafka-site git commit: Update Uber link on powered-by.html |
Thu, 11 May, 22:22 |
| ewe...@apache.org |
kafka git commit: KAFKA-4343: Expose Connector type in REST API (KIP-151) |
Fri, 12 May, 01:18 |
| ij...@apache.org |
kafka git commit: KAFKA-5713; Shutdown brokers in tests |
Fri, 12 May, 01:29 |
| j...@apache.org |
kafka git commit: KAFKA-5078; PartitionRecords.fetchRecords(...) should defer exception to the next call if iterator has already moved across any valid record |
Fri, 12 May, 03:03 |
| guozh...@apache.org |
kafka git commit: KAFKA-4317: Checkpoint state stores on commit interval |
Fri, 12 May, 06:18 |
| guozh...@apache.org |
kafka git commit: KAFKA-4881: add internal.leave.group.config to consumer |
Fri, 12 May, 06:26 |
| ij...@apache.org |
kafka git commit: KAFKA-5194; Include only client traffic in BytesOutPerSec metric (KIP-153) |
Fri, 12 May, 11:37 |
| ij...@apache.org |
kafka git commit: MINOR: Improve doc for num.x.threads configs |
Fri, 12 May, 12:15 |
| ij...@apache.org |
kafka git commit: MINOR: Set min isr to avoid race condition in ReplicationBytesIn initialisation |
Fri, 12 May, 16:07 |
| guozh...@apache.org |
kafka git commit: KAFKA-5132: abort long running transactions |
Fri, 12 May, 17:36 |
| j...@apache.org |
kafka git commit: MINOR: Fix consumer and producer to actually support metrics recording level |
Fri, 12 May, 17:38 |
| j...@apache.org |
[1/2] kafka git commit: KAFKA-5196; Make LogCleaner transaction-aware |
Fri, 12 May, 19:32 |
| j...@apache.org |
[2/2] kafka git commit: KAFKA-5196; Make LogCleaner transaction-aware |
Fri, 12 May, 19:32 |
| guozh...@apache.org |
[1/3] kafka git commit: KAFKA-5130: Refactor transaction coordinator's in-memory cache; plus fixes on transaction metadata synchronization |
Fri, 12 May, 22:01 |
| guozh...@apache.org |
[2/3] kafka git commit: KAFKA-5130: Refactor transaction coordinator's in-memory cache; plus fixes on transaction metadata synchronization |
Fri, 12 May, 22:01 |
| guozh...@apache.org |
[3/3] kafka git commit: KAFKA-5130: Refactor transaction coordinator's in-memory cache; plus fixes on transaction metadata synchronization |
Fri, 12 May, 22:01 |
| guozh...@apache.org |
kafka git commit: KAFKA-5216: Fix peekNextKey in cached window/session store iterators |
Fri, 12 May, 22:27 |
| j...@apache.org |
kafka git commit: KAFKA-5160; KIP-98 Broker side support for TxnOffsetCommitRequest |
Fri, 12 May, 23:28 |
| guozh...@apache.org |
kafka git commit: KAFKA-5216: Fix peekNextKey in cached window/session store iterators |
Fri, 12 May, 23:51 |
| guozh...@apache.org |
kafka git commit: KAFKA-4965: set internal.leave.group.on.close to false in StreamsConfig |
Fri, 12 May, 23:54 |
| guozh...@apache.org |
kafka git commit: KAFKA-5198: Synchronize on RocksDbStore#openIterators |
Sat, 13 May, 00:01 |
| guozh...@apache.org |
kafka git commit: KAFKA-5198: Synchronize on RocksDbStore#openIterators since it is accessed from multiple threads |
Sat, 13 May, 00:04 |
| ij...@apache.org |
kafka git commit: KAFKA-5227; Remove unsafe assertion, make jaas config safer |
Sat, 13 May, 00:41 |
| ij...@apache.org |
kafka git commit: KAFKA-4982; Add listener tags to socket-server-metrics (KIP-136) |
Sat, 13 May, 01:42 |
| ij...@apache.org |
kafka git commit: KAFKA-5180; Fix transient failure in ControllerIntegrationTest.testControllerMoveIncrementsControllerEpoch |
Sat, 13 May, 02:24 |
| j...@apache.org |
[1/2] kafka git commit: MINOR: Rename InitPidRequest/InitPidResponse to InitProducerIdRequest/InitProducerIdResponse |
Sat, 13 May, 03:02 |
| j...@apache.org |
[2/2] kafka git commit: MINOR: Rename InitPidRequest/InitPidResponse to InitProducerIdRequest/InitProducerIdResponse |
Sat, 13 May, 03:02 |
| guozh...@apache.org |
kafka git commit: HOTFIX: convert Bytes back to byte[] in MergedSortedCacheWindowStoreIteratorTest |
Sat, 13 May, 04:29 |
| guozh...@apache.org |
[1/3] kafka git commit: KAFKA-4144: Allow per stream/table timestamp extractor |
Sat, 13 May, 04:39 |