![]() |
1
2
让我们一步一步地进行: 第一 ,当然只有一个名为“partitions”的参数
接口“Collection”后跟一个类型(TopicPartitions),这意味着您可以向该方法输入TopicPartition对象的任何集合。E、 g.:
语法
这里您称之为关键字(“partitions”)的是 根本没有关键字 ,但只是 名称/标识符 输入参数。必须为每个参数指定一个目标名称,以便在方法代码中识别它。 在本例中,您可以将“partitions”重命名为任何您想要的名称,我可以保证类似“partCollection”的名称 void、return、public、private、static、class、, 。。。这些是关键词。
第二
,TopicPartition,此处引用的方法是TopicPartition类的构造函数,它需要2个参数:
构造函数是在实例化类时调用的方法(创建对象,例如使用
因此,给您一个更详细的示例:
|
![]() |
yershalom · 同一消费群体中具有不同分区数量的不同卡夫卡主题 2 年前 |
![]() |
Sravan Kumar · Apache kafka模式注册表问题 2 年前 |
![]() |
MrSham · 如何确保旧版本0.10.0在卡夫卡中只处理一次 2 年前 |
![]() |
Iheb Mar · 卡夫卡制作人/消费者粉碎每一秒的API调用 2 年前 |
![]() |
Raman · Kafka流:POJO序列化/反序列化 6 年前 |