Question: If a kakfa topic has more than one partition , in java , those many consumer instances/threads would be instantiated at consumer side.

How it could be handled in spark-streaming consumer side ? I dont find much information regarding the same. Any sample for the same i.e. invoking multiple consumers at spark-streaming-consumer of a topic.

Any design suggestion/examples around would be highly thankful.

Regards,
Shyam

Answer: 
if you are using calligraphy so you should migrate to calligraphy3 :
<https://github.com/InflationX/Calligraphy>

```
implementation 'io.github.inflationx:calligraphy3:3.1.1'
implementation 'io.github.inflationx:viewpump:2.0.3'

```
Migrate from [chrisjenx/Calligraphy](https://github.com/chrisjenx/Calligraphy)
to [InflationX/Calligraphy](https://github.com/InflationX/Calligraphy)
and update `Calligraphy` to newest version