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: 
Update `Calligraphy` to newest version to solve this problem:
Link: <https://github.com/InflationX/Calligraphy/issues/35>

More specifically, both Calligraphy **and** ViewPump need to be updated:

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

```

Migrating from Calligraphy 2 to 3 requires some code changes; see examples in [Calligraphy 3 README](https://github.com/InflationX/Calligraphy).
You can change buildTools version and sdk version from 29 to 28

```
    targetSdk = 28
    compileSdk = 28
    buildTools = '28.0.3'

```