kafka.git
11 hours ago  Jason GustafsonMINOR: Fix transiently failing consumer group admin... trunk
12 hours ago  Jorge Quilcate... KAFKA-6850: Add Record Header support to Kafka Streams...
14 hours ago  Jeremy CustenborderKAFKA-5807 - Check Connector.config() and Transformatio...
16 hours ago  Jason GustafsonMINOR: AdminClient consumer group domain objects should...
17 hours ago  Jason GustafsonMINOR: AdminClient metadata manager should reset state...
18 hours ago  Ismael JumaMINOR: Remove o.a.kafka.common.utils.Base64 and IS_JAVA...
19 hours ago  Filipe AgapitoKAFKA-6474: Rewrite tests to use new public TopologyTes...
27 hours ago  Ismael JumaMINOR: Remove unnecessary conditional in KafkaAdminClie...
28 hours ago  Ismael JumaKAFKA-4423: Drop support for Java 7 (KIP-118) and updat...
30 hours ago  Jagadesh AdireddiKAFKA-6685: Added Exception to distinguish message...
34 hours ago  Guozhang WangMINOR: Ignore test_broker_type_bounce_at_start system...
40 hours ago  Guozhang WangMINOR: Reduce required occurrance from 100 to 10 (...
43 hours ago  Colin Patrick... KAFKA-6868; Fix buffer underflow and expose group state...
2 days ago  Joan GoyeauMINOR: Fix type inference on joins and aggregates ...
2 days ago  Guozhang WangKAFKA-6729: Follow up; disable logging for source KTabl...
3 days ago  David GlasserKAFKA-6905: Document that Transformers may be re-used...
4 days ago  Andy CoatesKAFKA-6849: add transformValues methods to KTable....
4 days ago  Rajini SivaramKAFKA-6917; Process txn completion asynchronously to...
4 days ago  Guozhang WangMINOR: Remove unused class (#5037)
4 days ago  Robert YokotaKAFKA-6566: Improve Connect Resource Cleanup
4 days ago  John RoeslerKAFKA-5697: revert wakeup-based impl (#5035)
5 days ago  Guozhang WangHOTFIX: use ConsumedInternal in StreamsBuilder
5 days ago  Guozhang WangHOTFIX: move Conusmed to o.a.k.streams.kstream (#5033)
5 days ago  Guozhang WangKAFKA-6729: Reuse source topics for source KTable's...
5 days ago  Joan GoyeauMINOR: Use Set instead of List for multiple topics...
6 days ago  Matthias J... MINOR: add missing parameter `processing.guaratees...
6 days ago  Guozhang WangMINOR: fix broken links in streams doc (#5025)
6 days ago  David GlasserKAFKA-6905: Document that Processors may be re-used...
7 days ago  Guozhang WangMINOR: doc change for deprecate removal (#5006)
7 days ago  Boyang ChenKAFKA-6896: Add producer metrics exporting in KafkaStre...
8 days ago  Dong LinKAFKA-3473; More Controller Health Metrics (KIP-237)
11 days ago  Matthias J... MINOR: Ensure sensor names are unique in Kafka Streams...
11 days ago  Matthias J... HOTFIX: RegexSourceIntegrationTest needs to cleanup...
11 days ago  Guozhang WangKAFKA-6813: Remove deprecated APIs in KIP-182, Part...
11 days ago  Joel HamillMINOR - Fix typo in Streams Dev Guide (#4972)
11 days ago  Joan GoyeauMINOR: Count fix and Type alias refactor in Streams...
11 days ago  Manikumar Reddy OKAFKA-6394; Add a check to prevent misconfiguration...
11 days ago  fedosov-alexanderKAFKA-5965: Remove Deprecated AdminClient from Streams...
12 days ago  Ismael JumaMINOR: Rename RecordFormat to RecordVersion (#4809)
12 days ago  Jason GustafsonMINOR: A few small cleanups in AdminClient from KAFKA...
12 days ago  Robert YokotaKAFKA-6894: Improve err msg when connecting processor...
12 days ago  Rajini SivaramKAFKA-6893; Create processors before starting acceptor...
12 days ago  Gunju KoMINOR: Fix typo in ConsumerRebalanceListener JavaDoc...
12 days ago  Guozhang WangMINOR: Remove deprecated valueTransformer.punctuate...
12 days ago  Rajini SivaramMINOR: Update dynamic broker configuration doc for...
12 days ago  Chia-Ping TsaiKAFKA-6870 Concurrency conflicts in SampledStat (#4985)
13 days ago  Anna Povzner KAFKA-6361: Fix log divergence between leader and...
13 days ago  Guozhang WangKAFKA-6813: Remove deprecated APIs in KIP-182, Part...
13 days ago  tedyuKAFKA-6878 Switch the order of underlying.init and...
13 days ago  Colin Patrick... KAFKA-6299; Fix AdminClient error handling when metadat...
13 days ago  tedyuKAFKA-6878: NPE when querying global state store not...
13 days ago  asutosh936KAFKA 6673: Implemented missing override equals method...
2018-05-09  Rajini SivaramKAFKA-6834: Handle compaction with batches bigger than...
2018-05-09  Colin Patrick... MINOR: Fix trace logging in ReplicaManager (#4916)
2018-05-09  Adem Efe GencerKAFKA-6877; Remove completedFetch upon a failed parse...
2018-05-09  Roman KhlebnovKAFKA-6292; Improve FileLogInputStream batch position...
2018-05-08  dan norwoodMINOR: add equals()/hashCode() for Produced/Consumed...
2018-05-08  Jason GustafsonKAFKA-6879; Invoke session init callbacks outside lock...
2018-05-08  Joan GoyeauMINOR: Make Serdes less confusing in Scala (#4963)
2018-05-08  Guozhang WangKAFKA-6813: Remove deprecated APIs in KIP-182, Part...
2018-05-07  Liju JohnKAFKA-6628: RocksDBSegmentedBytesStoreTest does not...
2018-05-07  Guozhang WangMINOR: Remove deprecated KTable#writeAs, print, foreach...
2018-05-07  Michael G.... KAFKA-6871: KStreams Scala API: incorrect Javadocs...
2018-05-07  Guozhang WangMINOR: Remove deprecated parameter in ProcessorContext...
2018-05-07  Filipe AgapitoKAFKA-6474: Rewrite tests to use new public TopologyTes...
2018-05-07  Sean GloverMINOR: Build and code sample updates for Kafka Streams...
2018-05-04  Guozhang WangMINOR: Remove KafkaStreams#toString (#4909)
2018-05-04  Surabhi DixitKAFKA-6867; Corrected the typos in upgrade.html (#4970)
2018-05-04  Bill BejeckKAFKA-6844: Call shutdown on GlobalStreamThread after...
2018-05-04  Guozhang WangHOTFIX: fix streams tutorial code example
2018-05-04  John RoeslerKAFKA-5697: issue Consumer#wakeup during Streams shutdown
2018-05-04  Guozhang WangMINOR: Removed deprecated schedule function (#4908)
2018-05-04  Bill BejeckKAFKA-6761: Part 1 of 3; Graph nodes (#4923)
2018-05-04  Anna PovznerKAFKA-6857; Leader should reply with undefined offset...
2018-05-03  Rajini SivaramKAFKA-6854; Handle batches deleted during log cleaning...
2018-05-03  Fedor BobinKAFKA-6853: ZooKeeperRequestLatencyMs is incorrect...
2018-05-03  Ismael JumaUpgrade ZooKeeper to 3.4.12 and Scala to 2.12.6 (#4940)
2018-05-03  Bill BejeckKAFKA-6829: retry commits on unknown topic or partition...
2018-05-02  Guozhang WangHOTFIX: Simplify ConsoleConsumer stripWithPrefix function
2018-05-02  Boyang ChenKAFKA-6657: Add StreamsConfig prefix for different...
2018-05-02  Guozhang WangKAFKA-6825: Make StreamsConfig#DEFAULT_PRODUCTION_EXCEP...
2018-05-01  Mickael MaisonMINOR: Removed unused imports in a few tests (#4938)
2018-05-01  Rajini SivaramKAFKA-6526: Enable unclean leader election without...
2018-04-30  Rajini SivaramKAFKA-6810; Enable dynamic update of SSL truststores...
2018-04-30  Jason GustafsonMINOR: Ensure exception messages include partition...
2018-04-30  Manikumar Reddy OMINOR: Fix sasl.jaas.config doc string (#4921)
2018-04-30  Mickael MaisonKAFKA-3417: Wrap metric reporter calls in try/catch...
2018-04-30  khairyKAFKA-6535: Set default retention ms for Streams repart...
2018-04-29  Colin Patrick... KAFKA-6785: Add Trogdor documentation (#4862)
2018-04-29  Colin Patrick... MINOR: Fix Trogdor tests, partition assignments (#4892)
2018-04-28  Bill BejeckMINOR: update VerifiableProducer to send keys if config...
2018-04-27  manjuapuFix streams web doc configs tables (#4943)
2018-04-27  manjuapuMINOR: Streams web doc table fix (#4942)
2018-04-27  Guozhang WangHOTFIX: rename run_test to execute in streams simple...
2018-04-27  Max ZhengMINOR: Pin pip to 9.0.3 as 10 is not compatible with...
2018-04-26  Manikumar Reddy OKAFKA-6778; AdminClient.describeConfigs() should return...
2018-04-26  Guozhang WangMINOR: Remove deprecated streams config (#4906)
2018-04-26  Filipe AgapitoKAFKA-6474: Rewrite tests to use new public TopologyTes...
2018-04-26  Jarek RudzinskiMINOR: use jdk8 to build/run system tests (#4925)
2018-04-26  Bill BejeckMINOR: Fixes for streams system tests (#4935)
next