Glad to hear that. Thanks for update. --
Best wishes to you ! From ：Xiaoxiang Yu 在 2020-10-20 17:30:00，"张敏" <zhang_...@startimes.com.cn> 写道： It works! thank you : ) | | 张敏 | | zhang_...@startimes.com.cn | 签名由网易邮箱大师定制 On 10/20/2020 16:37，Xiaoxiang Yu<x...@apache.org> wrote： After research, I guess you can try to add "kylin.source.kafka.config-override.xxx" for consumer related properties in Cube level configuration and try again. If you have some time, you can check source code at "https://github.com/apache/kylin/blob/fb4cdb32828a6508dcb8fd2cd953762dbd8a7e02/stream-source-kafka/src/main/java/org/apache/kylin/stream/source/kafka/KafkaSource.java#L75"; to confirm . -- Best wishes to you ! From ：Xiaoxiang Yu 在 2020-10-20 15:10:06，"Xiaoxiang Yu" <x...@apache.org> 写道： >Hi, > 1. From "Caused by: org.apache.kafka.common.errors.TimeoutException: > Timeout expired while fetching topic metadata" in your log files, I guess you > did not configure kafka broker list in correct way. Please >double check this doc : >http://kylin.apache.org/docs/tutorial/realtime_olap.html . > 2. kylin-kafka-consumer.xml won't take effect for Realtime OLAP because it > is used for NRT ( http://kylin.apache.org/docs/tutorial/cube_streaming.html > ) . > >-- > >Best wishes to you ! >From ：Xiaoxiang Yu > > > > >在 2020-10-20 14:18:58，"张敏" <zhang_...@startimes.com.cn> 写道： > >Hi, > Sorry about the screenshots. > I attached kylin-kafka-consumer.xml & kylin instance log kylin.out in the > attachment. Receiver instances have no log actually. > Thank you a lot. > > > >| >| > > >| >| >zhang_...@startimes.com.cn >| >签名由网易邮箱大师定制 >On 10/20/2020 12:06，Xiaoxiang Yu<x...@apache.org> wrote： >Hi, > I cannot see your screenshots, maybe you can try to use plain text format > to share with us your error messages/exceptions, I perfer you to upload logs > both from kylin instance & receiver instances. > >-- > >Best wishes to you ! >From ：Xiaoxiang Yu > > > > >在 2020-10-20 10:57:18，"张敏" <zhang_...@startimes.com.cn> 写道： > > > >encryption between clients and brokers in my kafka cluster : > - port 9092: Plaintext > - port 9094: TLS > > >it's all good to test with kafka-console-producer.sh and >kafka-console-consumer.sh on the machine where kylin is located > > >it's also ok when specify 9092 in kylin, like cube kylin_test_cube, while >there is no other configuration > > > > >but failed to enable kylin_ssl_test_cube which is ssl encryption（port 9094）, I >did update conf/kylin-kafka-consumer.xml > > > > > > > > >Did I make any wrong configuration? thank you >签名由网易邮箱大师定制
