kafka-commits mailing list archives: May 2017

Site index · List index
Message list1 · 2 · 3 · 4 · Next »Thread · Author · Date
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
Message list1 · 2 · 3 · 4 · Next »Thread · Author · Date
Box list
Sep 201887
Aug 2018206
Jul 2018171
Jun 2018321
May 2018152
Apr 2018139
Mar 2018225
Feb 2018250
Jan 2018168
Dec 2017114
Nov 2017334
Oct 2017262
Sep 2017250
Aug 2017189
Jul 2017194
Jun 2017511
May 2017339
Apr 2017168
Mar 2017147
Feb 2017317
Jan 2017294
Dec 2016152
Nov 2016110
Oct 2016268
Sep 2016182
Aug 2016132
Jul 2016138
Jun 2016121
May 2016327
Apr 2016257
Mar 2016199
Feb 2016139
Jan 2016157
Dec 2015118
Nov 2015388
Oct 2015224
Sep 201576
Aug 201578
Jul 201560
Jun 201537
May 201525
Apr 201565
Mar 201537
Feb 201590
Jan 201582
Dec 201423
Nov 201439
Oct 201483
Sep 201433
Aug 201468
Jul 201437
Jun 201423
May 201436
Apr 201478
Mar 201486
Feb 201496
Jan 201422
Dec 201322
Nov 201340
Oct 201363
Sep 201365
Aug 201335
Jul 2013108
Jun 201340
May 201327
Apr 201364
Mar 201382
Feb 201336
Jan 2013131
Dec 201265
Nov 201252
Oct 2012108
Sep 201268
Aug 201263
Jul 201237
Jun 201234
May 20129
Apr 201211
Mar 201220
Feb 201231
Jan 201222
Dec 201119
Nov 201127
Oct 201163
Sep 201126
Aug 201179
Jul 20115