Skip to content

[Bug] [Kafka Source] Failed when the consume topic name like a.b.c.d #8396

@liunaijie

Description

@liunaijie

Search before asking

  • I had searched in the issues and found no similar issues.

What happened

When consume topic name has more than 2 ., will got exception.

the code is:
https://github.com/apache/seatunnel/blob/dev/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceConfig.java#L208

https://github.com/apache/seatunnel/blob/dev/seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/TablePath.java#L53

SeaTunnel Version

dev

SeaTunnel Config

read kafka, topic name is `a.b.c.d`

Running Command

na

Error Exception

Cannot get split '%s' to get databaseName and tableName

Zeta or Flink or Spark Version

No response

Java or Scala Version

No response

Screenshots

No response

Are you willing to submit PR?

  • Yes I am willing to submit a PR!

Code of Conduct

Metadata

Metadata

Assignees

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions