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