我有一个Kafka集群运行在合流云上,但我无法从UI中重置提交偏移量。因此,我试图通过Kafka的CLI来做这件事,如下所示:
kafka-consumer-groups --bootstrap-server=my_cluster.confluent.cloud:9092 --list
但是,我遇到了下面的错误。我认为这与我如何认证有关。
Error: Executing consumer group command failed due to org.apache.kafka.common.KafkaException: Failed to find brokers to send List
当我在kafka中执行以下命令时
./kafka-consumer-groups.sh --bootstrap-server sample-address:9092 --list
我面临着下面的错误
Error: Executing consumer group command failed due to org.apache.kafka.common.KafkaException: Failed to find brokers to send ListGroups
java.util.concurrent.ExecutionException: org.apache.kafka.common
我尝试在Scala中使用KafkaAdminClient.create,如下所示: import java.util.Properties
import org.apache.kafka.clients.admin.KafkaAdminClient
final class DetectorActor extends TemplateActor {
val props = new Properties
props.put("bootstrap.servers", "localhost:9092")
props.put("connect
我试图模仿这个创建kafka主题并等待未来对象完成的方法。无法模拟下面一行:
createResult.values().get(topic).get();
测试用例在上面的行以NullPointerException结束。
@Test
public void testCreateKafkaTopic(){
MyClass myClass = new MyClass();
PowerMockito.mockStatic(AdminClient.class);
final KafkaAdminClient
我用下面的方法在Kafka中创建主题,
public class KafkaTopicAdmin {
public void createTopic(final String topicName) {
final AdminClient client = getKafkaClient();
final List<NewTopic> topics = Collections.synchronizedList(new ArrayList<>());
final NewTopic newTopic = new NewT
这是在运行命令: bin/schema-registry-start etc/schema-registry/schema-registry.properties时遇到的错误。
[2019-08-14 18:44:30,596] INFO Logging initialized @2427ms to org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log:193)
[2019-08-14 18:44:32,759] INFO Initializing KafkaStore with broker endpoints: SS