Neng Lu

@sleepy-brook Heron currently doesn't have native Kafka spout, but you can utilize the Kafka spout from Storm to compose your topology. https://github.com/apache/storm/tree/master/external/storm-kafka-client

> add spec.minReplicas to indicate the minimum number of replicas for the workloads > change spec.replicas to an optional field why not use `spec.replicas` as the default minReplicas? `spec.relicas` should...

Ref for Python implementation: https://github.com/apache/pulsar/pull/9588

The problem is fixed in this PR: https://github.com/streamnative/pulsar-spark/pull/62 And is released in: Release-3.1.1.4

Hi @gaozhangmin , could you fix the unit test

@Aaronzk This part of documentation is misleading and the code is quite discrete. I also met this problem recently, I think we need to either change the doc or update...

@imaffe Could you help release a stable 1.13 once the pipeline is finished.

@syhily Could you also take a look?

@jianyun8023 @syhily could you help take a look?

@asagjj Thanks for your contribution. Could you fix some failed workflow check.