| ewe...@apache.org |
kafka git commit: KAFKA-4077: Backdate system test certificates to cope with clock skew |
Thu, 01 Sep, 17:05 |
| guozh...@apache.org |
kafka git commit: KAFKA-4112: Remove alpha quality label from Kafka Streams in docs |
Thu, 01 Sep, 19:21 |
| guozh...@apache.org |
kafka git commit: KAFKA-4112: Remove alpha quality label from Kafka Streams in docs |
Thu, 01 Sep, 19:25 |
| guozh...@apache.org |
kafka git commit: KAFKA-4104: Queryable state metadata is sometimes invalid |
Fri, 02 Sep, 04:21 |
| jun...@apache.org |
kafka git commit: KAFKA-4099; Fix the potential frequent log rolling |
Fri, 02 Sep, 19:49 |
| guozh...@apache.org |
kafka git commit: KAFKA-4105: Queryable state tests |
Mon, 05 Sep, 04:49 |
| guozh...@apache.org |
kafka git commit: KAFKA-4023: Add thread id and task id for logging prefix in Streams |
Tue, 06 Sep, 18:38 |
| guozh...@apache.org |
[1/2] kafka git commit: MINOR: changes embedded broker time to MockTime |
Tue, 06 Sep, 22:35 |
| guozh...@apache.org |
[2/2] kafka git commit: MINOR: changes embedded broker time to MockTime |
Tue, 06 Sep, 22:35 |
| ij...@apache.org |
kafka git commit: MINOR: Include TopicPartition in warning when log cleaner resets dirty offset |
Wed, 07 Sep, 00:16 |
| ij...@apache.org |
kafka git commit: KAFKA-4129; Processor throw exception when getting channel remote address after closing the channel |
Wed, 07 Sep, 00:17 |
| gwens...@apache.org |
kafka git commit: MINOR: More graceful handling of buffers that are too small in Record's `isValid` and `ensureValid` |
Wed, 07 Sep, 00:34 |
| j...@apache.org |
kafka-site git commit: Add Jason to committers page |
Wed, 07 Sep, 00:39 |
| ij...@apache.org |
kafka git commit: MINOR: Reduce the log level when the peer isn't authenticated but is using SSL |
Wed, 07 Sep, 02:43 |
| guozh...@apache.org |
kafka git commit: KAFKA-4058: Failure in org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterReset |
Wed, 07 Sep, 06:02 |
| ij...@apache.org |
kafka git commit: KAFKA-3129; Console producer issue when request-required-acks=0 |
Wed, 07 Sep, 16:08 |
| guozh...@apache.org |
kafka git commit: MINOR: Fixes javadoc of Windows, fixes typo in parameter name of KGroupedTable |
Wed, 07 Sep, 22:28 |
| j...@apache.org |
kafka git commit: MINOR: Document that Connect topics should use compaction |
Thu, 08 Sep, 00:34 |
| guozh...@apache.org |
kafka git commit: KAFKA-4123: Queryable State returning null for key before all stores in instance have been initialized |
Thu, 08 Sep, 00:42 |
| guozh...@apache.org |
[1/2] kafka git commit: KAFKA-3595: window stores use compact, delete config for changelogs |
Thu, 08 Sep, 01:02 |
| guozh...@apache.org |
[2/2] kafka git commit: KAFKA-3595: window stores use compact, delete config for changelogs |
Thu, 08 Sep, 01:02 |
| j...@apache.org |
kafka git commit: KAFKA-4139; Reset findCoordinatorFuture when brokers are unavailable |
Thu, 08 Sep, 16:42 |
| guozh...@apache.org |
kafka git commit: MINOR: fix transient QueryableStateIntegration test failure |
Thu, 08 Sep, 17:53 |
| j...@apache.org |
kafka git commit: KAFKA-4033; Revise partition assignment semantics on consumer subscription changes (KIP-70) |
Fri, 09 Sep, 02:57 |
| ij...@apache.org |
kafka git commit: HOTFIX: Temporarily ignoring this test until fixed |
Fri, 09 Sep, 14:22 |
| ij...@apache.org |
kafka git commit: KAFKA-3807; Fix transient test failure caused by race on future completion |
Fri, 09 Sep, 21:08 |
| ij...@apache.org |
kafka git commit: KAFKA-4145; Avoid redundant integration testing in ProducerSendTests |
Sat, 10 Sep, 07:16 |
| ij...@apache.org |
kafka git commit: KAFKA-4147; Fix transient failure in ConsumerCoordinatorTest.testAutoCommitDynamicAssignment |
Sun, 11 Sep, 07:46 |
| jun...@apache.org |
kafka git commit: KAFKA-1981; Make log compaction point configurable |
Mon, 12 Sep, 01:45 |
| guozh...@apache.org |
kafka git commit: MINOR: catch InvalidStateStoreException in QueryableStateIntegrationTest |
Mon, 12 Sep, 04:00 |
| j...@apache.org |
kafka git commit: KAFKA-2311; Make KafkaConsumer's ensureNotClosed method thread-safe |
Tue, 13 Sep, 03:31 |
| jjko...@apache.org |
kafka git commit: KAFKA-4158; Reset quota to default value if quota override is deleted |
Wed, 14 Sep, 00:34 |
| j...@apache.org |
kafka git commit: MINOR: Give a name to the coordinator heartbeat thread |
Wed, 14 Sep, 16:16 |
| ewe...@apache.org |
kafka git commit: KAFKA-4162: Fixed typo "rebalance" |
Wed, 14 Sep, 17:38 |
| ewe...@apache.org |
kafka git commit: KAFKA-4162: Fixed typo "rebalance" |
Wed, 14 Sep, 17:38 |
| j...@apache.org |
kafka git commit: KAFKA-4172; Ensure fetch responses contain the requested partitions |
Thu, 15 Sep, 01:05 |
| guozh...@apache.org |
kafka git commit: KAFKA-4160: Ensure rebalance listener not called with coordinator lock |
Thu, 15 Sep, 05:31 |
| guozh...@apache.org |
kafka git commit: HOTFIX: set sourceNodes to null for selectKey |
Thu, 15 Sep, 15:42 |
| guozh...@apache.org |
kafka git commit: HOTFIX: fix KafkaStreams SmokeTest |
Thu, 15 Sep, 15:57 |
| guozh...@apache.org |
kafka git commit: KAFKA-4131; Multiple Regex KStream-Consumers cause Null pointer exception |
Fri, 16 Sep, 00:08 |
| jun...@apache.org |
[1/3] kafka git commit: KAFKA-1464; Add a throttling option to the Kafka replication |
Fri, 16 Sep, 05:28 |
| jun...@apache.org |
[2/3] kafka git commit: KAFKA-1464; Add a throttling option to the Kafka replication |
Fri, 16 Sep, 05:28 |
| jun...@apache.org |
[3/3] kafka git commit: KAFKA-1464; Add a throttling option to the Kafka replication |
Fri, 16 Sep, 05:28 |
| guozh...@apache.org |
[1/6] kafka git commit: KAFKA-3776: Unify store and downstream caching in streams |
Fri, 16 Sep, 16:58 |
| guozh...@apache.org |
[2/6] kafka git commit: KAFKA-3776: Unify store and downstream caching in streams |
Fri, 16 Sep, 16:58 |
| guozh...@apache.org |
[3/6] kafka git commit: KAFKA-3776: Unify store and downstream caching in streams |
Fri, 16 Sep, 16:58 |
| guozh...@apache.org |
[4/6] kafka git commit: KAFKA-3776: Unify store and downstream caching in streams |
Fri, 16 Sep, 16:58 |
| guozh...@apache.org |
[5/6] kafka git commit: KAFKA-3776: Unify store and downstream caching in streams |
Fri, 16 Sep, 16:58 |
| guozh...@apache.org |
[6/6] kafka git commit: KAFKA-3776: Unify store and downstream caching in streams |
Fri, 16 Sep, 16:58 |
| j...@apache.org |
kafka git commit: KAFKA-4183; Corrected Kafka Connect's JSON Converter to properly convert from null to logical values |
Fri, 16 Sep, 21:58 |
| j...@apache.org |
kafka git commit: KAFKA-4173; SchemaProjector should successfully project missing Struct field when target field is optional |
Fri, 16 Sep, 22:54 |
| ij...@apache.org |
[1/2] kafka git commit: KAFKA-4093; Cluster Id (KIP-78) |
Sat, 17 Sep, 07:13 |
| ij...@apache.org |
[2/2] kafka git commit: KAFKA-4093; Cluster Id (KIP-78) |
Sat, 17 Sep, 07:13 |
| jun...@apache.org |
[1/2] kafka git commit: KAFKA-3492; Secure quotas for authenticated users |
Sat, 17 Sep, 17:06 |
| jun...@apache.org |
[2/2] kafka git commit: KAFKA-3492; Secure quotas for authenticated users |
Sat, 17 Sep, 17:06 |
| ij...@apache.org |
kafka git commit: HOTFIX: Increase timeout for bounce test |
Sat, 17 Sep, 21:43 |
| ij...@apache.org |
kafka git commit: HOTFIX: changed quickstart donwload from 0.10.0.0 to 0.10.0.1 |
Sat, 17 Sep, 21:45 |
| ij...@apache.org |
kafka git commit: HOTFIX: changed quickstart donwload from 0.10.0.0 to 0.10.0.1 |
Sat, 17 Sep, 21:45 |
| ij...@apache.org |
kafka git commit: KAFKA-4157; Transient system test failure in replica_verification_test.test_replica_lags |
Sat, 17 Sep, 21:48 |
| ij...@apache.org |
kafka git commit: KAFKA-4157; Transient system test failure in replica_verification_test.test_replica_lags |
Sat, 17 Sep, 21:48 |
| ij...@apache.org |
kafka git commit: MINOR: Update the README.md to include a note about GRADLE_USER_HOME |
Sat, 17 Sep, 22:01 |
| j...@apache.org |
[1/3] kafka git commit: KAFKA-2063; Bound fetch response size (KIP-74) |
Sun, 18 Sep, 16:16 |
| j...@apache.org |
[2/3] kafka git commit: KAFKA-2063; Bound fetch response size (KIP-74) |
Sun, 18 Sep, 16:16 |
| j...@apache.org |
[3/3] kafka git commit: KAFKA-2063; Bound fetch response size (KIP-74) |
Sun, 18 Sep, 16:16 |
| ij...@apache.org |
kafka git commit: MINOR: Fix reference to argument in `LogSegment.translateOffset` |
Sun, 18 Sep, 22:01 |
| guozh...@apache.org |
kafka git commit: HOTFIX: logic in QuerybaleStateIntegrationTest.shouldBeAbleToQueryState incorrect |
Mon, 19 Sep, 17:29 |
| guozh...@apache.org |
kafka git commit: KAFKA-4175: Can't have StandbyTasks in KafkaStreams where NUM_STREAM_THREADS_CONFIG > 1 |
Mon, 19 Sep, 17:31 |
| guozh...@apache.org |
kafka git commit: KAFKA-4163: NPE in StreamsMetadataState during re-balance operations |
Mon, 19 Sep, 18:00 |
| jun...@apache.org |
kafka git commit: KAFKA-4079; Documentation for secure quotas |
Mon, 19 Sep, 19:16 |
| guozh...@apache.org |
kafka git commit: MINOR: Allow creation of statestore without logging enabled or explicit source topic |
Mon, 19 Sep, 19:37 |
| j...@apache.org |
kafka git commit: KAFKA-4183; Centralize checking for optional and default values in JsonConverter |
Mon, 19 Sep, 19:49 |
| j...@apache.org |
kafka git commit: MINOR: Add KafkaServerStartable constructor overload for compatibility |
Mon, 19 Sep, 20:08 |
| j...@apache.org |
[1/4] kafka git commit: KAFKA-4183; Corrected Kafka Connect's JSON Converter to properly convert from null to logical values |
Mon, 19 Sep, 21:08 |
| j...@apache.org |
[2/4] kafka git commit: KAFKA-4173; SchemaProjector should successfully project missing Struct field when target field is optional |
Mon, 19 Sep, 21:08 |
| j...@apache.org |
[3/4] kafka git commit: KAFKA-4183; Centralize checking for optional and default values in JsonConverter |
Mon, 19 Sep, 21:08 |
| j...@apache.org |
[4/4] kafka git commit: KAFKA-4100: Ensure 'fields' and 'fieldsByName' are not null for Struct schemas |
Mon, 19 Sep, 21:08 |
| j...@apache.org |
kafka git commit: KAFKA-3283; Remove beta from new consumer documentation |
Mon, 19 Sep, 21:26 |
| j...@apache.org |
kafka git commit: KAFKA-4135; Consumer poll with no subscription or assignment should raise an error |
Mon, 19 Sep, 23:43 |
| guozh...@apache.org |
kafka git commit: KAFKA-4153: Fix incorrect KStream-KStream join behavior with asymmetric time window |
Tue, 20 Sep, 00:13 |
| j...@apache.org |
[1/2] kafka git commit: KAFKA-4148; Support ListOffsetRequest v1 and search offsets by timestamp in consumer (KIP-79) |
Tue, 20 Sep, 01:38 |
| j...@apache.org |
[2/2] kafka git commit: KAFKA-4148; Support ListOffsetRequest v1 and search offsets by timestamp in consumer (KIP-79) |
Tue, 20 Sep, 01:38 |
| j...@apache.org |
[kafka] Git Push Summary |
Tue, 20 Sep, 02:47 |
| j...@apache.org |
kafka git commit: MINOR: Bump to version 0.10.2 |
Tue, 20 Sep, 04:22 |
| j...@apache.org |
kafka git commit: KAFKA-4193; Fix for intermittent failure in FetcherTest |
Tue, 20 Sep, 06:17 |
| j...@apache.org |
kafka git commit: KAFKA-4193; Fix for intermittent failure in FetcherTest |
Tue, 20 Sep, 06:17 |
| ij...@apache.org |
kafka git commit: HOTFIX: Added check for metadata unavailable |
Tue, 20 Sep, 10:39 |
| ij...@apache.org |
kafka git commit: HOTFIX: Added check for metadata unavailable |
Tue, 20 Sep, 10:40 |
| ij...@apache.org |
kafka git commit: KAFKA-4184; Intermittent failures in ReplicationQuotasTest.shouldBootstrapTwoBrokersWithFollowerThrottle |
Tue, 20 Sep, 14:39 |
| ij...@apache.org |
kafka git commit: KAFKA-4184; Intermittent failures in ReplicationQuotasTest.shouldBootstrapTwoBrokersWithFollowerThrottle |
Tue, 20 Sep, 14:39 |
| ij...@apache.org |
kafka git commit: KAFKA-4197; Make ReassignPartitionsTest System Test move data |
Tue, 20 Sep, 14:41 |
| ij...@apache.org |
kafka git commit: KAFKA-4197; Make ReassignPartitionsTest System Test move data |
Tue, 20 Sep, 14:41 |
| guozh...@apache.org |
kafka git commit: MINOR: add javadoc comment to PersistenKeyValueFactory.enableCaching |
Wed, 21 Sep, 18:11 |
| guozh...@apache.org |
kafka git commit: MINOR: add javadoc comment to PersistenKeyValueFactory.enableCaching |
Wed, 21 Sep, 18:11 |
| guozh...@apache.org |
kafka git commit: MINOR: remove unused code from InternalTopicManager |
Wed, 21 Sep, 18:13 |
| guozh...@apache.org |
kafka git commit: MINOR: remove unused code from InternalTopicManager |
Wed, 21 Sep, 18:13 |
| guozh...@apache.org |
kafka git commit: KAFKA-3782: Ensure heartbeat thread restarted after rebalance woken up |
Thu, 22 Sep, 17:07 |
| guozh...@apache.org |
kafka git commit: KAFKA-3782: Ensure heartbeat thread restarted after rebalance woken up |
Thu, 22 Sep, 17:08 |
| guozh...@apache.org |
kafka git commit: MINOR: Fix comments in KStreamKStreamJoinTest |
Thu, 22 Sep, 17:33 |
| guozh...@apache.org |
kafka git commit: MINOR: Fix comments in KStreamKStreamJoinTest |
Thu, 22 Sep, 17:33 |
| guozh...@apache.org |
kafka git commit: HOTFIX: Decrease commit interval |
Thu, 22 Sep, 19:45 |