Yeah, the direct api uses the simple consumer
On Fri, Aug 28, 2015 at 1:32 PM, Cassa L <lcas...@gmail.com> wrote:
> Hi I am using below Spark jars with Direct Stream API.
> spark-streaming-kafka_2.10
>
> When I look at its pom.xml, Kafka libraries that its pulling in is
> <groupId>org.apache.kafka</groupId>
> <artifactId>kafka_${scala.binary.version}</artifactId>
> <version>0.8.2.1</version>
>
>
> I believe this DirectStream API uses SimpleConsumer API. Can someone from
> Spark community confirm too?
>
> Thanks,
> LCassa.
>
> On Fri, Aug 28, 2015 at 11:12 AM, Sriharsha Chintalapani <ka...@harsha.io>
> wrote:
>
>> SSL is supported for new producer and consumer api and old api (simple
>> consumer and high-level consumer) is not supported.
>> I think spark uses simple consumer? if so its not supported.
>>
>> Thanks,
>> Harsha
>>
>>
>> On August 28, 2015 at 11:00:30 AM, Cassa L (lcas...@gmail.com) wrote:
>>
>> Hi,
>> I was going through SSL setup of Kafka.
>> https://cwiki.apache.org/confluence/display/KAFKA/Deploying+SSL+for+Kafka
>> However, I am also using Spark-Kafka streaming to read data from Kafka.
>> Is
>> there a way to activate SSL for spark streaming API or not possible at
>> all?
>>
>> Thanks,
>> LCassa
>>
>>
>
