Kim

sasl authenticate error : EOF

12

 inputs: - Kafka: decorate_events: false topic: topicname: 5 #assign: # weblog: [0,9] codec: plain consumer_settings: bootstrap.servers: "xxxxxx:9093" group.id: xxxxxx max.partition.fetch.bytes: '10485760' auto.commit.interval.ms: '5000' from.beginning: 'false' sasl.mechanism: 'PLAIN' sasl.user: '******'...

source_schemas的 设计缺陷问题

2

source_schemas的schemas字段，目前保存的是 所有库、表、字段的一个大JSON。 但是按照实际稍微大一点的企业的大数据的数据表的规模会达到上万张，比如，impala查询引擎就有这个问题。

**Datart Version** 1.0.0-beta.4 **Describe the bug** 

**Describe the bug(Please use English)** Elasticsearch7 connection reset by peer **Environment :** - Flink version : 1.13.6 - Flink CDC version: 2.2.1 - Database and version: mysql-5.7 - Flink-sql-connector-elasticsearch7: 2.11-1.13.6...

[Feature][Seatunnel engine] The st engine own indicators support the protocol specification of OpenTelemetry

1

### Search before asking - [X] I had searched in the [feature](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22Feature%22) and found no similar feature requirement. ### Description The indicators data of the ST engine itself can only...

[Feature][zeta][monitoring] Support exposing monitoring metrics by prometheus exporter protocol (#5070)

16

PR for #5070 The final effect ： https://github.com/kim-up/incubator-seatunnel/blob/telemetry/docs/en/seatunnel-engine/telemetry.md ## Overall Design  ### Node Hazelcast Metrics Getting metrics from `ManagedExecutorServiceMBean` - systemExecutorMBean - asyncExecutorMBean - scheduledExecutorMBean - clientExecutorMBean - clientQueryExecutorMBean...