What's Changed

What's Changed

• Add self repaired feature, that provide a param 'fix_pos_newest' for pipline. If set 'fix_pos_newest' is true,when pipeline failed to sync mysql while the error is that binlog file is not exist, binlogo will update the newest position for this pipeline.
• Closed dashboard repo, merge that to this repo.
• Set ElasticSearch output, provie add & update function, but the sender function is not implemented.

• more stable
• optimized codes

Resolve some bugs

• The first issue was that the node had exited, but a proper re-election process was not triggered.
• The second issue stemmed from inadequate concurrency control, resulting in pipeline stages not functioning correctly.

• fixbug: data change more than once in the transaction will loss
• feature: add prometheus metrics
• feature: use object pool for reducing gc and memory use

• fixbug: If etcd connection is lost during startup, it will become a zombie process

• Add Redis output
• Add RocketMQ output
• Add some events
• Fix bugs by etcd disconnectd
• Change send logic, block if send error
• Change node register logic, quite if register lease lose
• Rewrite election code
• Add front-end code relatively

Fixbug:

• When aggregating events, wrong way of time comparison
• Add configuration of ETCD username
  Feature:
• When configuring the pipeline on console, some inputs use a larger text type

• ADD RabbitMQ output