SAMZA-1428: Fix scala 2.10 compilation issue with java 8 interface st…
[samza.git] / samza-kafka /
3 days ago  Jacob MaesSAMZA-1392: KafkaSystemProducer performance and correct...
2017-08-11  Jacob MaesSAMZA-1387: Unable to Start Samza App Because Regex...
2017-07-17  Boris ShkolnikSAMZA-1336. Session disconnect propagation.
2017-06-03  Jacob MaesSAMZA-1317: Changelog validation error for topics with...
2017-06-02  Jacob MaesSAMZA-1317: Changelog topic configuration should accept...
2017-06-01  Jacob MaesSAMZA-1234: Documentation for 0.13.0 release
2017-05-10  Xinyu LiuSAMZA-1283: Expose the buffered-message-size metric
2017-05-09  Jacob MaesSAMZA-1275: Kafka throws when users configure replicati...
2017-05-03  Navina RameshSAMZA-1212 - Refactor interaction between StreamProcess...
2017-04-27  Jacob MaesSamza 1214: Allow users to set a default replication...
2017-04-14  James LentSAMZA-1145: Provide Ability To Confgure The Default...
2017-03-31  vjagadish1989 SAMZA-1135 - Support scala 2.12
2017-03-11  Tommy BeckerSAMZA-1112; BrokerProxy does not log fatal errors
2017-03-06  Jacob MaesSAMZA-1096: StreamSpec constructors in the ExecutionEnv...
2017-02-17  Jacob MaesSAMZA-1075: Refactor SystemAdmin Interface to expose...
2017-02-09  Shanthoosh Venkata... SAMZA-1083 Do not load task stores which are older...
2017-01-06  Boris ShkolnikSAMZA-1076; getKafkaChangelogEnabledStores() should...
2016-12-23  Xinyu LiuSAMZA-1069: Fix Deadlock between KafkaSystemProducer...
2016-12-23  Shanthoosh Venkata... SAMZA-855; Upgrade Samza's Kafka client version to...
2016-09-29  Xinyu LiuSAMZA-1028: Fix KafkaSystemProducer logging and use...
2016-09-29  vjagadish1989SAMZA-1020: Remove methods in Kafka checkpoint classes...
2016-09-23  Tommy BeckerFix SAMZA-1018.
2016-09-14  Branislav CogicSAMZA-702 - Document the significance of all the differ...
2016-08-18  Xinyu LiuSAMZA-1003: Restore lazy init for kafka system producer
2016-07-29  Xinyu LiuSAMZA-981 - Set consistent Kafka clientId for a job...
2016-07-29  Xinyu LiuSAMZA-979 - Remove KafkaCheckpointMigration
2016-07-19  Xinyu LiuSAMZA-863: Multithreading support in Samza
2016-06-14  Jacob MaesSAMZA-964 - Improve the performance of the continuous...
2016-06-08  Boris ShkolnikSAMZA-962 - Add Java friendly api to KafkaSystemConsume...
2016-05-19  Jacob MaesSAMZA-950: Add backward-compatible KafkaSystemProducer...
2016-04-27  Jagadish VenkatramanSAMZA-911: set a max retry on KafkaSystemProducer to...
2016-04-09  Ivan SimonekoSAMZA-920: BrokerProxy.abdicateAll can get stuck on...
2016-03-25  Navina RameshSAMZA-882 : Detect partition count changes in input...
2016-02-19  Boris ShkolnikSAMZA-864: allow job to continue when checkpoint partit...
2015-11-24  Monal DaxiniSAMZA-775: add consumer size-based fetch threshold
2015-11-19  Yi PanSAMZA-754: set the oldest offset to 0 on empty topic...
2015-11-18  Yan FangSAMZA-753 - BrokerProxy stop should stop the Kafka...
2015-11-02  NavinaSAMZA-798 : Performance and stability issue after combi...
2015-10-19  Aleksandar BircakovicSAMZA-791 - KafkaSystemFactory narrows return types
2015-09-28  Yi PanSAMZA-778: Fix KafkaCheckpointMigration code to avoid...
2015-09-24  Yi Pan (Data Infra... SAMZA-615: Auto-migrate Kafka checkpoints into coordina...
2015-08-24  Yan FangSAMZA-676: Implemented broadcast stream
2015-08-24  Aleksandar PejakovicSAMZA-736: Fixed infinite loop in BrokerProxy when...
2015-08-18  Aleksandar Pejakovic SAMZA-738: Samza timer based metrics does not have...
2015-08-11  Robert ZuljevicSAMZA-690: Move changelog topic creation to JobCoordinator
2015-06-16  rzuljevicSAMZA-546 Add config option max.in.flight.requests...
2015-05-15  Gustavo AnatolySAMZA-643: Improve error messages fro null stream in...
2015-04-29  Naveen SomasundaramSAMZA-465: Use coordinator stream and eliminate Checkpo...
2015-04-02  Dan HarveySAMZA-633; expose configuration to Kafka's encoder...
2015-03-23  Yan FangSAMZA-458; closing kafka system producers flushes all...
2015-03-19  Chris RiccominiSAMZA-586; disable compressed messages when sending...
2015-03-14  Benjamin FradetSAMZA-600: Move Java tests into src/test/java in samza...
2015-03-13  Chris RiccominiSAMZA-592; ignore replica not available exceptions...
2015-03-11  Chris RiccominiSAMZA-590; kafka broker proxy should relinquish ownersh...
2015-03-03  Chris RiccominiSAMZA-584; fix race condition in kafka system consumer
2015-02-28  Chris RiccominiSAMZA-579; don't drop SSPs when a topic metadata refres...
2015-02-12  Chris RiccominiSAMZA-522; upgrade to Kafka 0.8.2.0
2015-02-06  David ChenSAMZA-93; gradle check should fail if missing license...
2015-01-30  Yan FangSAMZA-503: refresh lag gauge even when not fetching...
2015-01-28  Navina RameshSAMZA-227; upgrade kafka producer to new java client
2014-12-22  Naveen SomasundaramSAMZA-226; auto-create changelogs
2014-12-15  Jakob HomanSAMZA-163: Remove mutable.ConcurrentMap when we stop...
2014-10-22  Chris RiccominiSAMZA-440; fix infinite loop in broker proxy when parti...
2014-09-16  David ChenSAMZA-412; replace assert calls in tests with appropria...
2014-08-26  Chris RiccominiSAMZA-399; make task.checkpoint.segment.bytes configurable
2014-08-26  Chris RiccominiSAMZA-393; enable log compaction for checkpoint topics...
2014-08-22  Yan FangSAMZA-361: Remove Grizzled SLF4J
2014-08-19  Chris RiccominiSAMZA-384; eliminate send method in task instance and...
2014-08-14  Chris RiccominiSAMZA-379; turn down verbosity of debug logging
2014-07-30  Chris RiccominiSAMZA-359; refactor grouper package names
2014-07-28  Jakob HomanSAMZA-123: Move topic partition grouping to the AM...
2014-06-25  Jakob HomanSAMZA-284: Resolve bundled Kafka jar issue
2014-06-19  Jakob HomanSAMZA-35: Write Javadocs for all samza-api interfaces
2014-06-18  Martin KleppmannSAMZA-296: Configuration cleanup
2014-06-13  Chris RiccominiSAMZA-289; fix race condition that makes jobs fail...
2014-06-09  Yan FangSAMZA-144; add stream level overrides for fetch size.
2014-06-05  Martin KleppmannSAMZA-275: Fix logging of exception stack traces at...
2014-05-30  Yan FangSAMZA-271; remove dead code from kafka system consumer
2014-04-22  Yan FangSAMZA-64; Fail KafkaCheckpointManager on unrecoverable...
2014-04-15  Chris RiccominiSAMZA-233; start new broker proxies when abdicating
2014-04-09  Yan FangSAMZA-231: TestKafkaSystemConsumer needs ASF header.
2014-04-08  Yan FangSAMZA-221: TestKafkaCheckpointManager is in the wrong...
2014-04-04  Zhijie ShenSAMZA-204; add ASF header to test get offset
2014-04-02  Martin KleppmannSAMZA-180: Command-line tool for manipulating checkpoin...
2014-03-27  Jakob HomanSAMZA-209: Use timeout setting when fetching metadata
2014-03-25  Chris RiccominiSAMZA-203; fix changelog restore performance by increas...
2014-03-25  Chris RiccominiTest fails with this patch. Reverting to fix.
2014-03-25  Chris RiccominiSAMZA-203; fix changelog restore performance by increas...
2014-03-24  Zhijie ShenSAMZA-44; change state topic phrasing in kafka checkpoi...
2014-03-21  Martin KleppmannSAMZA-178: Don't catch Throwable, because we want OutOf...
2014-03-21  Neha NarkhedeSAMZA-193; closing a disconnected KafkaCheckpointManage...
2014-03-20  Martin KleppmannSAMZA-174: General-purpose implementation of a retry...
2014-03-19  Jakob HomanSAMZA-161: Fix the warnings in check task
2014-03-18  Martin KleppmannSAMZA-185: Upgrade Samza to Kafka 0.8.1. Reviewed by...
2014-03-14  Chris RiccominiSAMZA-157; add samza.offset.default configuration for...
2014-03-14  Chris RiccominiSeeing issues when running with SAMZA-157, so reverting.
2014-03-13  Chris RiccominiSAMZA-157; add samza.offset.default configuration for...
2014-03-10  Martin KleppmannSAMZA-16; fix java 7 test incompatibility
2014-03-06  Martin KleppmannSAMZA-169; retry on topic metadata refresh failure...
2014-03-05  Chris RiccominiSAMZA-173; fix NPE when changelog restore includes...
next