apache-kafka - 如何在 Presto 中使用 SSL 配置 Apache Kafka

Question

我正在尝试将 Presto 配置为从 Apache Kafka 读取数据。kafka 集群运行在 SSL 协议上，想知道如何在 kafka.properties 文件中配置 ssl 协议、truststore.location 和 truststore.password？

connector.name=kafka kafka.nodes=abc1:9092,abc2:9092, abc3:9092 kafka.table-names=customer kafka.hide-internal-columns=false

我尝试添加

kafka.consumer-key=/Users/presto/kafka.truststore.jks kafka.consumer-secret=a1b2c3

但是，它失败了

ERROR main com.facebook.presto.server.PrestoServer 无法创建注入器，看到以下错误：

1) io.airlift.bootstrap.Bootstrap.lambda$initialize$2(Bootstrap.java:233) 中未使用配置属性“kafka.consumer-key”

2) io.airlift.bootstrap.Bootstrap.lambda$initialize$2(Bootstrap.java:233) 中未使用配置属性“kafka.consumer-secret”

2 错误com.google.inject.CreationException: Unable to create injector，看到如下错误：

1) io.airlift.bootstrap.Bootstrap.lambda$initialize$2(Bootstrap.java:233) 中未使用配置属性“kafka.consumer-key”

2) io.airlift.bootstrap.Bootstrap.lambda$initialize$2(Bootstrap.java:233) 中未使用配置属性“kafka.consumer-secret”

在 com.google.inject.internal.InternalInjectorCreator.initializeStatically(InternalInjectorCreator.java:159) 在 com.google.inject.internal.InternalInjectorCreator 的 com.google.inject.internal.Errors.throwCreationExceptionIfErrorsExist(Errors.java:543) 有 2 个错误.build(InternalInjectorCreator.java:106) 在 com.google.inject.Guice.createInjector(Guice.java:87) 在 io.airlift.bootstrap.Bootstrap.initialize(Bootstrap.java:240) 在 com.facebook.presto。 kafka.KafkaConnectorFactory.create(KafkaConnectorFactory.java:87) at com.facebook.presto.connector.ConnectorManager.createConnector(ConnectorManager.java:352) at com.facebook.presto.connector.ConnectorManager.addCatalogConnector(ConnectorManager.java:216)在 com.facebook.presto.connector.ConnectorManager.createConnection(ConnectorManager.java:208) 在 com.facebook.presto。connector.ConnectorManager.createConnection(ConnectorManager.java:194) 在 com.facebook.presto.metadata.StaticCatalogStore.loadCatalog(StaticCatalogStore.java:96) 在 com.facebook.presto.metadata.StaticCatalogStore.loadCatalogs(StaticCatalogStore.java:74)在 com.facebook.presto.server.PrestoServer.run(PrestoServer.java:131) 在 com.facebook.presto.server.PrestoServer.main(PrestoServer.java:73)

标签： apache-kafkapresto