addErrorBatchingFeature().run(); If you describe your feature (e.g., “add WebSocket output” or “implement retry on failed transformations”), I can give you a ready-to-use Scramjet implementation.