commits@kafka.apache.org, 2017-05

You are viewing a plain text version of this content. The canonical link for it is here.

- [1/4] kafka git commit: KAFKA-4954; Request handler utilization quotas - posted by ju...@apache.org on 2017/05/01 16:13:38 UTC, 0 replies.
- [2/4] kafka git commit: KAFKA-4954; Request handler utilization quotas - posted by ju...@apache.org on 2017/05/01 16:13:39 UTC, 0 replies.
- [3/4] kafka git commit: KAFKA-4954; Request handler utilization quotas - posted by ju...@apache.org on 2017/05/01 16:13:40 UTC, 0 replies.
- [4/4] kafka git commit: KAFKA-4954; Request handler utilization quotas - posted by ju...@apache.org on 2017/05/01 16:13:41 UTC, 0 replies.
- kafka git commit: KAFKA-5091; ReassignPartitionsCommand should protect against empty replica list assignment - posted by jg...@apache.org on 2017/05/01 19:24:22 UTC, 0 replies.
- [1/3] kafka git commit: KAFKA-3265; Add a public AdminClient API in Java (KIP-117) - posted by ij...@apache.org on 2017/05/01 23:24:48 UTC, 0 replies.
- [2/3] kafka git commit: KAFKA-3265; Add a public AdminClient API in Java (KIP-117) - posted by ij...@apache.org on 2017/05/01 23:24:49 UTC, 0 replies.
- [3/3] kafka git commit: KAFKA-3265; Add a public AdminClient API in Java (KIP-117) - posted by ij...@apache.org on 2017/05/01 23:24:50 UTC, 0 replies.
- kafka git commit: KAFKA-5059 Follow-up: Remove broken locking and fix handleAddPartitions - posted by gu...@apache.org on 2017/05/01 23:47:13 UTC, 0 replies.
- kafka git commit: MINOR: Some cleanups in the transactional producer - posted by ij...@apache.org on 2017/05/02 00:11:49 UTC, 0 replies.
- [1/2] kafka git commit: KAFKA-5136: move coordinatorEpoch from WriteTxnMarkerRequest to TxnMarkerEntry - posted by gu...@apache.org on 2017/05/02 00:16:48 UTC, 0 replies.
- [2/2] kafka git commit: HOTFIX: fix unit tests for KAFKA-5136 - posted by gu...@apache.org on 2017/05/02 00:16:49 UTC, 0 replies.
- kafka git commit: MINOR: Describe topics should describe, not delete - posted by ij...@apache.org on 2017/05/02 11:43:14 UTC, 0 replies.
- kafka git commit: KAFKA-4623; Default unclean.leader.election.enabled to false (KIP-106) - posted by ij...@apache.org on 2017/05/02 15:28:59 UTC, 0 replies.
- kafka git commit: KAFKA-5107; remove preferred replica election state from ControllerContext - posted by ju...@apache.org on 2017/05/02 15:41:23 UTC, 0 replies.
- kafka git commit: KAFKA-5131; WriteTxnMarkers and complete commit/abort on partition immigration - posted by ij...@apache.org on 2017/05/03 00:17:10 UTC, 0 replies.
- kafka git commit: KAFKA-5131; WriteTxnMarkers and complete commit/abort on partition immigration [Forced Update!] - posted by ij...@apache.org on 2017/05/03 00:18:08 UTC, 1 replies.
- kafka git commit: MINOR: Serialize the real isolationLevel in FetchRequest - posted by ij...@apache.org on 2017/05/03 00:19:46 UTC, 0 replies.
- kafka git commit: MINOR: Handle 0 futures in all() - posted by ij...@apache.org on 2017/05/03 01:28:08 UTC, 0 replies.
- kafka git commit: KAFA-4378: Fix Scala 2.12 "eta-expansion of zero-argument method" warnings - posted by ij...@apache.org on 2017/05/03 09:17:51 UTC, 0 replies.
- kafka git commit: KAFKA-3754; Add GC log retention policy to limit size of log - posted by ij...@apache.org on 2017/05/03 09:51:51 UTC, 0 replies.
- kafka git commit: KAFKA-4703: Test with two SASL_SSL listeners with different JAAS contexts - posted by rs...@apache.org on 2017/05/03 20:09:00 UTC, 0 replies.
- kafka git commit: MINOR: Fix error logged if not enough alive brokers for transactions state topic - posted by gu...@apache.org on 2017/05/03 20:26:11 UTC, 0 replies.
- kafka git commit: KAFKA-5144: renamed variables in MinTimestampTracker and added comments - posted by gu...@apache.org on 2017/05/03 20:43:23 UTC, 0 replies.
- kafka git commit: KAFKA-5055: Fix Kafka Streams skipped-records-rate sensor bug - posted by gu...@apache.org on 2017/05/03 21:19:29 UTC, 0 replies.
- [1/5] kafka git commit: KAFKA-5045: Clarify on KTable APIs for queryable stores - posted by gu...@apache.org on 2017/05/03 23:15:58 UTC, 0 replies.
- [2/5] kafka git commit: KAFKA-5045: Clarify on KTable APIs for queryable stores - posted by gu...@apache.org on 2017/05/03 23:15:59 UTC, 0 replies.
- [3/5] kafka git commit: KAFKA-5045: Clarify on KTable APIs for queryable stores - posted by gu...@apache.org on 2017/05/03 23:16:00 UTC, 0 replies.
- [4/5] kafka git commit: KAFKA-5045: Clarify on KTable APIs for queryable stores - posted by gu...@apache.org on 2017/05/03 23:16:01 UTC, 0 replies.
- [5/5] kafka git commit: KAFKA-5045: Clarify on KTable APIs for queryable stores - posted by gu...@apache.org on 2017/05/03 23:16:02 UTC, 0 replies.
- kafka git commit: HOTFIX: fix potentially hanging test shouldAddStateStoreToRegexDefinedSource - posted by gu...@apache.org on 2017/05/04 07:20:19 UTC, 0 replies.
- kafka git commit: KAFKA-4925: delay initial rebalance of consumer group - posted by gu...@apache.org on 2017/05/04 18:14:31 UTC, 0 replies.
- kafka git commit: KAFKA-5118: Improve message for Kafka failed startup with non-Kafka data in data.dirs - posted by gu...@apache.org on 2017/05/04 18:46:09 UTC, 1 replies.
- kafka git commit: KAFKA-5104: DumpLogSegments should not open index files with `rw` - posted by gu...@apache.org on 2017/05/04 19:32:26 UTC, 0 replies.
- kafka git commit: MINOR: Temporarily disable a few flaky tests - posted by ij...@apache.org on 2017/05/05 03:52:02 UTC, 0 replies.
- kafka git commit: KAFKA-4996; Fix findBugs warning in getOrCreateSegment - posted by ij...@apache.org on 2017/05/05 03:59:41 UTC, 0 replies.
- kafka git commit: KAFKA-5162; Add a reference to AdminClient to docs/api.html - posted by ij...@apache.org on 2017/05/05 04:08:35 UTC, 0 replies.
- kafka git commit: KAFKA-5137; Controlled shutdown timeout message improvement - posted by ij...@apache.org on 2017/05/05 04:12:13 UTC, 0 replies.
- kafka git commit: KAFKA-5161: add code in reassign-partitions to check broker existence - posted by gu...@apache.org on 2017/05/05 05:12:32 UTC, 0 replies.
- kafka git commit: KAFKA-5170; KafkaAdminClientIntegrationTest should wait until metadata is propagated to all brokers - posted by ij...@apache.org on 2017/05/05 07:48:27 UTC, 0 replies.
- kafka git commit: KAFKA-5169; KafkaConsumer.close should be idempotent - posted by ij...@apache.org on 2017/05/05 07:51:35 UTC, 0 replies.
- kafka git commit: KAFKA-5143: add kafka-broker-api-version.bat for Windows platform - posted by gu...@apache.org on 2017/05/05 23:53:35 UTC, 0 replies.
- [1/6] kafka git commit: KAFKA-5121; Implement transaction index for KIP-98 - posted by jg...@apache.org on 2017/05/06 18:51:10 UTC, 0 replies.
- [2/6] kafka git commit: KAFKA-5121; Implement transaction index for KIP-98 - posted by jg...@apache.org on 2017/05/06 18:51:11 UTC, 0 replies.
- [3/6] kafka git commit: KAFKA-5121; Implement transaction index for KIP-98 - posted by jg...@apache.org on 2017/05/06 18:51:12 UTC, 0 replies.
- [4/6] kafka git commit: KAFKA-5121; Implement transaction index for KIP-98 - posted by jg...@apache.org on 2017/05/06 18:51:13 UTC, 0 replies.
- [5/6] kafka git commit: KAFKA-5121; Implement transaction index for KIP-98 - posted by jg...@apache.org on 2017/05/06 18:51:14 UTC, 0 replies.
- [6/6] kafka git commit: KAFKA-5121; Implement transaction index for KIP-98 - posted by jg...@apache.org on 2017/05/06 18:51:15 UTC, 0 replies.
- kafka git commit: KAFKA-5172: Fix fetchPrevious to find the correct session - posted by gu...@apache.org on 2017/05/08 05:15:43 UTC, 0 replies.
- kafka git commit: KAFKA-5174: Have at least 2 threads for compaction and flushing in RocksDB - posted by gu...@apache.org on 2017/05/08 16:40:58 UTC, 1 replies.
- kafka git commit: KAFKA-4839; Throw NoOffsetForPartitionException from poll once for all TopicPartitions affected - posted by jg...@apache.org on 2017/05/08 16:44:49 UTC, 0 replies.
- kafka git commit: KAFKA-3353; Remove deprecated producer configs - posted by jg...@apache.org on 2017/05/08 17:00:08 UTC, 0 replies.
- kafka git commit: KAFKA-3763; Remove deprecated APIs for 0.11.0.0 - posted by jg...@apache.org on 2017/05/08 17:39:23 UTC, 0 replies.
- kafka git commit: KAFKA-5176; AdminClient: add controller and clusterId methods to DescribeClusterResults - posted by ij...@apache.org on 2017/05/09 01:10:57 UTC, 0 replies.
- kafka git commit: KAFKA-4222: Adjust timeout in low resource environments - posted by gu...@apache.org on 2017/05/09 16:23:40 UTC, 0 replies.
- kafka git commit: KAFKA-5126: Implement KIP-98 transactional methods in the MockProducer - posted by gu...@apache.org on 2017/05/09 17:15:43 UTC, 0 replies.
- kafka git commit: HOTFIX: Increase kafkatest startup wait time on ConnectDistributed service - posted by jg...@apache.org on 2017/05/09 21:03:37 UTC, 0 replies.
- kafka git commit: HOTFIX: Increase kafkatest startup wait time on ConnectDistributed service in 0.10.2 - posted by jg...@apache.org on 2017/05/09 21:21:02 UTC, 0 replies.
- kafka git commit: KAFKA-4927: Fix KStreamsTestDriver to not throw NPE when KStream.to() sinks are used - posted by gu...@apache.org on 2017/05/09 21:31:53 UTC, 0 replies.
- kafka git commit: KAFKA-5063: Fix flaky o.a.k.streams.integration.ResetIntegrationTest - posted by gu...@apache.org on 2017/05/09 21:36:00 UTC, 0 replies.
- kafka git commit: MINOR: Add a release script that helps generate release candidates. - posted by gw...@apache.org on 2017/05/10 20:09:32 UTC, 0 replies.
- kafka git commit: KAFKA-5099; Replica Deletion Regression from KIP-101 - posted by ju...@apache.org on 2017/05/10 20:45:36 UTC, 0 replies.
- [1/2] kafka git commit: KAFKA-5184 KAFKA-5173; Various improvements to SASL tests - posted by ij...@apache.org on 2017/05/10 21:38:54 UTC, 0 replies.
- [2/2] kafka git commit: KAFKA-5184 KAFKA-5173; Various improvements to SASL tests - posted by ij...@apache.org on 2017/05/10 21:38:55 UTC, 0 replies.
- kafka git commit: KAFKA-5213; Mark a MemoryRecordsBuilder as full as soon as the append stream is closed - posted by jg...@apache.org on 2017/05/11 01:18:58 UTC, 0 replies.
- kafka git commit: KAFKA-4422; Drop support for Scala 2.10 (KIP-119) - posted by ij...@apache.org on 2017/05/11 07:08:16 UTC, 0 replies.
- kafka git commit: KAFKA-5182; Close txn coordinator threads during broker shutdown - posted by ij...@apache.org on 2017/05/11 12:37:05 UTC, 0 replies.
- kafka git commit: HOTFIX: change compression codec in TransactionStateManager to UncompressedCodec - posted by ij...@apache.org on 2017/05/11 12:59:57 UTC, 0 replies.
- kafka git commit: MINOR: JoinGroupRequest V0 invalid rebalance timeout - posted by rs...@apache.org on 2017/05/11 20:18:45 UTC, 0 replies.
- kafka-site git commit: Update Uber link on powered-by.html - posted by ew...@apache.org on 2017/05/11 22:22:17 UTC, 0 replies.
- kafka git commit: KAFKA-4343: Expose Connector type in REST API (KIP-151) - posted by ew...@apache.org on 2017/05/12 01:18:30 UTC, 0 replies.
- kafka git commit: KAFKA-5713; Shutdown brokers in tests - posted by ij...@apache.org on 2017/05/12 01:29:51 UTC, 0 replies.
- kafka git commit: KAFKA-5078; PartitionRecords.fetchRecords(...) should defer exception to the next call if iterator has already moved across any valid record - posted by jq...@apache.org on 2017/05/12 03:03:36 UTC, 0 replies.
- kafka git commit: KAFKA-4317: Checkpoint state stores on commit interval - posted by gu...@apache.org on 2017/05/12 06:18:27 UTC, 0 replies.
- kafka git commit: KAFKA-4881: add internal.leave.group.config to consumer - posted by gu...@apache.org on 2017/05/12 06:26:59 UTC, 0 replies.
- kafka git commit: KAFKA-5194; Include only client traffic in BytesOutPerSec metric (KIP-153) - posted by ij...@apache.org on 2017/05/12 11:37:22 UTC, 0 replies.
- kafka git commit: MINOR: Improve doc for num.x.threads configs - posted by ij...@apache.org on 2017/05/12 12:15:44 UTC, 0 replies.
- kafka git commit: MINOR: Set min isr to avoid race condition in ReplicationBytesIn initialisation - posted by ij...@apache.org on 2017/05/12 16:07:54 UTC, 0 replies.
- kafka git commit: KAFKA-5132: abort long running transactions - posted by gu...@apache.org on 2017/05/12 17:36:04 UTC, 0 replies.
- kafka git commit: MINOR: Fix consumer and producer to actually support metrics recording level - posted by jg...@apache.org on 2017/05/12 17:38:17 UTC, 0 replies.
- [1/2] kafka git commit: KAFKA-5196; Make LogCleaner transaction-aware - posted by jg...@apache.org on 2017/05/12 19:32:52 UTC, 0 replies.
- [2/2] kafka git commit: KAFKA-5196; Make LogCleaner transaction-aware - posted by jg...@apache.org on 2017/05/12 19:32:53 UTC, 0 replies.
- [1/3] kafka git commit: KAFKA-5130: Refactor transaction coordinator's in-memory cache; plus fixes on transaction metadata synchronization - posted by gu...@apache.org on 2017/05/12 22:01:05 UTC, 0 replies.
- [2/3] kafka git commit: KAFKA-5130: Refactor transaction coordinator's in-memory cache; plus fixes on transaction metadata synchronization - posted by gu...@apache.org on 2017/05/12 22:01:06 UTC, 0 replies.
- [3/3] kafka git commit: KAFKA-5130: Refactor transaction coordinator's in-memory cache; plus fixes on transaction metadata synchronization - posted by gu...@apache.org on 2017/05/12 22:01:07 UTC, 0 replies.
- kafka git commit: KAFKA-5216: Fix peekNextKey in cached window/session store iterators - posted by gu...@apache.org on 2017/05/12 22:27:06 UTC, 1 replies.
- kafka git commit: KAFKA-5160; KIP-98 Broker side support for TxnOffsetCommitRequest - posted by jg...@apache.org on 2017/05/12 23:28:38 UTC, 0 replies.
- kafka git commit: KAFKA-4965: set internal.leave.group.on.close to false in StreamsConfig - posted by gu...@apache.org on 2017/05/12 23:54:45 UTC, 0 replies.
- kafka git commit: KAFKA-5198: Synchronize on RocksDbStore#openIterators - posted by gu...@apache.org on 2017/05/13 00:01:29 UTC, 0 replies.
- kafka git commit: KAFKA-5198: Synchronize on RocksDbStore#openIterators since it is accessed from multiple threads - posted by gu...@apache.org on 2017/05/13 00:04:01 UTC, 0 replies.
- kafka git commit: KAFKA-5227; Remove unsafe assertion, make jaas config safer - posted by ij...@apache.org on 2017/05/13 00:41:15 UTC, 0 replies.
- kafka git commit: KAFKA-4982; Add listener tags to socket-server-metrics (KIP-136) - posted by ij...@apache.org on 2017/05/13 01:42:56 UTC, 0 replies.
- kafka git commit: KAFKA-5180; Fix transient failure in ControllerIntegrationTest.testControllerMoveIncrementsControllerEpoch - posted by ij...@apache.org on 2017/05/13 02:24:04 UTC, 0 replies.
- [1/2] kafka git commit: MINOR: Rename InitPidRequest/InitPidResponse to InitProducerIdRequest/InitProducerIdResponse - posted by jg...@apache.org on 2017/05/13 03:02:22 UTC, 0 replies.
- [2/2] kafka git commit: MINOR: Rename InitPidRequest/InitPidResponse to InitProducerIdRequest/InitProducerIdResponse - posted by jg...@apache.org on 2017/05/13 03:02:23 UTC, 0 replies.
- kafka git commit: HOTFIX: convert Bytes back to byte[] in MergedSortedCacheWindowStoreIteratorTest - posted by gu...@apache.org on 2017/05/13 04:29:15 UTC, 0 replies.
- [1/3] kafka git commit: KAFKA-4144: Allow per stream/table timestamp extractor - posted by gu...@apache.org on 2017/05/13 04:39:07 UTC, 0 replies.
- [2/3] kafka git commit: KAFKA-4144: Allow per stream/table timestamp extractor - posted by gu...@apache.org on 2017/05/13 04:39:08 UTC, 0 replies.
- [3/3] kafka git commit: KAFKA-4144: Allow per stream/table timestamp extractor - posted by gu...@apache.org on 2017/05/13 04:39:09 UTC, 0 replies.
- kafka git commit: KAFKA-5167: fix unreleased state lock due to uncaught exception when closing a task - posted by gu...@apache.org on 2017/05/13 05:50:08 UTC, 0 replies.
- kafka git commit: MINOR: Close ZooKeeper clients in a couple of tests - posted by ij...@apache.org on 2017/05/13 07:07:42 UTC, 0 replies.
- kafka git commit: MINOR: Improve shutdown sequence - posted by ij...@apache.org on 2017/05/13 07:15:46 UTC, 0 replies.
- kafka git commit: MINOR: Various small improvements to kafka.metrics.MetricsTest - posted by ij...@apache.org on 2017/05/13 08:45:26 UTC, 0 replies.
- kafka git commit: MINOR: Handle nulls in NonEmptyListValidator - posted by ij...@apache.org on 2017/05/14 17:33:09 UTC, 0 replies.
- kafka git commit: KAFKA-5230; Fix conversion of Class configs to handle nested classes properly - posted by ij...@apache.org on 2017/05/14 23:39:30 UTC, 1 replies.
- [1/2] kafka git commit: MINOR: Consolidate Topic classes - posted by ij...@apache.org on 2017/05/15 08:10:20 UTC, 0 replies.
- [2/2] kafka git commit: MINOR: Consolidate Topic classes - posted by ij...@apache.org on 2017/05/15 08:10:21 UTC, 0 replies.
- kafka git commit: KAFKA-5232; Fix Log.parseTopicPartitionName to handle deleted topics with a period in the name - posted by ij...@apache.org on 2017/05/15 08:17:42 UTC, 1 replies.
- kafka git commit: MINOR: Fix one flaky test in MetricsTest and improve checks for another - posted by ij...@apache.org on 2017/05/15 13:08:29 UTC, 0 replies.
- kafka git commit: KAFKA-5203; Metrics: fix resetting of histogram sample - posted by ju...@apache.org on 2017/05/15 17:50:51 UTC, 0 replies.
- kafka git commit: HOTFIX: AddOffsetsToTxnResponse using incorrect schema in parse - posted by jg...@apache.org on 2017/05/15 18:15:28 UTC, 0 replies.
- kafka git commit: KAFKA-5206: Use default aggSerde if no user-overridden is provided in RocksDBSessionStore - posted by gu...@apache.org on 2017/05/15 18:18:15 UTC, 1 replies.
- kafka git commit: MINOR: Eliminate PID terminology from non test code - posted by jg...@apache.org on 2017/05/15 18:28:47 UTC, 0 replies.
- kafka git commit: KAFKA-5206: Use default values of keySerde if it is not specified by users in CachingSessionStore - posted by gu...@apache.org on 2017/05/15 18:51:18 UTC, 1 replies.
- kafka git commit: KAFKA-5205: Use default values of keySerde if it is not specified by users in CachingSessionStore [Forced Update!] - posted by gu...@apache.org on 2017/05/15 18:57:39 UTC, 1 replies.
- kafka git commit: KAFKA-5248; Remove unused/unneeded retention time in TxnOffsetCommitRequest - posted by jg...@apache.org on 2017/05/15 19:59:07 UTC, 0 replies.
- kafka git commit: KAFKA-5244; Refactor BrokerTopicStats and ControllerStats so that they are classes - posted by ij...@apache.org on 2017/05/15 21:35:46 UTC, 0 replies.
- kafka git commit: KAFKA-5179; Log connection termination during authentication - posted by rs...@apache.org on 2017/05/15 22:13:38 UTC, 0 replies.
- kafka git commit: KAFKA-5249; Fix incorrect producer snapshot offsets when recovering segments - posted by ju...@apache.org on 2017/05/15 22:23:31 UTC, 0 replies.
- kafka git commit: MINOR: Fix bug in `waitUntilLeaderIsElectedOrChanged` and simplify result type - posted by ju...@apache.org on 2017/05/15 23:08:11 UTC, 0 replies.
- kafka git commit: KAFKA-5252; Fix transient failures LogCleanerTest testCommitMarkerRemoval and testAbortMarkerRemoval - posted by jg...@apache.org on 2017/05/16 05:56:27 UTC, 0 replies.
- kafka git commit: MINOR: Print offset and size in sendFetches - posted by gu...@apache.org on 2017/05/16 06:34:34 UTC, 0 replies.
- kafka git commit: KAFKA-5175; Fix transient failure in ControllerIntegrationTest.testPreferredReplicaLeaderElection - posted by ij...@apache.org on 2017/05/16 09:46:49 UTC, 0 replies.
- kafka git commit: KAFKA-5215; Small Javadoc fixes for AdminClient#describeTopics - posted by ij...@apache.org on 2017/05/16 10:56:32 UTC, 0 replies.
- kafka git commit: KAFKA-5129; Add ACL checks for Transactional APIs - posted by jg...@apache.org on 2017/05/16 17:14:18 UTC, 0 replies.
- kafka git commit: MINOR: Some minor improvements to TxnOffsetCommit handling - posted by jg...@apache.org on 2017/05/16 20:23:46 UTC, 0 replies.
- kafka git commit: KAFKA-5241: GlobalKTable should checkpoint offsets after restoring state - posted by gu...@apache.org on 2017/05/16 20:59:22 UTC, 1 replies.
- kafka git commit: KAFKA-5166: Add option "dry run" to Streams application reset tool - posted by gu...@apache.org on 2017/05/16 21:24:33 UTC, 0 replies.
- kafka git commit: KAFKA-4957; Request rate quotas documentation - posted by ju...@apache.org on 2017/05/16 23:36:30 UTC, 0 replies.
- [1/3] kafka git commit: KAFKA-4923: Add Exactly-Once Semantics to Streams - posted by gu...@apache.org on 2017/05/17 00:23:14 UTC, 0 replies.
- [2/3] kafka git commit: KAFKA-4923: Add Exactly-Once Semantics to Streams - posted by gu...@apache.org on 2017/05/17 00:23:15 UTC, 0 replies.
- [3/3] kafka git commit: KAFKA-4923: Add Exactly-Once Semantics to Streams - posted by gu...@apache.org on 2017/05/17 00:23:16 UTC, 0 replies.
- kafka git commit: KAFKA-4714; Flatten and Cast single message transforms (KIP-66) - posted by jg...@apache.org on 2017/05/17 06:07:49 UTC, 0 replies.
- kafka git commit: MINOR: Use new-consumer config in MirrorMaker doc - posted by ij...@apache.org on 2017/05/17 11:36:42 UTC, 0 replies.
- kafka git commit: MINOR: Make some constructors in admin package public - posted by ij...@apache.org on 2017/05/17 11:42:09 UTC, 0 replies.
- kafka git commit: KAFKA-5182: Reduce rebalance timeouts in request quota test - posted by rs...@apache.org on 2017/05/17 13:41:39 UTC, 0 replies.
- kafka git commit: KAFKA-4772: Exploit #peek to implement #print() and other methods - posted by gu...@apache.org on 2017/05/17 18:15:34 UTC, 0 replies.
- kafka git commit: KAFKA-4743; [KIP-122] Add Reset Consumer Group Offsets tooling - posted by jg...@apache.org on 2017/05/17 21:27:00 UTC, 0 replies.
- kafka git commit: KAFKA-5188; Integration tests for transactions - posted by jg...@apache.org on 2017/05/17 23:21:55 UTC, 0 replies.
- kafka git commit: KAFKA-5231: Bump up producer epoch when sending abort txn markers on InitPid - posted by gu...@apache.org on 2017/05/18 01:05:15 UTC, 0 replies.
- kafka git commit: KAFKA-5036; hold onto the leader lock in Partition while serving an O… - posted by ju...@apache.org on 2017/05/18 01:54:50 UTC, 0 replies.
- [1/3] kafka git commit: KAFKA-3266; Describe, Create and Delete ACLs Admin APIs (KIP-140) - posted by ij...@apache.org on 2017/05/18 02:31:02 UTC, 0 replies.
- [2/3] kafka git commit: KAFKA-3266; Describe, Create and Delete ACLs Admin APIs (KIP-140) - posted by ij...@apache.org on 2017/05/18 02:31:03 UTC, 0 replies.
- [3/3] kafka git commit: KAFKA-3266; Describe, Create and Delete ACLs Admin APIs (KIP-140) - posted by ij...@apache.org on 2017/05/18 02:31:04 UTC, 0 replies.
- [1/2] kafka git commit: KAFKA-2273; Sticky partition assignment strategy (KIP-54) - posted by jg...@apache.org on 2017/05/18 03:17:06 UTC, 0 replies.
- [2/2] kafka git commit: KAFKA-2273; Sticky partition assignment strategy (KIP-54) - posted by jg...@apache.org on 2017/05/18 03:17:07 UTC, 0 replies.
- [1/3] kafka git commit: KAFKA-3267; Describe and Alter Configs Admin APIs (KIP-133) - posted by ij...@apache.org on 2017/05/18 05:51:22 UTC, 0 replies.
- [2/3] kafka git commit: KAFKA-3267; Describe and Alter Configs Admin APIs (KIP-133) - posted by ij...@apache.org on 2017/05/18 05:51:23 UTC, 0 replies.
- [3/3] kafka git commit: KAFKA-3267; Describe and Alter Configs Admin APIs (KIP-133) - posted by ij...@apache.org on 2017/05/18 05:51:24 UTC, 0 replies.
- kafka git commit: KAFKA-5210: Application Reset Tool does not need to seek for internal topics - posted by gu...@apache.org on 2017/05/18 06:15:26 UTC, 0 replies.
- kafka git commit: TRIVIAL: Remove redundant asMap utility in ConsumerProtocol - posted by ij...@apache.org on 2017/05/18 10:27:58 UTC, 0 replies.
- kafka git commit: KAFKA-4222; QueryableIntegrationTest.queryOnRebalance transient failure - posted by ij...@apache.org on 2017/05/18 10:28:55 UTC, 0 replies.
- kafka git commit: KAFKA-5258; Move all partition and replica state transition rules into their states - posted by ij...@apache.org on 2017/05/18 10:37:35 UTC, 0 replies.
- [1/3] kafka git commit: KAFKA-3487: Support classloading isolation in Connect (KIP-146) - posted by ew...@apache.org on 2017/05/18 17:39:21 UTC, 0 replies.
- [2/3] kafka git commit: KAFKA-3487: Support classloading isolation in Connect (KIP-146) - posted by ew...@apache.org on 2017/05/18 17:39:22 UTC, 0 replies.
- [3/3] kafka git commit: KAFKA-3487: Support classloading isolation in Connect (KIP-146) - posted by ew...@apache.org on 2017/05/18 17:39:23 UTC, 0 replies.
- kafka git commit: KAFKA-5268; Fix bounce test transient failure by clearing partitions before writing Complete state to transaction log - posted by jg...@apache.org on 2017/05/18 18:17:43 UTC, 0 replies.
- kafka git commit: KAFKA-5171; TC should not accept empty string transactional id - posted by jg...@apache.org on 2017/05/18 18:40:09 UTC, 0 replies.
- kafka git commit: KAFKA-5033; Set default retries for the idempotent producer to be infinite - posted by jg...@apache.org on 2017/05/18 20:07:19 UTC, 0 replies.
- kafka git commit: KAFKA-3070: SASL unit tests dont work with IBM JDK - posted by rs...@apache.org on 2017/05/18 20:11:33 UTC, 0 replies.
- kafka git commit: KAFKA-5250: Do fetch down conversion after throttling - posted by ij...@apache.org on 2017/05/18 21:43:38 UTC, 0 replies.
- kafka git commit: HOTFIX: Close transactional producers in all new tests - posted by jg...@apache.org on 2017/05/18 22:21:24 UTC, 0 replies.
- kafka git commit: KAFKA-4667: Connect uses AdminClient to create internal topics when needed (KIP-154) - posted by ew...@apache.org on 2017/05/18 23:02:42 UTC, 0 replies.
- kafka git commit: MINOR: Small refactor of request quotas handling in KafkaApis - posted by ij...@apache.org on 2017/05/18 23:14:29 UTC, 0 replies.
- [kafka] Git Push Summary - posted by ij...@apache.org on 2017/05/18 23:15:12 UTC, 0 replies.
- [1/3] kafka git commit: KAFKA-5192: add WindowStore range scan (KIP-155) - posted by gu...@apache.org on 2017/05/19 00:02:55 UTC, 1 replies.
- [2/3] kafka git commit: KAFKA-5192: add WindowStore range scan (KIP-155) - posted by gu...@apache.org on 2017/05/19 00:02:56 UTC, 1 replies.
- [3/3] kafka git commit: KAFKA-5192: add WindowStore range scan (KIP-155) - posted by gu...@apache.org on 2017/05/19 00:02:57 UTC, 1 replies.
- kafka git commit: MINOR: Bump Kafka version to 0.11.1.0-SNAPSHOT - posted by ij...@apache.org on 2017/05/19 09:20:25 UTC, 0 replies.
- kafka git commit: KAFKA-3878; Support exponential backoff policy via reconnect.backoff.max (KIP-144) - posted by ij...@apache.org on 2017/05/19 13:09:58 UTC, 1 replies.
- kafka git commit: KAFKA-4714; TimestampConverter transformation (KIP-66) - posted by jg...@apache.org on 2017/05/19 18:28:14 UTC, 1 replies.
- kafka git commit: MINOR: improve descriptions of Streams reset tool options - posted by gu...@apache.org on 2017/05/19 23:29:29 UTC, 1 replies.
- kafka git commit: KAFKA-5269; Retry on unknown topic/partition error in transactional requests - posted by jg...@apache.org on 2017/05/20 01:52:04 UTC, 1 replies.
- kafka git commit: KAFKA-4208; Add record headers upgrade doc - posted by jq...@apache.org on 2017/05/21 21:34:25 UTC, 0 replies.
- kafka git commit: KAFKA-3995; KIP-126 Allow KafkaProducer to split and resend oversized batches - posted by jq...@apache.org on 2017/05/22 00:31:36 UTC, 1 replies.
- kafka git commit: HOTFIX: In Connect test with auto topic creation disabled, ensure precreated topic is always used - posted by ew...@apache.org on 2017/05/22 01:04:40 UTC, 1 replies.
- kafka git commit: MINOR: Fix race condition in TestVerifiableProducer sanity test - posted by ew...@apache.org on 2017/05/22 01:23:22 UTC, 1 replies.
- kafka git commit: KAFKA-4923: Modify compatibility test for Exaclty-Once Semantics in Streams - posted by gu...@apache.org on 2017/05/22 05:16:22 UTC, 1 replies.
- kafka git commit: KAFKA-5294: PlainSaslServerFactory should allow a null Map - posted by rs...@apache.org on 2017/05/22 10:01:11 UTC, 1 replies.
- kafka git commit: KAFKA-5289: handleStopReplica should not send a second response - posted by rs...@apache.org on 2017/05/22 12:39:01 UTC, 1 replies.
- kafka git commit: KAFKA-5303, KAFKA-5305: Improve logging when fetches fail in ReplicaFetcherThread - posted by rs...@apache.org on 2017/05/22 15:08:29 UTC, 1 replies.
- kafka git commit: KAFKA-5277; Sticky Assignor should not cache previous assignment (KIP-54 follow-up) - posted by jg...@apache.org on 2017/05/22 18:01:09 UTC, 1 replies.
- kafka git commit: KAFKA-5186; Avoid expensive log scan to build producer state when upgrading - posted by jg...@apache.org on 2017/05/22 22:41:32 UTC, 1 replies.
- kafka git commit: HOTFIX: Replace JDK download and fix missing argument in Vagrant provisioning script - posted by ew...@apache.org on 2017/05/23 00:47:03 UTC, 4 replies.
- kafka git commit: MINOR: Broker should disallow downconversion of transactional/idempotent records - posted by jg...@apache.org on 2017/05/23 03:01:37 UTC, 1 replies.
- kafka git commit: KAFKA-5247; Materialize committed offsets in offset order - posted by jg...@apache.org on 2017/05/23 16:46:59 UTC, 1 replies.
- kafka git commit: MINOR: remove TransactionCoordinatorIntegrationTest - posted by gu...@apache.org on 2017/05/23 16:50:49 UTC, 1 replies.
- kafka git commit: MINOR: Log transaction metadata state transitions plus a few cleanups - posted by jg...@apache.org on 2017/05/23 16:57:03 UTC, 1 replies.
- kafka git commit: MINOR: improve EmbeddedKafkaCluster test utility for deleting topics - posted by gu...@apache.org on 2017/05/23 18:53:16 UTC, 1 replies.
- [1/2] kafka git commit: KAFKA-5280: Protect txn metadata map with read-write lock - posted by gu...@apache.org on 2017/05/23 20:34:47 UTC, 1 replies.
- [2/2] kafka git commit: KAFKA-5280: Protect txn metadata map with read-write lock - posted by gu...@apache.org on 2017/05/23 20:34:48 UTC, 1 replies.
- kafka git commit: KAFKA-5310; reset ControllerContext during resignation - posted by ju...@apache.org on 2017/05/23 23:30:01 UTC, 1 replies.
- kafka git commit: KAFKA-5135; Controller Health Metrics (KIP-143) - posted by ij...@apache.org on 2017/05/23 23:38:18 UTC, 1 replies.
- kafka git commit: KAFKA-5081: Force jackson-annotations to a single version matching expected Jackson version - posted by ew...@apache.org on 2017/05/24 05:07:22 UTC, 1 replies.
- kafka git commit: KAFKA-5273: Make KafkaConsumer.committed query the server for all partitions - posted by gu...@apache.org on 2017/05/24 06:09:00 UTC, 1 replies.
- kafka git commit: MINOR: Improve the help doc of consumer group command - posted by jg...@apache.org on 2017/05/24 16:14:23 UTC, 1 replies.
- [1/5] kafka git commit: KAFKA-5259; TransactionalId auth implies ProducerId auth - posted by jg...@apache.org on 2017/05/24 22:28:51 UTC, 1 replies.
- [2/5] kafka git commit: KAFKA-5259; TransactionalId auth implies ProducerId auth - posted by jg...@apache.org on 2017/05/24 22:28:52 UTC, 1 replies.
- [3/5] kafka git commit: KAFKA-5259; TransactionalId auth implies ProducerId auth - posted by jg...@apache.org on 2017/05/24 22:28:53 UTC, 1 replies.
- [4/5] kafka git commit: KAFKA-5259; TransactionalId auth implies ProducerId auth - posted by jg...@apache.org on 2017/05/24 22:28:54 UTC, 1 replies.
- [5/5] kafka git commit: KAFKA-5259; TransactionalId auth implies ProducerId auth - posted by jg...@apache.org on 2017/05/24 22:28:55 UTC, 1 replies.
- kafka git commit: KAFKA-4144 Follow-up: add one missing overload function to maintain backward compatibility - posted by gu...@apache.org on 2017/05/25 02:00:39 UTC, 1 replies.
- kafka git commit: MINOR: GroupCoordinator can append with group lock - posted by jg...@apache.org on 2017/05/25 04:02:30 UTC, 1 replies.
- kafka git commit: KAFKA-4935; Deprecate client checksum API and compute lazy partial checksum for magic v2 - posted by ij...@apache.org on 2017/05/25 07:21:10 UTC, 0 replies.
- [1/2] kafka git commit: KAFKA-4208; Add record headers upgrade doc - posted by ij...@apache.org on 2017/05/25 07:31:57 UTC, 0 replies.
- [2/2] kafka git commit: KAFKA-4935; Deprecate client checksum API and compute lazy partial checksum for magic v2 - posted by ij...@apache.org on 2017/05/25 07:31:58 UTC, 0 replies.
- kafka git commit: MINOR: fix flakiness in testDeleteAcls - posted by ij...@apache.org on 2017/05/25 10:21:02 UTC, 1 replies.
- kafka git commit: KAFKA-5263: Avoid tight polling loop in consumer with no ready nodes - posted by rs...@apache.org on 2017/05/25 10:23:46 UTC, 1 replies.
- kafka git commit: KAFKA-5279: TransactionCoordinator must expire transactionalIds - posted by gu...@apache.org on 2017/05/25 18:01:13 UTC, 1 replies.
- kafka git commit: KAFKA-5320: Include all request throttling in client throttle metrics - posted by rs...@apache.org on 2017/05/25 19:28:46 UTC, 1 replies.
- kafka git commit: KAFKA-5147; Add missing synchronization to TransactionManager - posted by jg...@apache.org on 2017/05/25 23:25:41 UTC, 1 replies.
- kafka git commit: MINOR: Preserve the base offset of the original record batch in V2 - posted by ij...@apache.org on 2017/05/26 08:50:43 UTC, 1 replies.
- kafka git commit: KAFKA-5309: Stores not queryable after one thread died - posted by gu...@apache.org on 2017/05/26 16:42:03 UTC, 1 replies.
- kafka git commit: KAFKA-5128; Check inter broker version in transactional methods - posted by jg...@apache.org on 2017/05/26 16:54:16 UTC, 1 replies.
- kafka git commit: KAFKA-5333; Remove Broker ACL resource type - posted by ju...@apache.org on 2017/05/26 22:25:07 UTC, 1 replies.
- kafka git commit: KAFKA-4660; Improve test coverage KafkaStreams - posted by gu...@apache.org on 2017/05/26 22:32:00 UTC, 1 replies.
- kafka git commit: KAFKA-5191: Autogenerate Consumer Fetcher metrics - posted by gu...@apache.org on 2017/05/26 22:34:22 UTC, 1 replies.
- kafka git commit: MINOR: Cleanup in tests to avoid threads being left behind - posted by ij...@apache.org on 2017/05/27 09:18:00 UTC, 1 replies.
- kafka git commit: MINOR: Remove unused method parameter in `SimpleAclAuthorizer` - posted by ij...@apache.org on 2017/05/27 09:19:17 UTC, 0 replies.
- kafka git commit: KAFKA-5316; LogCleaner should account for larger record sets after cleaning - posted by jg...@apache.org on 2017/05/28 17:00:03 UTC, 1 replies.
- kafka git commit: KAFKA-5338: fix a miss-spell in ResetIntegrationTest - posted by gu...@apache.org on 2017/05/29 23:01:59 UTC, 1 replies.
- kafka git commit: KAFKA-5260; Producer should not send AbortTxn unless transaction has actually begun - posted by jg...@apache.org on 2017/05/30 05:55:42 UTC, 1 replies.
- kafka git commit: KAFKA-5278: ConsoleConsumer should honor `--value-deserializer` - posted by gu...@apache.org on 2017/05/30 07:12:58 UTC, 1 replies.
- kafka git commit: KAFKA-5344; set message.timestamp.difference.max.ms back to Long.MaxValue - posted by ij...@apache.org on 2017/05/30 14:53:07 UTC, 1 replies.
- kafka git commit: KAFKA-5316; Follow-up with ByteBufferOutputStream and other misc improvements - posted by jg...@apache.org on 2017/05/30 19:53:48 UTC, 1 replies.
- kafka git commit: KAFKA-4603: Disallow abbreviations in OptionParser constructor - posted by gu...@apache.org on 2017/05/30 20:53:36 UTC, 1 replies.
- kafka git commit: KAFKA-5202: Handle topic deletion while trying to send txn markers - posted by jg...@apache.org on 2017/05/30 21:57:35 UTC, 1 replies.
- kafka git commit: MINOR: Fix doc for producer throttle time metrics - posted by ju...@apache.org on 2017/05/30 23:35:29 UTC, 1 replies.
- kafka git commit: MINOR: onControllerResignation should be invoked if triggerControllerMove is called - posted by ju...@apache.org on 2017/05/30 23:59:37 UTC, 1 replies.
- kafka git commit: KAFKA-5150; Reduce LZ4 decompression overhead - posted by ij...@apache.org on 2017/05/31 01:20:35 UTC, 1 replies.
- kafka git commit: KAFKA-5150; Reduce LZ4 decompression overhead [Forced Update!] - posted by ij...@apache.org on 2017/05/31 01:22:11 UTC, 0 replies.
- kafka git commit: KAFKA-5324; AdminClient: add close with timeout, fix some timeout bugs - posted by ij...@apache.org on 2017/05/31 02:04:21 UTC, 1 replies.
- kafka git commit: KAFKA-5251; Producer should cancel unsent AddPartitions and Produce requests on abort - posted by jg...@apache.org on 2017/05/31 03:54:08 UTC, 1 replies.
- kafka git commit: KAFKA-5211; Do not skip a corrupted record in consumer - posted by jg...@apache.org on 2017/05/31 05:59:04 UTC, 1 replies.
- kafka git commit: KAKFA-5334: Allow rocksdb.config.setter to be specified as a String or Class instance - posted by gu...@apache.org on 2017/05/31 06:21:18 UTC, 1 replies.
- kafka git commit: KAFKA-5308; TC should handle UNSUPPORTED_FOR_MESSAGE_FORMAT in WriteTxnMarker response - posted by gu...@apache.org on 2017/05/31 06:42:18 UTC, 1 replies.
- kafka git commit: KAFKA-5266; Follow-up improvements for consumer offset reset tool (KIP-122) - posted by jg...@apache.org on 2017/05/31 07:52:42 UTC, 1 replies.
- kafka git commit: MINOR: Improve assert in ControllerFailoverTest - posted by ij...@apache.org on 2017/05/31 09:22:23 UTC, 1 replies.
- kafka git commit: KAFKA-5349; Fix illegal state error in consumer's ListOffset handler - posted by ij...@apache.org on 2017/05/31 09:28:25 UTC, 1 replies.
- kafka git commit: MINOR: Use new consumer in ProducerCompressionTest - posted by ij...@apache.org on 2017/05/31 15:13:33 UTC, 1 replies.
- [1/3] kafka git commit: KAFKA-5265; Move ACLs, Config, Topic classes into org.apache.kafka.common - posted by ij...@apache.org on 2017/05/31 16:37:42 UTC, 1 replies.
- [2/3] kafka git commit: KAFKA-5265; Move ACLs, Config, Topic classes into org.apache.kafka.common - posted by ij...@apache.org on 2017/05/31 16:37:43 UTC, 1 replies.
- [3/3] kafka git commit: KAFKA-5265; Move ACLs, Config, Topic classes into org.apache.kafka.common - posted by ij...@apache.org on 2017/05/31 16:37:44 UTC, 1 replies.
- kafka git commit: KAFKA-5093; Avoid loading full batch data when possible when iterating FileRecords - posted by jg...@apache.org on 2017/05/31 21:14:19 UTC, 1 replies.
- kafka git commit: MINOR: Improve streams config parameters - posted by gu...@apache.org on 2017/05/31 21:53:32 UTC, 1 replies.
- kafka git commit: KAFKA-5218; New Short serializer, deserializer, serde - posted by gu...@apache.org on 2017/05/31 22:10:06 UTC, 1 replies.
- kafka git commit: MINOR: Use `waitUntil` to fix transient failures of ControllerFailoverTest - posted by ij...@apache.org on 2017/05/31 22:47:13 UTC, 1 replies.
- kafka git commit: KAFKA-5353; baseTimestamp should always have a create timestamp - posted by ij...@apache.org on 2017/05/31 23:17:00 UTC, 1 replies.