使用Kafka Confluent Teradata源连接器将表中的数据读取到Kafka主题中。只要Teradata表不包含Column Title，这就可以正常工作。如果存在Column Title，则它引用的是Column Title，而不是列名并得到错误。在错误消息中，Emp ID是列标题，Emp_ID是列名。
Error:
Caused by: org.apache.avro.SchemaParseException: Illegal character in: Emp ID
at org.apache.avro.Schema.validateName(Schema.java:1532)
at org.apache.avro.Schema.access$400(Schema.java:87)
at org.apache.avro.Schema$Field.<init>(Schema.java:520)
at org.apache.avro.Schema$Field.<init>(Schema.java:559)
尝试了多种选项，并提出了以下在属性文件中进行查询的解决方法，这与预期的一样有效。但问题是，我们有100个表要从Teradata中提取，使用这种解决方法，我们需要为每个表创建单独的属性文件，并且必须明确提及所有列。从维护的角度来看，这变得很复杂。
query=SELECT EMP_ID AS EMP_ID, CRET_TS AS CRET_TS FROM schema.table
希望有人能帮上忙。
将COLUMN_NAME=ON选项附加到Teradata URL
jdbc:teradata://mytdname/COLUMN_NAME=ON,