Re: [EXTERNAL] SSL error while doing curl on kafka

2021-01-20 Thread Sachit Murarka
Hi Jose, I was trying to validate the output of CURLfor ssl enabled kafka as there was issue with Kafka SSL while consumption through spark streaming. The client keystore was corrupt. I regenerated the certs and keystores. It worked fine. Kind Regards, Sachit Murarka On Tue, Jan 19, 2021 at

SSL error while doing curl on kafka

2021-01-19 Thread Sachit Murarka
Hello All, I am doing curl o : of kafka. It is throwing below error post applying SSL. Can you please check? NSS error -8172 (SEC_ERROR_UNTRUSTED_ISSUER) * Peer's certificate issuer has been marked as not trusted by the user. Kind Regards, Sachit Murarka

Re: [EXTERNAL] Unable to connect to SSL enabled kafka

2021-01-18 Thread Sachit Murarka
Hello, Getting follow error: UTC|TransportContext.java:345|Fatal (UNKNOWN_CA): Received fatal alert: unknown_ca ( 2021-01-18_14:41:22.26584 "throwable" : { 2021-01-18_14:41:22.26584 javax.net.ssl.SSLHandshakeException: Received fatal alert: unknown_ca Kind Regards, Sachit Murark

Re: [EXTERNAL] Unable to connect to SSL enabled kafka

2021-01-18 Thread Sachit Murarka
Thanks @Jose Manuel Vega Monroy for reply. I think some issue is there with CN name. I am actually doing it in docker. Kind Regards, Sachit Murarka On Mon, Jan 18, 2021 at 6:11 PM Jose Manuel Vega Monroy < jose.mon...@williamhill.com> wrote: > @Sachit > > > > You can us

Re: [EXTERNAL] Unable to connect to SSL enabled kafka

2021-01-18 Thread Sachit Murarka
using the issue exactly. Kind Regards, Sachit Murarka On Mon, Jan 18, 2021 at 5:49 PM Jose Manuel Vega Monroy < jose.mon...@williamhill.com> wrote: > @Sachit > > Review your SSL client config. > > Cheers, > > <http://www.williamhill.com/> > <http://www.when

Unable to connect to SSL enabled kafka

2021-01-18 Thread Sachit Murarka
org.apache.spark.sql.execution.streaming.MicroBatchExecution.runActivatedStream(MicroBatchExecution.scala:185) at org.apache.spark.sql.execution.streaming.StreamExecution.org $apache$spark$sql$execution$streaming$StreamExecution$$runStream(StreamExecution.sca la:334) Kind Regards, Sachit

Re: Deciding number of partitions

2018-11-11 Thread Sachit Murarka
.sh --create --topic --partitions > --replication-factor --zookeeper > > I hope it helps! > > > Regards! > Cathy > ------ 原始邮件 -- > 发件人: "Sachit Murarka"; > 发送时间: 2018年11月11日(星期天) 晚上10:48 > 收件人: "users"; > > 主题:

Deciding number of partitions

2018-11-11 Thread Sachit Murarka
Hello All, I am new to kafka. Could anyone please tell how to decided number of partitions for our topic? Kind Regards, Sachit Murarka

Get count of messages

2018-10-29 Thread Sachit Murarka
Hi All, Could you please help me in getting count of all messages stored in kafka from a particular offset? I have tried GetOffsetShell command, it is not giving me. Kind Regards, Sachit Murarka