| guozh...@apache.org |
kafka git commit: MINOR: removed obsolete class |
Mon, 01 Feb, 21:51 |
| guozh...@apache.org |
kafka git commit: KAFKA-1860: Fix issue that file system errors are not detected unless Kafka tries to write. |
Mon, 01 Feb, 22:41 |
| ewe...@apache.org |
[1/2] kafka git commit: KAFKA-3060: Refactor MeteredStore and RockDBStore Impl |
Tue, 02 Feb, 00:11 |
| ewe...@apache.org |
[2/2] kafka git commit: KAFKA-3060: Refactor MeteredStore and RockDBStore Impl |
Tue, 02 Feb, 00:11 |
| ewe...@apache.org |
kafka git commit: MINOR: Reorder StreamThread shutdown sequence |
Tue, 02 Feb, 01:32 |
| ewe...@apache.org |
kafka git commit: KAFKA-3068: Remove retry with nodesEverSeen |
Tue, 02 Feb, 17:36 |
| ewe...@apache.org |
kafka git commit: KAFKA-3068: Remove retry with nodesEverSeen |
Tue, 02 Feb, 17:36 |
| guozh...@apache.org |
kafka git commit: KAFKA-3170; Set default fetch_min_bytes in new consumer to 1 |
Tue, 02 Feb, 17:38 |
| guozh...@apache.org |
kafka git commit: Cherry-pick c97a75d985e42a9d1b1be0352240c45e0b0d2978 |
Tue, 02 Feb, 17:51 |
| guozh...@apache.org |
kafka git commit: revert one upgrade.html change from trunk |
Tue, 02 Feb, 17:52 |
| guozh...@apache.org |
kafka git commit: MINOR: fix the logic of RocksDBWindowStore using RocksDBStore Segments |
Tue, 02 Feb, 18:14 |
| guozh...@apache.org |
kafka git commit: MINOR: some javadocs for kstream public api |
Tue, 02 Feb, 18:52 |
| ewe...@apache.org |
kafka git commit: KAFKA-3121: Refactor KStream Aggregate to be Lambda-able. |
Tue, 02 Feb, 20:01 |
| ewe...@apache.org |
kafka git commit: MINOR: Increment ducktape dependency |
Wed, 03 Feb, 01:58 |
| ewe...@apache.org |
kafka git commit: KAFKA-3195; Transient test failure in OffsetCheckpointTest.testReadWrite |
Wed, 03 Feb, 02:29 |
| ewe...@apache.org |
kafka git commit: KAFKA-3092: Replace SinkTask onPartitionsAssigned/onPartitionsRevoked with open/close |
Wed, 03 Feb, 19:29 |
| ewe...@apache.org |
kafka git commit: MINOR: Some more Kafka Streams Javadocs |
Wed, 03 Feb, 19:35 |
| gwens...@apache.org |
kafka git commit: KAFKA-3194: Validate security.inter.broker.protocol against the adver… |
Wed, 03 Feb, 23:42 |
| gwens...@apache.org |
kafka git commit: KAFKA-3194: Validate security.inter.broker.protocol against the adver… |
Wed, 03 Feb, 23:45 |
| guozh...@apache.org |
kafka git commit: MINOR: Fix restoring for source KTable |
Thu, 04 Feb, 04:42 |
| ewe...@apache.org |
kafka git commit: MINOR: Pin to system tests to ducktape 0.3.10 |
Thu, 04 Feb, 06:33 |
| gwens...@apache.org |
kafka git commit: KAFKA-3198: Ticket Renewal Thread exits prematurely due to inverted c… |
Thu, 04 Feb, 07:48 |
| gwens...@apache.org |
kafka git commit: KAFKA-3198: Ticket Renewal Thread exits prematurely due to inverted c… |
Thu, 04 Feb, 07:48 |
| guozh...@apache.org |
kafka git commit: HOTFIX: temp fix for ktable look up |
Thu, 04 Feb, 18:16 |
| ewe...@apache.org |
kafka git commit: HOTFIX: fix broken WorkerSourceTask test |
Thu, 04 Feb, 19:11 |
| ewe...@apache.org |
kafka git commit: MINOR: Removed unnecessary Vagrantfile hack |
Thu, 04 Feb, 21:49 |
| ewe...@apache.org |
kafka git commit: MINOR: Removed unnecessary Vagrantfile hack |
Thu, 04 Feb, 21:49 |
| guozh...@apache.org |
kafka git commit: HOTFIX: fix partition ordering in assignment |
Thu, 04 Feb, 22:14 |
| ewe...@apache.org |
kafka git commit: MINOR: log connect reconfiguration error only if there was an error |
Thu, 04 Feb, 22:34 |
| ewe...@apache.org |
kafka git commit: MINOR: log connect reconfiguration error only if there was an error |
Thu, 04 Feb, 22:34 |
| guozh...@apache.org |
kafka git commit: KAFKA-3207: Fix StateChangeLogger to use the right topic name |
Thu, 04 Feb, 22:51 |
| jjko...@apache.org |
kafka git commit: KAFKA-3179; Fix seek on compressed messages |
Fri, 05 Feb, 00:08 |
| jjko...@apache.org |
kafka git commit: KAFKA-3179; Fix seek on compressed messages |
Fri, 05 Feb, 01:24 |
| ewe...@apache.org |
kafka git commit: KAFKA-3211: Handle WorkerTask stop before start correctly |
Fri, 05 Feb, 02:00 |
| guozh...@apache.org |
kafka git commit: KAFKA-3003: Update the replica.highWatermark correctly |
Fri, 05 Feb, 17:06 |
| guozh...@apache.org |
kafka git commit: KAFKA-3003: Update the replica.highWatermark correctly |
Fri, 05 Feb, 17:07 |
| guozh...@apache.org |
kafka git commit: KAFKA-3157: Mirror maker doesn't commit offset with low traffic |
Fri, 05 Feb, 17:11 |
| guozh...@apache.org |
kafka git commit: KAFKA-3157: Mirror maker doesn't commit offset with low traffic |
Fri, 05 Feb, 17:11 |
| ewe...@apache.org |
kafka git commit: KAFKA-3165: Fix ignored parameters in the gradle "All" tasks |
Fri, 05 Feb, 18:41 |
| ewe...@apache.org |
kafka git commit: MINOR: Add more info to RecordCollector error message |
Fri, 05 Feb, 20:58 |
| ewe...@apache.org |
kafka git commit: KAFKA-3037: Test number of alive brokers known after single node cluster startup |
Fri, 05 Feb, 21:16 |
| ewe...@apache.org |
kafka git commit: KAFKA-2589: The default value for the "rebalance.backoff.ms" property is not specified correctly |
Fri, 05 Feb, 21:25 |
| ewe...@apache.org |
kafka git commit: KAFKA-2589: The default value for the "rebalance.backoff.ms" property is not specified correctly |
Fri, 05 Feb, 21:25 |
| ewe...@apache.org |
kafka git commit: MINOR: Updated kafkatest version to match version specified in gradle.properties |
Fri, 05 Feb, 21:45 |
| ewe...@apache.org |
kafka git commit: MINOR: Improve error message for inconsistent broker ids |
Fri, 05 Feb, 22:59 |
| guozh...@apache.org |
kafka git commit: HOTFIX: fix streams issues |
Mon, 08 Feb, 20:46 |
| guozh...@apache.org |
kafka git commit: MINOR: fix RocksDBStore range search |
Mon, 08 Feb, 21:00 |
| ewe...@apache.org |
kafka git commit: HOTFIX: RecordCollector should send a record to the specified partition |
Tue, 09 Feb, 00:35 |
| ewe...@apache.org |
kafka git commit: HOTFIX: open window segments on init |
Tue, 09 Feb, 00:48 |
| ewe...@apache.org |
kafka git commit: KAFKA-3191: Improve offset committing JavaDoc in KafkaConsumer |
Tue, 09 Feb, 00:57 |
| ewe...@apache.org |
kafka git commit: KAFKA-3191: Improve offset committing JavaDoc in KafkaConsumer |
Tue, 09 Feb, 00:57 |
| ewe...@apache.org |
kafka git commit: MINOR: Use explicit type in AclCommand |
Tue, 09 Feb, 17:25 |
| ewe...@apache.org |
kafka git commit: MINOR: Use explicit type in AclCommand |
Tue, 09 Feb, 17:25 |
| ewe...@apache.org |
kafka git commit: KAFKA-3217: Close producers in unit tests |
Tue, 09 Feb, 17:49 |
| ewe...@apache.org |
kafka git commit: HOTFIX: Fix NPE after standby task reassignment |
Tue, 09 Feb, 18:02 |
| ewe...@apache.org |
kafka git commit: KAFKA-3189: Kafka server returns UnknownServerException for inherited exceptions |
Tue, 09 Feb, 18:17 |
| gwens...@apache.org |
kafka git commit: KAFKA-3216: "Modifying topics" section incorrectly says you can't change replication factor. |
Tue, 09 Feb, 18:33 |
| gwens...@apache.org |
kafka git commit: KAFKA-3216: "Modifying topics" section incorrectly says you can't change replication factor. |
Tue, 09 Feb, 18:33 |
| gwens...@apache.org |
kafka git commit: MINOR: Stabilize transient replication test failures in 0.9.0 |
Tue, 09 Feb, 18:36 |
| ewe...@apache.org |
kafka git commit: HOTFIX: open window segments in order, add segment id check in getSegment |
Tue, 09 Feb, 21:22 |
| jun...@apache.org |
kafka git commit: KAFKA-3159; stale high watermark segment offset causes early fetch return |
Tue, 09 Feb, 22:57 |
| jun...@apache.org |
kafka git commit: KAFKA-3159; stale high watermark segment offset causes early fetch return |
Tue, 09 Feb, 22:58 |
| gwens...@apache.org |
kafka git commit: KAFKA-3141: Add checks to catch invalid authorizer porperties |
Wed, 10 Feb, 04:49 |
| gwens...@apache.org |
kafka git commit: KAFKA-3141: Add checks to catch invalid authorizer porperties |
Wed, 10 Feb, 04:49 |
| gwens...@apache.org |
kafka git commit: KAFKA-3162: Added producer and consumer interceptors |
Wed, 10 Feb, 05:10 |
| gwens...@apache.org |
kafka git commit: MINOR: Remove multi-byte charactor in docs |
Wed, 10 Feb, 19:51 |
| gwens...@apache.org |
kafka git commit: MINOR: Remove multi-byte charactor in docs |
Wed, 10 Feb, 19:51 |
| gwens...@apache.org |
kafka git commit: HOTFIX: poll even when all partitions are paused. handle concurrent cleanup |
Wed, 10 Feb, 22:02 |
| ewe...@apache.org |
kafka git commit: MINOR: Connect hangs on startup failure |
Thu, 11 Feb, 01:08 |
| ewe...@apache.org |
kafka git commit: MINOR: add setUncaughtExceptionHandler to KafkaStreams |
Thu, 11 Feb, 06:02 |
| gwens...@apache.org |
kafka git commit: KAFKA-3229 ensure that root statestore is registered with ProcessorStateManager |
Thu, 11 Feb, 18:36 |
| jun...@apache.org |
kafka git commit: change release version to 0.9.0.1 |
Fri, 12 Feb, 00:34 |
| jun...@apache.org |
[kafka] Git Push Summary |
Fri, 12 Feb, 00:39 |
| guozh...@apache.org |
kafka git commit: MINOR: catch an exception in rebalance and stop the stream thread |
Fri, 12 Feb, 09:11 |
| guozh...@apache.org |
kafka git commit: KAFKA-3147; Memory records is not writable in MirrorMaker |
Fri, 12 Feb, 09:15 |
| jjko...@apache.org |
kafka git commit: KAFKA-3088; Make client-id a nullable string and fix handling of invalid requests." |
Sat, 13 Feb, 02:49 |
| ewe...@apache.org |
kafka git commit: KAFKA-3227; Conservative update of Kafka dependencies |
Tue, 16 Feb, 15:19 |
| jjko...@apache.org |
kafka git commit: KAFKA-3088; Make client-id a nullable string and fix handling of invalid requests. |
Tue, 16 Feb, 19:29 |
| ewe...@apache.org |
kafka git commit: MINOR: Reconcile differences in .bat & .sh start scripts |
Tue, 16 Feb, 20:23 |
| srihar...@apache.org |
kafka git commit: KAFKA-2508; Replace UpdateMetadata{Request,Response} with o.a.k.c.req… |
Wed, 17 Feb, 02:25 |
| srihar...@apache.org |
kafka git commit: KAFKA-2547; Make DynamicConfigManager to use the ZkNodeChangeNotifica… |
Wed, 17 Feb, 04:35 |
| jun...@apache.org |
svn commit: r12425 - in /release/kafka/0.9.0.1: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/consumer/ javadoc/org/apache/kafka/clients/producer/ javadoc/org/a... |
Wed, 17 Feb, 07:05 |
| guozh...@apache.org |
kafka git commit: KAFKA-2757; Consolidate BrokerEndPoint and EndPoint |
Wed, 17 Feb, 10:48 |
| ewe...@apache.org |
kafka git commit: KAFKA-3225: Method commit() of class SourceTask never invoked |
Wed, 17 Feb, 16:13 |
| guozh...@apache.org |
kafka git commit: MINOR: remove streams config params from producer/consumer configs |
Thu, 18 Feb, 01:39 |
| jun...@apache.org |
[1/5] kafka git commit: KAFKA-3025; Added timetamp to Message and use relative offset. |
Fri, 19 Feb, 15:56 |
| jun...@apache.org |
[2/5] kafka git commit: KAFKA-3025; Added timetamp to Message and use relative offset. |
Fri, 19 Feb, 15:56 |
| jun...@apache.org |
[3/5] kafka git commit: KAFKA-3025; Added timetamp to Message and use relative offset. |
Fri, 19 Feb, 15:56 |
| jun...@apache.org |
[4/5] kafka git commit: KAFKA-3025; Added timetamp to Message and use relative offset. |
Fri, 19 Feb, 15:56 |
| jun...@apache.org |
[5/5] kafka git commit: KAFKA-3025; Added timetamp to Message and use relative offset. |
Fri, 19 Feb, 15:56 |
| jun...@apache.org |
[1/3] kafka-site git commit: updating docs for 0.9.0.1 release |
Fri, 19 Feb, 17:27 |
| jun...@apache.org |
[2/3] kafka-site git commit: updating docs for 0.9.0.1 release |
Fri, 19 Feb, 17:27 |
| jun...@apache.org |
[3/3] kafka-site git commit: updating docs for 0.9.0.1 release |
Fri, 19 Feb, 17:27 |
| jun...@apache.org |
kafka git commit: trivial fix to authorization CLI table |
Fri, 19 Feb, 17:41 |
| jun...@apache.org |
kafka git commit: trivial fix to authorization CLI table |
Fri, 19 Feb, 17:44 |
| jun...@apache.org |
kafka-site git commit: trivial fix to authorization CLI table |
Fri, 19 Feb, 17:50 |
| jun...@apache.org |
kafka git commit: trivial change to make release version 0.9.0.2-SNAPSHOT |
Fri, 19 Feb, 17:59 |
| gwens...@apache.org |
kafka git commit: inor: Added few variable and their descriptions to vagrant readme |
Mon, 22 Feb, 06:53 |
| gwens...@apache.org |
kafka git commit: KAFKA-3235: Unclosed stream in AppInfoParser static block |
Mon, 22 Feb, 06:54 |
| ewe...@apache.org |
kafka git commit: KAFKA-3255: Added unit tests for NetworkClient.connectionDelay(Node node, long now) |
Mon, 22 Feb, 18:13 |