4536 Commits (697a4af35a3672dd339c3a6a34d5ab27e31e0fbd)
 

Author SHA1 Message Date
Filipe Agapito 697a4af35a KAFKA-6363: Use MockAdminClient for any unit tests that depend on AdminClient (#4371) 7 years ago
Joel Hamill 26270983cd MINOR: Fix menu ordering in streams docs 7 years ago
Ewen Cheslack-Postava e1c407973f MINOR: Improve exception messages when state stores cannot be accessed. (#4383) 7 years ago
Joel Hamill d63f94797c MINOR: fix image 404s in streams doc 7 years ago
Romain Hardouin a7e49027b2 MINOR: Catch JsonMappingException subclass (#3821) 7 years ago
Matt Farmer e1c5d0c119 MINOR: Add documentation for KAFKA-6086 (ProductionExceptionHandler) (#4395) 7 years ago
Arjun Satish 3b03c9d348 KAFKA-6252; Close the metric group to clean up any existing metrics 7 years ago
Study ecf0ab42c1 KAFKA-4335: Add batch.size to FileStreamSource connector to prevent OOM 7 years ago
Ewen Cheslack-Postava bfb272c5cd KAFKA-6311: Expose Kafka cluster ID in Connect REST API (KIP-238) (#4314) 7 years ago
Ismael Juma 3ea2d912c8 MINOR: Fix concurrency bug in MetadataCache and Metadata request when listeners inconsistent (#4374) 7 years ago
Narendra kumar f459a31ccb KAFKA-6298; Added support for location aware logger which fixes log line numbers (#4311) 7 years ago
Ismael Juma 98296f852f MINOR: Fix zk client session state metric names and various async zk clean-ups 7 years ago
Rajini Sivaram 3de910319e KAFKA-6415; Use WARN log level for Metadata in system test 7 years ago
Matthias J. Sax 6869f95232 KAFKA-6256: fix flaky test KStreamKTableJoinIntegrationTest.shouldCountClicksPerRegionWithNonZeroByteCache 7 years ago
Guozhang Wang 2119e9f26e Revert "KAFKA-6383: complete shutdown for CREATED StreamThreads (#4343)" 7 years ago
Wladimir Schmidt d61a592c8a MINOR: refactored code duplicates in several files (Streams project) (#4357) 7 years ago
Siva Santhalingam fd2bdbfd70 KAFKA-6318: StreamsResetter should return non-zero return code on error (#4305) 7 years ago
Clemens Valiente 5ca1226c22 KAFKA-6391 ensure topics are created with correct partitions BEFORE building the… (#4347) 7 years ago
Guozhang Wang f8593b0958 Fix wrong property mentioned in doc; Author: Praveen K Palaniswamy <yourspraveen@gmail.com> 7 years ago
Bill Bejeck 0ecc3596b4 KAFKA-6269: KTable restore fails after rebalance (#4300) 7 years ago
Matthias J. Sax 39f2d4588f KAFKA-5368: Add test for skipped-records metric (#4365) 7 years ago
Rohan 47db063c31 KAFKA-6383: complete shutdown for CREATED StreamThreads (#4343) 7 years ago
Koen De Groote 96df93522f Replace Arrays.asList with Collections.singletonList where possible (#4368) 7 years ago
tedyu 5d4965bad4 KAFKA-6307: Fix KafkaMbean leak in JmxReporter (#4307) 7 years ago
Matthias J. Sax 2cefe3f0d0 MINOR: Temporarily disable flaky Streams EOS system tests (#4355) 7 years ago
Koen De Groote 2bc780b959 MINOR: Use EnumMap/EnumSet if possible (#3919) 7 years ago
Satish Duggana a3aea3cf4d MINOR: Fixed clusterId reference in Metadata.update (#4360) 7 years ago
Manikumar Reddy O 89b245baa7 MINOR: Update test classes to use KafkaZkClient/AdminZkClient methods (#4353) 7 years ago
Vahid Hashemian 5fc3fd48b0 MINOR: Use TopicPartition in ConsumerGroupCommand instead of TopicAndPartition where possible (#4333) 7 years ago
Guozhang Wang 5995453f4c MINOR: Web docs for KIP-220 7 years ago
Matthias Wessendorf 0538f15ac3 KAFKA-5772 Improve Util classes (#3370) 7 years ago
Ismael Juma 2652565d42
KAFKA-6390: Update ZooKeeper to 3.4.11, Gradle and other minor updates (#4345) 7 years ago
Jun Rao 27c2c81663 KAFKA-6320: Move ZK metrics in KafkaHealthCheck to ZookeeperClient (#4351) 7 years ago
Matthias Wessendorf 43aaa7c363 KAFKA-5895: Gradle 3.0+ is needed on the build (#3861) 7 years ago
Ismael Juma 9fcb0017d7
MINOR: Use GitHub git repo for push by default (#4352) 7 years ago
Joel Hamill 3e2fe17c08 MINOR: Improve Streams Dev Guide content on web docs 7 years ago
Guozhang Wang 7d6f6f7320 MINOR: Fix race condition in Streams EOS system test 7 years ago
Matthias J. Sax dca1474b4b KAFKA-6126: Remove unnecessary topics created check 7 years ago
Matthias J. Sax 9cacb92d13 KAFKA-4263: Fix flaky test QueryableStateIntegrationTest.concurrentAccess 7 years ago
Colin P. Mccabe 760d86a970 KAFKA-5849; Add process stop, round trip workload, partitioned test 7 years ago
Manikumar Reddy 488ea4b9fd KAFKA-5647; Use KafkaZkClient in ReassignPartitionsCommand and PreferredReplicaLeaderElectionCommand 7 years ago
Rajini Sivaram 35c1be7469 KAFKA-5746; Document new broker metrics added for health checks 7 years ago
Dong Lin cdb3955452 KAFKA-6331; Fix transient failure in AdminClientIntegrationTest.testAlterReplicaLogDirs 7 years ago
Guozhang Wang 82c6d429e7 KAFKA-6150: KIP-204 part III; Change repartition topic segment size and ms 7 years ago
Bill Bejeck f3b9afe622 MINOR: Broker down for significant amt of time system test 7 years ago
Ismael Juma 88c2b6849a KAFKA-6317; Maven artifact for kafka should not depend on log4j 7 years ago
Matthias J. Sax 9aad649fd0 MINOR: Fix race condition in KafkaStreamsTest.shouldReturnThreadMetadata 7 years ago
Matthias J. Sax 22f742cdd2 MINOR: Stabilize flaky smoke system tests before KIP-91 7 years ago
Dong Lin 066bfc314c KAFKA-6258; SSLTransportLayer should keep reading from socket until either the buffer is full or the socket has no more data 7 years ago
Matthias J. Sax e86f70ed20 MINOR: improve JavaDocs for KafkaStreams, KafkaProducer, KafkaConsumer 7 years ago