| jun...@apache.org |
kafka git commit: KAFKA-2949; Make EndToEndAuthorizationTest replicated. |
Sun, 03 Jan, 23:26 |
| ewe...@apache.org |
kafka git commit: KAFKA-3055; Fix JsonConverter mangling the Schema in Connect |
Mon, 04 Jan, 16:47 |
| ewe...@apache.org |
kafka git commit: KAFKA-3055; Fix JsonConverter mangling the Schema in Connect |
Mon, 04 Jan, 16:48 |
| guozh...@apache.org |
kafka git commit: KAFKA-3052; Broker properties get logged twice if acl enabled |
Mon, 04 Jan, 16:51 |
| guozh...@apache.org |
kafka git commit: KAFKA-3052; Broker properties get logged twice if acl enabled |
Mon, 04 Jan, 16:51 |
| gwens...@apache.org |
kafka git commit: MINOR: Update version to 0.9.0.1-SNAPSHOT |
Mon, 04 Jan, 18:51 |
| ewe...@apache.org |
kafka git commit: KAFKA-2422: Allow copycat connector plugins to be aliased to simpler names |
Mon, 04 Jan, 20:02 |
| jun...@apache.org |
kafka git commit: KAFKA-3051 KAFKA-3048; Security config docs improvements |
Mon, 04 Jan, 20:49 |
| jun...@apache.org |
kafka git commit: KAFKA-3051 KAFKA-3048; Security config docs improvements |
Mon, 04 Jan, 20:49 |
| ewe...@apache.org |
kafka git commit: MINOR: Add secondary constructor that takes only `props` in `KafkaConfig` |
Mon, 04 Jan, 20:52 |
| guozh...@apache.org |
[1/2] kafka git commit: KAFKA-3016: phase-1. A local store for join window |
Tue, 05 Jan, 00:47 |
| guozh...@apache.org |
[2/2] kafka git commit: KAFKA-3016: phase-1. A local store for join window |
Tue, 05 Jan, 00:47 |
| gwens...@apache.org |
kafka git commit: MINOR: Update `config/producer.properties` to have new producer properties |
Tue, 05 Jan, 14:22 |
| jun...@apache.org |
kafka git commit: KAFKA-3010; Include error in log when ack 0 |
Tue, 05 Jan, 19:39 |
| jun...@apache.org |
kafka git commit: KAFKA-3010; Include error in log when ack 0 |
Tue, 05 Jan, 19:40 |
| jun...@apache.org |
kafka git commit: KAFKA-3045; ZkNodeChangeNotificationListener shouldn't log InterruptedException as error |
Tue, 05 Jan, 20:03 |
| jun...@apache.org |
kafka git commit: KAFKA-3045; ZkNodeChangeNotificationListener shouldn't log InterruptedException as error |
Tue, 05 Jan, 20:03 |
| jun...@apache.org |
kafka git commit: KAFKA-3058; remove the usage of deprecated config properties |
Tue, 05 Jan, 20:04 |
| guozh...@apache.org |
kafka git commit: KAFKA-1901; Added error handling when no file exists in .git/refs/heads. |
Wed, 06 Jan, 20:48 |
| jun...@apache.org |
kafka git commit: KAFKA-2937; Disable the leaderIsr check if the topic is to be deleted. |
Wed, 06 Jan, 22:17 |
| jun...@apache.org |
kafka git commit: KAFKA-2937; Disable the leaderIsr check if the topic is to be deleted. |
Wed, 06 Jan, 22:17 |
| guozh...@apache.org |
[1/2] kafka git commit: KAFKA-3016: phase-2. stream join implementations |
Wed, 06 Jan, 22:34 |
| guozh...@apache.org |
[2/2] kafka git commit: KAFKA-3016: phase-2. stream join implementations |
Wed, 06 Jan, 22:34 |
| jun...@apache.org |
kafka git commit: KAFKA-2850; Fix SSL invalid endpoint validation test |
Wed, 06 Jan, 23:01 |
| jun...@apache.org |
kafka git commit: KAFKA-2874; shutdown ZK process reliably |
Wed, 06 Jan, 23:21 |
| jun...@apache.org |
kafka git commit: KAFKA-2072; Replace StopReplica Request/Response with their org.apache.kafka.common.requests equivalents |
Thu, 07 Jan, 00:08 |
| ewe...@apache.org |
kafka git commit: KAFKA-3022: Deduplicate common project configurations |
Thu, 07 Jan, 00:19 |
| ewe...@apache.org |
[1/3] kafka git commit: KAFKA-2929: Migrate duplicate error mapping functionality |
Thu, 07 Jan, 05:25 |
| ewe...@apache.org |
[2/3] kafka git commit: KAFKA-2929: Migrate duplicate error mapping functionality |
Thu, 07 Jan, 05:25 |
| ewe...@apache.org |
[3/3] kafka git commit: KAFKA-2929: Migrate duplicate error mapping functionality |
Thu, 07 Jan, 05:25 |
| jun...@apache.org |
kafka git commit: KAFKA-2988; Change default configuration of the log cleaner |
Thu, 07 Jan, 17:57 |
| jun...@apache.org |
kafka git commit: KAFKA-2988; Change default configuration of the log cleaner |
Thu, 07 Jan, 17:59 |
| guozh...@apache.org |
kafka git commit: KAFKA-2649: Add support for custom partitioning in topology sinks |
Thu, 07 Jan, 22:46 |
| guozh...@apache.org |
[1/2] kafka git commit: KAFKA-2653: Add KStream/KTable Aggregation and KTable Join APIs |
Fri, 08 Jan, 01:18 |
| guozh...@apache.org |
[2/2] kafka git commit: KAFKA-2653: Add KStream/KTable Aggregation and KTable Join APIs |
Fri, 08 Jan, 01:18 |
| ewe...@apache.org |
kafka git commit: KAFKA-2979: Enable authorizer and ACLs in ducktape tests |
Fri, 08 Jan, 04:04 |
| guozh...@apache.org |
kafka git commit: MINOR: Fix typos in Kafka website page |
Fri, 08 Jan, 18:43 |
| ewe...@apache.org |
kafka git commit: MINOR: speed up connect startup when full connector class name is provided |
Fri, 08 Jan, 23:04 |
| ewe...@apache.org |
kafka git commit: MINOR: Add property to configure showing of standard streams in Gradle |
Fri, 08 Jan, 23:13 |
| ewe...@apache.org |
kafka git commit: MINOR: Security doc fixes |
Sat, 09 Jan, 00:08 |
| ewe...@apache.org |
kafka git commit: MINOR: Security doc fixes |
Sat, 09 Jan, 00:09 |
| gwens...@apache.org |
kafka git commit: Minor: fix sasl.kerberos.service.name |
Sat, 09 Jan, 02:34 |
| gwens...@apache.org |
kafka-site git commit: Minor updates to api, design, security and upgrade pages |
Sat, 09 Jan, 02:46 |
| ewe...@apache.org |
kafka git commit: KAFKA-3044: Re-word consumer.poll behaviour |
Mon, 11 Jan, 06:14 |
| ewe...@apache.org |
kafka git commit: KAFKA-3084: Topic existence checks in topic commands (create, alter, delete) |
Mon, 11 Jan, 18:09 |
| ewe...@apache.org |
kafka git commit: KAFKA-3019: Add an exceptionName method to Errors |
Mon, 11 Jan, 19:10 |
| ewe...@apache.org |
kafka git commit: KAFKA-3021: Centralize dependency version management |
Mon, 11 Jan, 22:17 |
| jun...@apache.org |
kafka git commit: KAFKA-3085; BrokerChangeListener computes inconsistent live/dead broker list |
Mon, 11 Jan, 23:00 |
| guozh...@apache.org |
kafka git commit: MINOR: remove unused TimeUnit from MetricConfig |
Tue, 12 Jan, 02:01 |
| ewe...@apache.org |
kafka git commit: KAFKA-3077: Enable KafkaLog4jAppender to work with SASL enabled brokers |
Tue, 12 Jan, 07:14 |
| ewe...@apache.org |
kafka git commit: KAFKA-3078: Add ducktape tests for KafkaLog4jAppender producing to SASL enabled Kafka cluster |
Tue, 12 Jan, 07:15 |
| ewe...@apache.org |
kafka git commit: KAFKA-3069: Fix recursion in ZkSecurityMigrator |
Tue, 12 Jan, 17:49 |
| ewe...@apache.org |
kafka-site git commit: Update consumer_config, kafka_config and producer_config |
Tue, 12 Jan, 18:47 |
| ewe...@apache.org |
kafka git commit: KAFKA-3063; LogRecoveryTest causes JVM to exit occasionally |
Wed, 13 Jan, 00:16 |
| guozh...@apache.org |
kafka git commit: MINOR: Typo in documentation of topic config removal |
Wed, 13 Jan, 22:58 |
| guozh...@apache.org |
kafka git commit: MINOR: modify config specification of topic level |
Wed, 13 Jan, 23:01 |
| guozh...@apache.org |
[1/2] kafka git commit: KAFKA-3081: KTable Aggregation |
Thu, 14 Jan, 01:16 |
| guozh...@apache.org |
[2/2] kafka git commit: KAFKA-3081: KTable Aggregation |
Thu, 14 Jan, 01:16 |
| guozh...@apache.org |
kafka git commit: MINOR: add internal source topic for tracking |
Fri, 15 Jan, 01:09 |
| guozh...@apache.org |
kafka git commit: KAFKA-3108: custom StreamParitioner for Windowed key |
Fri, 15 Jan, 01:20 |
| ewe...@apache.org |
kafka git commit: KAFKA-2886: Handle sink task rebalance failures by stopping worker task |
Fri, 15 Jan, 17:29 |
| guozh...@apache.org |
kafka git commit: KAFKA-2993: Calculate compression rate at close() call |
Mon, 18 Jan, 01:14 |
| guozh...@apache.org |
kafka git commit: KAFKA-2993: Calculate compression rate at close() call |
Mon, 18 Jan, 01:14 |
| jun...@apache.org |
kafka git commit: KAFKA-3085; BrokerChangeListener computes inconsistent live/dead broker list. |
Mon, 18 Jan, 05:22 |
| ewe...@apache.org |
kafka git commit: KAFKA-3105: Use `Utils.atomicMoveWithFallback` instead of `File.rename` |
Mon, 18 Jan, 17:47 |
| guozh...@apache.org |
kafka git commit: KAFKA-2695: limited support for nullable byte arrays |
Mon, 18 Jan, 17:54 |
| guozh...@apache.org |
kafka git commit: KAFKA-2695: limited support for nullable byte arrays |
Mon, 18 Jan, 17:54 |
| gwens...@apache.org |
kafka git commit: KAFKA-3098: "partition.assignment.strategy" appears twice in documentation |
Mon, 18 Jan, 17:56 |
| gwens...@apache.org |
kafka git commit: KAFKA-3098: "partition.assignment.strategy" appears twice in documentation |
Mon, 18 Jan, 17:56 |
| gwens...@apache.org |
kafka git commit: KAFKA-3095: Add documentation on format of sasl.kerberos.principal.to.local.rules |
Mon, 18 Jan, 18:03 |
| gwens...@apache.org |
kafka git commit: KAFKA-3095: Add documentation on format of sasl.kerberos.principal.to.local.rules |
Mon, 18 Jan, 18:04 |
| gwens...@apache.org |
kafka git commit: KAFKA-2999: Errors enum should be a 1 to 1 mapping of error codes and… |
Mon, 18 Jan, 18:09 |
| guozh...@apache.org |
[1/2] kafka git commit: KAFKA-3104: add windowed aggregation to KStream |
Mon, 18 Jan, 20:14 |
| guozh...@apache.org |
[2/2] kafka git commit: KAFKA-3104: add windowed aggregation to KStream |
Mon, 18 Jan, 20:14 |
| guozh...@apache.org |
kafka git commit: MINOR: complete built-in stream aggregate functions |
Mon, 18 Jan, 21:43 |
| gwens...@apache.org |
kafka git commit: KAFKA-3119: Adding -daemon option to zookeeper-server-start.sh USAGE, similar to kafka-server-start.sh |
Tue, 19 Jan, 02:16 |
| gwens...@apache.org |
kafka git commit: KAFKA-3012: Avoid reserved.broker.max.id collisions on upgrade |
Tue, 19 Jan, 02:40 |
| gwens...@apache.org |
kafka git commit: KAFKA-3012: Avoid reserved.broker.max.id collisions on upgrade |
Tue, 19 Jan, 02:40 |
| gwens...@apache.org |
kafka git commit: KAFKA-3091: Broker persists generated ID even when the ID can't be used due to duplicates |
Tue, 19 Jan, 02:55 |
| guozh...@apache.org |
kafka git commit: MINOR: MemoryRecords.sizeInBytes throws NPE when non-writable. |
Tue, 19 Jan, 06:25 |
| guozh...@apache.org |
kafka git commit: MINOR: MemoryRecords.sizeInBytes throws NPE when non-writable. |
Tue, 19 Jan, 06:25 |
| guozh...@apache.org |
kafka git commit: MINOR: Fix javadoc for `PartitionInfo.leader()` |
Tue, 19 Jan, 17:17 |
| guozh...@apache.org |
kafka git commit: MINOR: Avoid unnecessary `ConcurrentHashMap.get` |
Tue, 19 Jan, 17:22 |
| guozh...@apache.org |
kafka git commit: MINOR: Avoid unnecessary `ConcurrentHashMap.get` |
Tue, 19 Jan, 17:22 |
| guozh...@apache.org |
kafka git commit: KAFKA-3122; Fix memory leak in `Sender.completeBatch` on TOPIC_AUTHORIZATION_FAILED |
Wed, 20 Jan, 06:50 |
| guozh...@apache.org |
kafka git commit: KAFKA-3122; Fix memory leak in `Sender.completeBatch` on TOPIC_AUTHORIZATION_FAILED |
Wed, 20 Jan, 06:50 |
| guozh...@apache.org |
[1/5] kafka git commit: KAFKA-3121: Remove aggregatorSupplier and add Reduce functions |
Thu, 21 Jan, 00:10 |
| guozh...@apache.org |
[2/5] kafka git commit: KAFKA-3121: Remove aggregatorSupplier and add Reduce functions |
Thu, 21 Jan, 00:10 |
| guozh...@apache.org |
[3/5] kafka git commit: KAFKA-3121: Remove aggregatorSupplier and add Reduce functions |
Thu, 21 Jan, 00:10 |
| guozh...@apache.org |
[4/5] kafka git commit: KAFKA-3121: Remove aggregatorSupplier and add Reduce functions |
Thu, 21 Jan, 00:10 |
| guozh...@apache.org |
[5/5] kafka git commit: KAFKA-3121: Remove aggregatorSupplier and add Reduce functions |
Thu, 21 Jan, 00:10 |
| ewe...@apache.org |
kafka git commit: KAFKA-2071: Replace Producer Request/Response with their org.apache.kafka.common.requests equivalents |
Thu, 21 Jan, 00:28 |
| gwens...@apache.org |
kafka git commit: KAFKA-3080: Fix ConsoleConsumerTest by checking version when service is started |
Thu, 21 Jan, 19:18 |
| guozh...@apache.org |
kafka git commit: MINOR: Upgrade note on compacted topics behaviour on receiving message without key |
Thu, 21 Jan, 19:44 |
| guozh...@apache.org |
kafka git commit: MINOR: Upgrade note on compacted topics behaviour on receiving message without key |
Thu, 21 Jan, 19:44 |
| guozh...@apache.org |
kafka git commit: KAFKA-2146: Fix adding partition did not find the correct startIndex. |
Fri, 22 Jan, 00:18 |
| ewe...@apache.org |
kafka git commit: MINOR: Vagrant AWS overrideable EC2 instance name prefix |
Fri, 22 Jan, 01:11 |
| gwens...@apache.org |
kafka git commit: MINOR: Remove remnants of hadoop clients from kafka-run-class.sh |
Fri, 22 Jan, 02:33 |
| gwens...@apache.org |
kafka git commit: MINOR: Remove remnants of hadoop clients from kafka-run-class.sh |
Fri, 22 Jan, 02:33 |
| gwens...@apache.org |
[1/4] kafka git commit: KAFKA-3136: Rename KafkaStreaming to KafkaStreams |
Fri, 22 Jan, 21:00 |