kafka.git
11 hours ago  Konstantine... MINOR: Add async and different sync startup modes in... trunk
11 hours ago  Matthias J... MINOR: increase timeout for unstable KTableSourceTopicR...
11 hours ago  Matthias J... MINOR: update docs with regard to improved resilience...
30 hours ago  Konstantine... KAFKA-6277: Ensure loadClass for plugin class loaders...
2 days ago  Jason GustafsonKAFKA-6366: Fix stack overflow in consumer due to many...
4 days ago  Jeff WidmanMINOR: Fix typo in Log.scala: "actually recovery" ...
4 days ago  Guozhang WangMINOR: Improve on reset integration test (#4436)
4 days ago  Guozhang WangKAFKA-6398: Return value getter based on KTable materia...
4 days ago  mulvennaMINOR: Fix a typo in a comment in config/server.propert...
4 days ago  Edoardo ComarMINOR: additional check to follower fetch handling...
4 days ago  manjuapuStreams Use case anchor (#4420)
4 days ago  Gunnar MorlingKAFKA-6456; JavaDoc clarification for Connect SourceTas...
4 days ago  Andras BeniMINOR: Fix error message in KafkaConfig validation...
4 days ago  Magnus ReftelMINOR: Fix typo in KafkaConsumer javadoc (#4422)
4 days ago  Guozhang Wangimprove internal topic integration test (#4437)
4 days ago  dan norwoodMINOR: Need to get a new transformer for each get(...
5 days ago  Matthias J... KAFKA-6302: Improve AdmintClient JavaDocs
5 days ago  Matthias J... KAFKA-6382: Make ProducerConfig and ConsumerConfig...
6 days ago  RichardYuSTUGKAFKA-6328: Sort node groups considering global stores...
6 days ago  Guozhang WangMINOR: Improve Join integration test coverage, PART II
6 days ago  Jeyhun KarimovKAFKA-4218: Enable access to key in ValueTransformer...
6 days ago  Joel HamillMINOR: Fix typo (#4426)
6 days ago  Manikumar ReddyKAFKA-4541; Support for delegation token mechanism
8 days ago  cmolterKAFKA-5890; records.lag should use tags for topic and...
10 days ago  RichardYuSTUG4385
10 days ago  Guozhang WangMINOR: Improve Join integration test coverage, PART I
11 days ago  Gavrie PhilipsonKAFKA-6250: Use existing Kafka Connect internal topics...
11 days ago  Richard YuKAFKA-6265: Add #queryableStoreName() to GlobalKTable
12 days ago  Rohan DesaiKAFKA-6383: Complete shut down for streams threads...
12 days ago  Jun RaoMerge pull request #3567 from bobrik/unclean-docs-clari...
12 days ago  Guozhang WangKAFKA-6398: fix KTable.filter that does not include...
12 days ago  tedyuKAFKA-6412 Improve synchronization in CachingKeyValueSt...
13 days ago  Joel HamillMINOR: Menu updates and navigation (#4405)
13 days ago  Chris EgertonKAFKA-4247; Prevent CLASSPATH from beginning with a...
2018-01-09  Rajini SivaramKAFKA-6096: Add multi-threaded tests for group coordina...
2018-01-08  lisa2lisaKAFKA-6422 Mirror maker will throw null pointer excepti...
2018-01-08  Jorge Quilcate... Updating docs for streams app reset tool (#4401)
2018-01-08  Filipe AgapitoKAFKA-6363: Use MockAdminClient for any unit tests...
2018-01-08  Joel HamillMINOR: Fix menu ordering in streams docs
2018-01-08  Ewen Cheslack... MINOR: Improve exception messages when state stores...
2018-01-08  Joel HamillMINOR: fix image 404s in streams doc
2018-01-08  Romain HardouinMINOR: Catch JsonMappingException subclass (#3821)
2018-01-08  Matt FarmerMINOR: Add documentation for KAFKA-6086 (ProductionExce...
2018-01-06  Arjun SatishKAFKA-6252; Close the metric group to clean up any...
2018-01-06  StudyKAFKA-4335: Add batch.size to FileStreamSource connecto...
2018-01-05  Ewen Cheslack... KAFKA-6311: Expose Kafka cluster ID in Connect REST...
2018-01-04  Ismael JumaMINOR: Fix concurrency bug in MetadataCache and Metadat...
2018-01-04  Narendra kumarKAFKA-6298; Added support for location aware logger...
2018-01-03  Ismael JumaMINOR: Fix zk client session state metric names and...
2018-01-03  Rajini SivaramKAFKA-6415; Use WARN log level for Metadata in system...
2018-01-03  Matthias J... KAFKA-6256: fix flaky test KStreamKTableJoinIntegration...
2018-01-02  Guozhang WangRevert "KAFKA-6383: complete shutdown for CREATED Strea...
2018-01-02  Wladimir SchmidtMINOR: refactored code duplicates in several files...
2018-01-02  Siva SanthalingamKAFKA-6318: StreamsResetter should return non-zero...
2018-01-02  Clemens ValienteKAFKA-6391 ensure topics are created with correct parti...
2018-01-02  Guozhang WangFix wrong property mentioned in doc; Author: Praveen...
2018-01-02  Bill BejeckKAFKA-6269: KTable restore fails after rebalance (... 4370/head
2018-01-02  Matthias J... KAFKA-5368: Add test for skipped-records metric (#4365)
2018-01-02  RohanKAFKA-6383: complete shutdown for CREATED StreamThreads...
2018-01-01  Koen De GrooteReplace Arrays.asList with Collections.singletonList...
2018-01-01  tedyuKAFKA-6307: Fix KafkaMbean leak in JmxReporter (#4307)
2017-12-29  Matthias J... MINOR: Temporarily disable flaky Streams EOS system...
2017-12-29  Koen De GrooteMINOR: Use EnumMap/EnumSet if possible (#3919)
2017-12-28  Satish DugganaMINOR: Fixed clusterId reference in Metadata.update...
2017-12-27  Manikumar Reddy OMINOR: Update test classes to use KafkaZkClient/AdminZk...
2017-12-23  Vahid HashemianMINOR: Use TopicPartition in ConsumerGroupCommand inste...
2017-12-22  Guozhang WangMINOR: Web docs for KIP-220
2017-12-22  Matthias WessendorfKAFKA-5772 Improve Util classes (#3370)
2017-12-22  Ismael JumaKAFKA-6390: Update ZooKeeper to 3.4.11, Gradle and...
2017-12-22  Jun RaoKAFKA-6320: Move ZK metrics in KafkaHealthCheck to...
2017-12-22  Matthias WessendorfKAFKA-5895: Gradle 3.0+ is needed on the build (#3861)
2017-12-22  Ismael JumaMINOR: Use GitHub git repo for push by default (#4352)
2017-12-21  Joel HamillMINOR: Improve Streams Dev Guide content on web docs
2017-12-21  Guozhang WangMINOR: Fix race condition in Streams EOS system test
2017-12-21  Matthias J... KAFKA-6126: Remove unnecessary topics created check
2017-12-20  Matthias J... KAFKA-4263: Fix flaky test QueryableStateIntegrationTes...
2017-12-20  Colin P. MccabeKAFKA-5849; Add process stop, round trip workload,...
2017-12-20  Manikumar ReddyKAFKA-5647; Use KafkaZkClient in ReassignPartitionsComm...
2017-12-20  Rajini SivaramKAFKA-5746; Document new broker metrics added for healt...
2017-12-20  Dong LinKAFKA-6331; Fix transient failure in AdminClientIntegra...
2017-12-20  Guozhang WangKAFKA-6150: KIP-204 part III; Change repartition topic...
2017-12-19  Bill BejeckMINOR: Broker down for significant amt of time system...
2017-12-19  Ismael JumaKAFKA-6317; Maven artifact for kafka should not depend...
2017-12-19  Matthias J... MINOR: Fix race condition in KafkaStreamsTest.shouldRet...
2017-12-19  Matthias J... MINOR: Stabilize flaky smoke system tests before KIP-91
2017-12-18  Dong LinKAFKA-6258; SSLTransportLayer should keep reading from...
2017-12-18  Matthias J... MINOR: improve JavaDocs for KafkaStreams, KafkaProducer...
2017-12-15  Prasanna GautamKAFKA-5473; handle ZK session expiration properly when...
2017-12-15  Vahid HashemianKAFKA-5526; Additional `--describe` views for ConsumerG...
2017-12-15  Matt FarmerKAFKA-6086: Provide for custom error handling when...
2017-12-14  Tobias GiesKAFKA-6308; Connect Struct should use deepEquals/deepHa...
2017-12-14  Colin P. MccabeKAFKA-6102; Consolidate MockTime implementations betwee...
2017-12-14  Damian GuyKAFKA-6360: Clear RocksDB Segments when store is closed
2017-12-13  Damian GuyKAFKA-6349: Fix concurrent modification exception in...
2017-12-13  Damian GuyMINOR: Fix warn logging in RecordCollectorImpl
2017-12-12  Manikumar ReddyKAFKA-5764; Add toLowerCase support to sasl.kerberos...
2017-12-12  umesh chaudharyKAFKA-5631; Use Jackson for serialising to JSON
2017-12-12  Rajini SivaramKAFKA-6319: Quote strings stored in JSON configs
2017-12-12  Ismael JumaKAFKA-6324; Change LogSegment.delete to deleteIfExists...
2017-12-12  Guozhang WangKAFKA-6334: minor typo fix in web docs
next