@Ananth_sp, thanks for providing us the update. ... View more

@vidanimegh Thank you for your participation in our community 🙂  ... View more

Hi @blueb  感谢您提供的宝贵的反馈！   基本上 Flink 连接 Kafka 也是遵照常规 Java 项目使用 Kafka 的模式，您可以参考此链接了解常规 Java client 与 Kafka 连接时的主要选项。   您的非 CM 管理的 Kafka 集群若是未启用认证的话，应该属于"Unsecured"。   我在 Cloudera 的官方 Github 上找到了一个 Flink ↔ Kafka 的 demo 项目，您可以参考其中的job.properties。 另外这个项目还有连接 secure Kafka 的 demo 项目，其中有配置连接 Kafka 的部分。   您可以看到 job.properties 文件中定义了:  kafka.security.protocol=SASL_SSL   这个 SASL_SSL 的含义是: 使用 SASL/PLAIN (CDP 中的 Kafka 开启 Kerberos 认证参考此链接) 作为认证方式，并使用 SSL/TLS 作为数据传输方式(也就是除了配置了认证之外，还在CM UI中Enable TLS/SSL for Kafka Broker)。参考: Confluent 官方文档。  如果传输方式没有Enable TLS/SSL，那么 Kafka Broker 的日志 (/var/log/kafka/server.log) 中，您会看到 listeners = SASL_PLAINTEXT；如果开启了Kerberos 认证 (或LDAP、PAM等其他SASL认证) 又Enable TLS/SSL for Kafka Broker，那么您会看到 listeners = SASL_SSL。 另外，值得注意的是，您可以同时配置多个listener，也就是listeners = SASL_PLAINTEXT 和 listeners = SASL_SSL 可以同时存在。   另外此 demo 代码也有一个 YouTube 视频演示。    以上信息供您参考。 ... View more

Thanks for the info.  Just playing around with it a little, but looks like this will get what I need for the Data Visualization on CDP Public Cloud I am using. Thanks ... View more

@roshanbim, Has the reply helped resolve your issue? If so, please mark the appropriate reply as the solution, as it will make it easier for others to find the answer in the future. ... View more

@ManjuN, Has the reply helped resolve your issue? If so, please mark the appropriate reply as the solution, as it will make it easier for others to find the answer in the future.  If you are still experiencing the issue, can you provide the information @Asok  has requested? ... View more

@midee, were you able to implement the suggestions? Has the reply helped resolve your issue? If so, can you please mark the appropriate reply as the solution, as it will make it easier for others to find the answer in the future?   ... View more

@Sam2020 you are missing an important point here that is the Trial installation will always we available for latest software version. Since we have released CM7.4.4 last week so the error you are seeing is expected. You have to change you repo to https://archive.cloudera.com/cm7/7.4.4/redhat7/yum/repodata/ (try accessing this from browser you will understand). Bottom-line is if you have valid subscription you can still have 7.3.1 but if you want trial than you have to go for 7.4.4. ... View more

@vidanimegh, Sure. Thanks for your response, will wait for your update.  ... View more

You need a UDF to parse the XML string and extract the values. As far as I know, Impala doesn't have a native function to do it. ... View more