使用Apache Kafka 0.10.0 API和Java创建Kafka经纪人集群 - java

我想使用Kafka 0.10 APIJava来创建代理群集。据我所读kafka_2.11-0.10.0.0.jar是否支持使用创建代理:

import kafka.cluster.Broker;
import kafka.cluster.Cluster; 

但是我找不到这样做的任何文档。我最近读了[1],它讲述了如何在Kafka API中使用Java创建主题。我们是否可以做类似的事情来创建代理群集,更新分区,将现有数据/分区迁移到新代理(因为这些新代理不会自动被分配任何数据分区,所以除非将分区移至它们,否则它们将不会做任何工作[2])

[1] How Can we create a topic in Kafka from the IDE using API

[2] https://kafka.apache.org/0100/ops.html#basic_ops_cluster_expansion

参考方案

我有一些示例代码,您可能会觉得有用。

要创建代理,请查看KafkaTestServer。这实际上是为了进行更简单的测试,因此它不会创建集群,而只是单个代理,但是扩展起来应该并不困难。

一旦我在测试服务器中内置了创建/查询/删除主题的功能,便创建了一个独立的管理客户端,可以对其他服务器执行相同的操作,因此,如果您已经在创建代理集群,则应该能够使用代码保持话题。看看KafkaAdminClient。

admin客户端基本上是围绕scala kafka.admin.AdminUtils类的纯Java包装程序,因此它可以处理所有scala Java转换。

java:继承 - java

有哪些替代继承的方法? java大神给出的解决方案 有效的Java:偏重于继承而不是继承。 (这实际上也来自“四人帮”)。他提出的理由是,如果扩展类未明确设计为继承,则继承会引起很多不正常的副作用。例如,对super.someMethod()的任何调用都可以引导您通过未知代码的意外路径。取而代之的是,持有对本来应该扩展的类的引用,然后委托给它。这是与Eric…

Java-如何将此字符串转换为日期? - java

我从服务器收到此消息,我不明白T和Z的含义,2012-08-24T09:59:59Z将此字符串转换为Date对象的正确SimpleDateFormat模式是什么? java大神给出的解决方案 这是ISO 8601标准。您可以使用SimpleDateFormat simpleFormat = new SimpleDateFormat("yyyy-MM…

JAVA 8具有任何匹配属性的对象的过滤器列表 - java

我的要求是通过匹配任何属性的字符串来过滤对象列表。例如,假设Contact类具有三个属性:街道,城市,电话。我知道java流过滤器是如何工作的,在这里我必须将输入字符串与每个属性进行比较,如下所示:contactList.stream().filter(contact -> contact.getStreet().equals("dubai&…

Java-固定大小的列表与指定初始容量的列表之间的差异 - java

我在理解这一点上遇到了问题。当我们做 List<Integer> list = Arrays.asList(array); 我们不能在该列表上使用添加,删除之类的方法。我知道Arrays.asList()返回固定大小的列表。我不明白的是,如果我们创建一个具有指定初始容量的列表,例如List<Integer> list2 = new A…

从方法返回数组-Java - java

private static Coordinate[] getCircleCoordintaes() { Coordinate coordinates[] = {new Coordinate(0, 0)}; return coordinates; } 以上程序工作正常。在上面的程序中,返回的坐标数组首先初始化了数组使用这条线Coordinate coordi…