Issues · salesforce/storm-dynamic-spout · GitHub

This repository was archived by the owner on Feb 12, 2022. It is now read-only.

Labels Milestones

Test / Verify what happens with zookeeper cluster becomes unavailable

#103

· Crim opened

on Jan 26, 2018

Test / Verify what happens when Kafka Brokers become unavailable

#102

· Crim opened

on Jan 26, 2018

Define Concrete Config classes for DynamicSpout, Sideline, and KafkaConsumer

#80

· Crim opened

on Nov 24, 2017

[SIDELINE] Cleanup PersistenceAdapter.persistSidelineRequestState()

#75

· stanlemon opened

on Nov 22, 2017

Reconcile DelegateSpout & VirtualSpout nomenclature

#70

· stanlemon opened

on Nov 22, 2017

Investigate long running tests

#49

· stanlemon opened

on Nov 3, 2017

Support consumer state that isn't an integer

#32

· stanlemon opened

on Oct 24, 2017

·

[KAFKA] Add support to override consumer position and reset to head/tail

#29

· stanlemon opened

on Oct 21, 2017

[KAFKA] On Consumer offset out of range, number of processed messages stat becomes incorrect

#22

· Crim opened

on Oct 20, 2017

·

Break DynamicSpout, KafkaConsumer, and SidelineSpout into separate modules

#19

· Crim opened

on Oct 18, 2017