commits@kafka.apache.org, 2016-06

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

- kafka git commit: KAFKA-3773; Remove from inflightResponses on client disconnect to prevent memory leak - posted by ij...@apache.org on 2016/06/01 00:00:29 UTC, 0 replies.
- kafka git commit: MINOR: added spacing in streams doc in section 9.2 - posted by gu...@apache.org on 2016/06/01 15:14:40 UTC, 0 replies.
- kafka git commit: MINOR; Close parenthesis in PartitionInfo.toString - posted by ij...@apache.org on 2016/06/01 23:49:52 UTC, 0 replies.
- kafka git commit: KAFKA-3660: Log exception message in ControllerBrokerRequestBatch - posted by ew...@apache.org on 2016/06/02 04:03:56 UTC, 1 replies.
- kafka git commit: MINOR: Add a newline to a Javadoc sample in KafkaConsumer - posted by ew...@apache.org on 2016/06/02 04:51:11 UTC, 0 replies.
- kafka git commit: KAFKA-3774: Make 'time' an optional argument of GetOffsetShell - posted by ew...@apache.org on 2016/06/02 05:53:48 UTC, 0 replies.
- kafka git commit: HOTFIX: updated JavaDoc example for 0.9 tech-prev to 0.10 - posted by gu...@apache.org on 2016/06/02 22:40:40 UTC, 0 replies.
- kafka git commit: MINOR: Fix setting of ACLs and ZK shutdown in test harnesses - posted by ij...@apache.org on 2016/06/03 00:19:53 UTC, 1 replies.
- kafka git commit: KAFKA-3785; Fetcher spending unnecessary time during metrics recording - posted by ij...@apache.org on 2016/06/03 08:41:32 UTC, 1 replies.
- kafka git commit: MINOR: Add user overridden test logging events - posted by ij...@apache.org on 2016/06/03 09:30:05 UTC, 1 replies.
- kafka git commit: MINOR: set charset of Javadoc to UTF-8 - posted by ew...@apache.org on 2016/06/03 16:34:02 UTC, 0 replies.
- kafka git commit: KAFKA-3784: TimeWindows#windowsFor calculation is incorrect - posted by gu...@apache.org on 2016/06/03 20:21:43 UTC, 1 replies.
- kafka git commit: KAFKA-3728; EndToEndAuthorizationTest offsets_topic misconfigured - posted by ij...@apache.org on 2016/06/03 20:31:32 UTC, 1 replies.
- kafka git commit: KAFKA-3645; Fix ConsumerGroupCommand and ConsumerOffsetChecker to correctly read endpoint info from ZK - posted by ij...@apache.org on 2016/06/04 08:42:37 UTC, 0 replies.
- kafka git commit: KAFKA-3768; Replace all pattern match on boolean value by if/else block. - posted by ij...@apache.org on 2016/06/04 20:25:19 UTC, 0 replies.
- kafka git commit: KAFKA-3789; Upgrade Snappy to fix snappy decompression errors - posted by ij...@apache.org on 2016/06/04 22:24:10 UTC, 1 replies.
- kafka git commit: KAFKA-3787; Preserve the message timestamp in mirror maker - posted by ij...@apache.org on 2016/06/05 07:57:57 UTC, 1 replies.
- kafka git commit: MINOR: Fix producer leak in `PlaintextProducerSendTest` - posted by sr...@apache.org on 2016/06/06 02:33:05 UTC, 0 replies.
- kafka git commit: MINOR: Move `ConsoleProducerTest` to the unit test directory - posted by sr...@apache.org on 2016/06/06 02:34:59 UTC, 0 replies.
- [1/3] kafka git commit: KAFKA-3771; Improving Kafka core code - posted by ij...@apache.org on 2016/06/06 07:46:08 UTC, 0 replies.
- [2/3] kafka git commit: KAFKA-3771; Improving Kafka core code - posted by ij...@apache.org on 2016/06/06 07:46:09 UTC, 0 replies.
- [3/3] kafka git commit: KAFKA-3771; Improving Kafka core code - posted by ij...@apache.org on 2016/06/06 07:46:10 UTC, 0 replies.
- kafka git commit: KAFKA-2948; Remove unused topics from producer metadata set - posted by ij...@apache.org on 2016/06/06 18:56:09 UTC, 0 replies.
- kafka git commit: KAFKA-724; Allow automatic socket.send.buffer from operating system in SocketServer - posted by ij...@apache.org on 2016/06/07 00:19:38 UTC, 0 replies.
- kafka git commit: KAFKA-3783; Catch proper exception on path delete - posted by ij...@apache.org on 2016/06/07 00:37:47 UTC, 1 replies.
- kafka git commit: KAFKA-3781; Errors.exceptionName() can throw NPE - posted by ew...@apache.org on 2016/06/07 03:28:51 UTC, 1 replies.
- kafka git commit: KAFKA-3501: Console consumer process hangs on exit - posted by ew...@apache.org on 2016/06/07 04:34:48 UTC, 0 replies.
- kafka git commit: KAFKA-3748: Add consumer-property to console tools consumer - posted by ew...@apache.org on 2016/06/07 06:58:52 UTC, 0 replies.
- kafka git commit: MINOR: Add comment for round robin partitioner with different subscriptions - posted by ew...@apache.org on 2016/06/08 02:38:56 UTC, 0 replies.
- kafka git commit: KAFKA-3711: Ensure a RecordingMap is passed to configured instances - posted by ew...@apache.org on 2016/06/08 16:33:58 UTC, 0 replies.
- kafka git commit: KAFKA-3817: handle null keys in KTableRepartitionMap - posted by gu...@apache.org on 2016/06/10 20:14:08 UTC, 1 replies.
- kafka git commit: MINOR: Fix a variable name semantically correct. - posted by ew...@apache.org on 2016/06/12 00:17:13 UTC, 0 replies.
- kafka git commit: MINOR: Fix connect development guide. - posted by ew...@apache.org on 2016/06/12 00:20:27 UTC, 0 replies.
- kafka git commit: MINOR: Respect the default value of partition argument in SimpleConsumerShell - posted by ew...@apache.org on 2016/06/12 00:50:45 UTC, 0 replies.
- kafka git commit: KAFKA-3786: Let ConfigDef filter property key value pairs - posted by gu...@apache.org on 2016/06/13 21:15:31 UTC, 0 replies.
- kafka git commit: KAFKA-3699: Update protocol page on website to explain how KIP-35 should be used - posted by ew...@apache.org on 2016/06/14 16:50:39 UTC, 1 replies.
- kafka git commit: KAFKA-3762 Log.loadSegments() should log the message in exception - posted by ew...@apache.org on 2016/06/14 18:54:37 UTC, 0 replies.
- kafka git commit: MINOR: Catch Throwable in commitSourceTask() - posted by ew...@apache.org on 2016/06/14 20:21:34 UTC, 0 replies.
- kafka git commit: KAFKA-3830; getTGT() debug logging exposes confidential information - posted by sr...@apache.org on 2016/06/15 16:32:47 UTC, 1 replies.
- kafka git commit: MINOR: Expose window store sequence number - posted by ew...@apache.org on 2016/06/15 19:09:06 UTC, 0 replies.
- kafka git commit: KAFKA-3753: Add approximateNumEntries() method to KeyValueStore interface - posted by gu...@apache.org on 2016/06/16 00:08:37 UTC, 0 replies.
- kafka git commit: KAFKA-3443: support for adding sources to KafkaStreams via Pattern. - posted by gu...@apache.org on 2016/06/16 02:20:47 UTC, 0 replies.
- [1/2] kafka git commit: KAFKA-2720: expire group metadata when all offsets have expired - posted by gu...@apache.org on 2016/06/16 02:47:24 UTC, 0 replies.
- [2/2] kafka git commit: KAFKA-2720: expire group metadata when all offsets have expired - posted by gu...@apache.org on 2016/06/16 02:47:25 UTC, 0 replies.
- kafka git commit: MINOR: Fix quota violation exception message - posted by ij...@apache.org on 2016/06/16 07:11:08 UTC, 1 replies.
- kafka git commit: KAFKA-3840; Allow clients default OS buffer sizes - posted by ij...@apache.org on 2016/06/16 12:35:07 UTC, 0 replies.
- [1/3] kafka git commit: KAFKA-3561: Auto create through topic for KStream aggregation and join - posted by gu...@apache.org on 2016/06/16 18:56:36 UTC, 0 replies.
- [2/3] kafka git commit: KAFKA-3561: Auto create through topic for KStream aggregation and join - posted by gu...@apache.org on 2016/06/16 18:56:37 UTC, 0 replies.
- [3/3] kafka git commit: KAFKA-3561: Auto create through topic for KStream aggregation and join - posted by gu...@apache.org on 2016/06/16 18:56:38 UTC, 0 replies.
- kafka git commit: MINOR: Follow-up from KAFKA-2720 with comment/style fixes - posted by ij...@apache.org on 2016/06/16 22:03:18 UTC, 0 replies.
- kafka git commit: KAFKA-3691; Confusing logging during metadata update timeout - posted by ij...@apache.org on 2016/06/16 22:30:19 UTC, 0 replies.
- kafka git commit: KAFKA-3805: Check if DB is null. - posted by gu...@apache.org on 2016/06/16 23:18:05 UTC, 1 replies.
- kafka git commit: KAFKA-3838; Update zkClient to 0.9 and Zookeeper to 3.4.8 - posted by ij...@apache.org on 2016/06/17 07:24:59 UTC, 0 replies.
- kafka git commit: HOTFIX: Check hasNext in KStreamWindowReduce - posted by gu...@apache.org on 2016/06/18 18:25:39 UTC, 1 replies.
- [1/4] kafka git commit: MINOR: Add INFO logging if ZK config is not specified - posted by gu...@apache.org on 2016/06/18 18:52:22 UTC, 0 replies.
- [2/4] kafka git commit: KAFKA-3716; Validate all timestamps are not negative - posted by gu...@apache.org on 2016/06/18 18:52:23 UTC, 0 replies.
- [3/4] kafka git commit: KAFKA-3735: Dispose all RocksObejcts upon completeness - posted by gu...@apache.org on 2016/06/18 18:52:24 UTC, 0 replies.
- [4/4] kafka git commit: Merge branch '0.10.0' of https://git-wip-us.apache.org/repos/asf/kafka into 0.10.0 - posted by gu...@apache.org on 2016/06/18 18:52:25 UTC, 0 replies.
- kafka git commit: MINOR: Check null keys in KTableSource - posted by gu...@apache.org on 2016/06/18 19:02:20 UTC, 1 replies.
- kafka git commit: KAFKA-3632; remove fetcher metrics on shutdown and leader migration - posted by ij...@apache.org on 2016/06/19 00:23:13 UTC, 0 replies.
- kafka git commit: MINOR: Fix javadoc typos in ConsumerRebalanceListener - posted by ij...@apache.org on 2016/06/19 08:42:38 UTC, 1 replies.
- kafka git commit: KAFKA-3810: replication of internal topics should not be limited by replica.fetch.max.bytes - posted by ew...@apache.org on 2016/06/19 18:42:18 UTC, 0 replies.
- kafka git commit: KAFKA-3850: WorkerSinkTask commit prior to rebalance should be retried on wakeup - posted by ew...@apache.org on 2016/06/19 22:31:08 UTC, 1 replies.
- kafka git commit: MINOR: Mention `log.message.format.version=0.10.0` in rolling upgrade section - posted by ew...@apache.org on 2016/06/19 23:03:43 UTC, 1 replies.
- kafka git commit: KAFKA-3864: make field.get return field's default value when needed - posted by ew...@apache.org on 2016/06/20 19:32:50 UTC, 1 replies.
- kafka git commit: MINOR: speed up streams integration tests - posted by gu...@apache.org on 2016/06/20 21:37:46 UTC, 0 replies.
- kafka git commit: KAFKA-3865: Fix transient failure in WorkerSourceTaskTest.testSlowTaskStart - posted by ew...@apache.org on 2016/06/21 03:32:16 UTC, 0 replies.
- [1/2] kafka git commit: MINOR: Catch Throwable in commitSourceTask() - posted by ew...@apache.org on 2016/06/21 03:43:42 UTC, 0 replies.
- [2/2] kafka git commit: KAFKA-3865: Fix transient failure in WorkerSourceTaskTest.testSlowTaskStart - posted by ew...@apache.org on 2016/06/21 03:43:43 UTC, 0 replies.
- kafka git commit: KAFKA-3176: Add partition/offset options to the new consumer - posted by ew...@apache.org on 2016/06/21 05:28:32 UTC, 0 replies.
- kafka git commit: MINOR: update streams.html with KStream API changes - posted by gu...@apache.org on 2016/06/21 19:16:56 UTC, 0 replies.
- kafka git commit: KAFKA-3872; Reduce log cleaner buffer size to 2 MB - posted by ij...@apache.org on 2016/06/21 20:52:02 UTC, 0 replies.
- kafka git commit: MINOR: KAFKA-3176 follow-up to fix minor issues - posted by ij...@apache.org on 2016/06/22 08:22:18 UTC, 0 replies.
- kafka git commit: MINOR: Verify acls for group resource on all servers of test cluster. - posted by sr...@apache.org on 2016/06/22 22:26:44 UTC, 0 replies.
- kafka git commit: KAFKA-3863: System tests covering connector/task failure and restart - posted by ew...@apache.org on 2016/06/23 00:06:52 UTC, 1 replies.
- kafka git commit: Kafka-3880: Disallow Join Window with size zero - posted by gu...@apache.org on 2016/06/23 21:16:45 UTC, 0 replies.
- kafka git commit: cherry-pick dummy - posted by gu...@apache.org on 2016/06/23 21:30:04 UTC, 0 replies.
- kafka git commit: MINOR: Pass absolute directory path to RocksDB.open - posted by gu...@apache.org on 2016/06/23 21:36:42 UTC, 1 replies.
- kafka git commit: HOTFIX: Remove Java verion 1.6 in quick-start docs - posted by gu...@apache.org on 2016/06/23 21:42:23 UTC, 0 replies.
- kafka git commit: cherry-pick doc change to remove Java 1.6 reference - posted by gu...@apache.org on 2016/06/23 21:45:27 UTC, 0 replies.
- kafka git commit: MINOR: Clean `Metrics.defaultRegistry` to avoid transient failures in `testSessionExpireListenerMetrics` - posted by gw...@apache.org on 2016/06/23 22:05:15 UTC, 0 replies.
- kafka git commit: KAFKA-3594; After calling MemoryRecords.close() method, hasRoomFor() method should return false - posted by ij...@apache.org on 2016/06/24 08:57:35 UTC, 0 replies.
- kafka git commit: KAFKA-3842: consolidate utility methods to TestUtils - posted by gu...@apache.org on 2016/06/24 20:42:57 UTC, 0 replies.
- kafka git commit: MINOR: fix grammatical errors in DataException message - posted by ew...@apache.org on 2016/06/24 21:16:55 UTC, 0 replies.
- kafka git commit: MINOR: Improve doc string in PartitionGrouper - posted by gu...@apache.org on 2016/06/24 21:46:43 UTC, 1 replies.
- kafka git commit: KAFKA-3896: fix transient failure in KStreamRepartitionJoinTest - posted by gu...@apache.org on 2016/06/27 18:50:46 UTC, 0 replies.
- kafka git commit: KAFKA-3761; Remove BrokerState "RunningAsController" - posted by ij...@apache.org on 2016/06/29 20:58:53 UTC, 0 replies.
- kafka git commit: MINOR: Follow-up from KAFKA-3842 to fix tempDir - posted by gu...@apache.org on 2016/06/29 22:17:12 UTC, 0 replies.
- kafka git commit: KAFKA-3890: Streams use same task assignment on cluster rolling restart - posted by gu...@apache.org on 2016/06/29 22:19:51 UTC, 1 replies.
- kafka git commit: HOTFIX: Check JoinWindow boundaries - posted by gu...@apache.org on 2016/06/30 17:50:54 UTC, 0 replies.
- [1/3] kafka git commit: hotfix: check join window boundaries - posted by gu...@apache.org on 2016/06/30 18:07:29 UTC, 0 replies.
- [2/3] kafka git commit: fixed checkstyle simplified boundary check - posted by gu...@apache.org on 2016/06/30 18:07:30 UTC, 0 replies.
- [3/3] kafka git commit: revertd API breaking changes - posted by gu...@apache.org on 2016/06/30 18:07:31 UTC, 0 replies.
- kafka git commit: KAFKA-3740: Part I: expose StreamConfig properties in ProcessorContext - posted by gu...@apache.org on 2016/06/30 18:10:20 UTC, 0 replies.
- kafka git commit: MINOR: Fix ambiguous log message in RecordCollector - posted by gu...@apache.org on 2016/06/30 18:12:38 UTC, 0 replies.
- kafka git commit: resolve conflicts - posted by gu...@apache.org on 2016/06/30 18:16:03 UTC, 0 replies.
- kafka git commit: KAFKA-3846: KIP-65: include timestamp in Connect record types - posted by ew...@apache.org on 2016/06/30 20:59:38 UTC, 0 replies.