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
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
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
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
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
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
.sh --create --topic --partitions
> --replication-factor --zookeeper
>
> I hope it helps!
>
>
> Regards!
> Cathy
> ------ 原始邮件 --
> 发件人: "Sachit Murarka";
> 发送时间: 2018年11月11日(星期天) 晚上10:48
> 收件人: "users";
>
> 主题:
Hello All,
I am new to kafka. Could anyone please tell how to decided number of
partitions for our topic?
Kind Regards,
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