3

我正在尝试连接到消息中心服务。如果我使用 REST API，我可以连接，但是当我尝试从我的 Java 程序连接时，总是会超时

我正在使用下一个配置：

Properties producerProps = new Properties();
producerProps.put(SslConfigs.SSL_PROTOCOL_CONFIG, "TLSv1.2");
producerProps.put(SslConfigs.SSL_ENABLED_PROTOCOLS_CONFIG, "TLSv1.2");
producerProps.put(SslConfigs.SSL_TRUSTSTORE_LOCATION_CONFIG, "/Library/Java/JavaVirtualMachines/jdk1.8.0_66.jdk/Contents/Home/jre/lib/security/cacerts");
producerProps.put(SslConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG, "changeit");
producerProps.put(SslConfigs.SSL_TRUSTSTORE_TYPE_CONFIG, "JKS");
producerProps.put(SslConfigs.SSL_ENDPOINT_IDENTIFICATION_ALGORITHM_CONFIG, "HTTPS");
producerProps.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, "SSL");

producerProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, org.apache.kafka.common.serialization.ByteArraySerializer.class);
producerProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, org.apache.kafka.common.serialization.ByteArraySerializer.class);
producerProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "kafka01-prod01.messagehub.services.us-south.bluemix.net:9093,kafka02-prod01.messagehub.services.us-south.bluemix.net:9093,kafka03-prod01.messagehub.services.us-south.bluemix.net:9093,kafka04-prod01.messagehub.services.us-south.bluemix.net:9093,kafka05-prod01.messagehub.services.us-south.bluemix.net:9093");
producerProps.put(ProducerConfig.CLIENT_ID_CONFIG, "myApiKey");

KafkaProducer<byte[], byte[]> kafkaProducer = new KafkaProducer<>(producerProps);
ProducerRecord<byte[], byte[]> producerRecord = new ProducerRecord<>("myTopic", "records".getBytes(), "[{ \"value\" : \"test\" }]".getBytes());

RecordMetadata metadata = kafkaProducer.send(producerRecord).get();
System.out.println("Offset: " + metadata.offset());
kafkaProducer.close();

过了一会儿，错误是

Exception in thread "main" java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 231 ms.
at org.apache.kafka.clients.producer.KafkaProducer$FutureFailure.<init>(KafkaProducer.java:706)
at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:453)
at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:339)

我正在使用 kafka-clients 版本 0.9.0.0

有什么想法吗？

4

3 回答 3

4

您看到的异常通常是主题在使用前未创建的症状。Message Hub 不允许自动创建主题 - 它们必须通过 Bluemix Dashboard 或通过管理 REST 界面以编程方式创建。当您收到此错误时，您是否先创建了主题？

如果您还没有找到它们 - 这是我们示例的链接，包括创建主题然后使用 Kafka Java 客户端生成/使用消息的 Java 示例。 https://github.com/ibm-messaging/message-hub-samples

于 2015-12-04T09:32:04.097 回答
1

好消息。现在一切正常。自从我上次使用它以来，这个话题就消失了

我向 REST API 发出了一个 POST 请求，以确保创建了主题，而不是收到 422，而是收到了 202，因此没有创建主题。现在一切都像魅力一样

感谢大家

于 2015-12-04T11:38:09.727 回答
0

关于 UI 卡在“Waiting for data...”上的问题，我们已经意识到这个问题并正在努力解决它。干杯

于 2015-12-04T10:20:15.337 回答