https://www.javainuse.com/spring/spring-boot-apache-kafka-hello-world
我按照這個例子構建了一個簡單的 Kafka 生產者來進行一些測驗。但是，我的 Kafka 實體不是本地的，由我公司的基礎架構團隊管理，因此它運行在遠程服務器上。我有運行它的地址和埠，但我不確定如何配置我的應用程式以連接到它。我是否需要使用 application.properties 檔案來定義 kafka 地址池或類似的東西？
spring.kafka.bootstrap-servers=[kafka-server-1:port],[kafka-server-2:port]
spring.kafka.consumer.group-id=my-sample-group
spring.kafka.security.protocol=SSL
在我為消費者關注的教程中，我的 application.properties 中有類似的內容，但我不確定生產者是否相同或應該不同。這里的第二個值似乎特定于消費者，并且基于我的 IDE 中的自動完成功能，我沒有看到生產者的類似值。
任何幫助表示贊賞
我已經更改了我的代碼并按照https://docs.spring.io/spring-kafka/reference/html/#spring-boot-producer-app 上的示例進行操作
現在，當我嘗試連接時，輸出只是在有關連接池中 2 個 kafka 服務器的 WARN 訊息之間交替：
2021-11-10 11:44:29.609 WARN 11839 --- [| adminclient-1] org.apache.kafka.clients.NetworkClient : [AdminClient clientId=adminclient-1] Connection to node -2 (kafka1.mycompany.com/[some-ip-address]:9092) terminated during authentication. This may happen due to any of the following reasons: (1) Authentication failed due to invalid credentials with brokers older than 1.0.0, (2) Firewall blocking Kafka TLS traffic (eg it may only allow HTTPS traffic), (3) Transient network issue.
2021-11-10 11:44:29.798 WARN 11839 --- [| adminclient-1] org.apache.kafka.clients.NetworkClient : [AdminClient clientId=adminclient-1] Connection to node -1 (kafka2.mycompany.com/[some-ip-address]:9092) terminated during authentication. This may happen due to any of the following reasons: (1) Authentication failed due to invalid credentials with brokers older than 1.0.0, (2) Firewall blocking Kafka TLS traffic (eg it may only allow HTTPS traffic), (3) Transient network issue.
一開始它似乎輸出了一些關于 kafka 設定的資訊。也許那里有一些關于我在 application.properties 中可能需要哪些額外引數才能實際連接的資訊。
bootstrap.servers = [kafka1.mycompany.com:9092, kafka2.mycompany.com:9092]
client.dns.lookup = use_all_dns_ips
client.id =
connections.max.idle.ms = 300000
default.api.timeout.ms = 60000
metadata.max.age.ms = 300000
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
receive.buffer.bytes = 65536
reconnect.backoff.max.ms = 1000
reconnect.backoff.ms = 50
request.timeout.ms = 30000
retries = 2147483647
retry.backoff.ms = 100
sasl.client.callback.handler.class = null
sasl.jaas.config = null
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.login.callback.handler.class = null
sasl.login.class = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.mechanism = GSSAPI
security.protocol = SSL
security.providers = null
send.buffer.bytes = 131072
socket.connection.setup.timeout.max.ms = 127000
socket.connection.setup.timeout.ms = 10000
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLSv1.3
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
uj5u.com熱心網友回復：
您遵循的教程已經過時了。我建議查看官方檔案：https : //docs.spring.io/spring-kafka/reference/html/#spring-boot-producer-app。根據您的設定，配置可能只是一個引導服務器。
spring.kafka.bootstrap-servers=kafka.your-company.com:9092
我會問 Kafka ops 團隊如何連接，因為這可能會因 jaas 和 ssl 而變得復雜。
Spring Boot Kafka 配置設定可以在這里找到：https : //docs.spring.io/spring-boot/docs/current/reference/html/application-properties.html#application-properties.integration.spring.kafka.admin。客戶編號
uj5u.com熱心網友回復：
spring.kafka.bootstrap-servers 對消費者和生產者（和管理員客戶端）來說是相同的屬性，是的。
我是否需要使用 application.properties 檔案
SpringBoot 應用程式不需要它，不需要。
轉載請註明出處，本文鏈接：https://www.uj5u.com/shujuku/355791.html
上一篇：字串到日期格式，反之亦然