def generate_ca(self):
        """
        Generate CA private key and certificate.
        """

        self.runcmd("keytool -genkeypair -alias ca -keyalg RSA -keysize 2048 -keystore %s -storetype JKS -storepass %s -keypass %s -dname CN=SystemTestCA -startdate %s --ext bc=ca:true" % (self.ca_jks_path, self.ca_passwd, self.ca_passwd, self.startdate))
        self.runcmd("keytool -export -alias ca -keystore %s -storepass %s -storetype JKS -rfc -file %s" % (self.ca_jks_path, self.ca_passwd, self.ca_crt_path))

    def generate_truststore(self):
        """
        Generate JKS truststore containing CA certificate.
        """

        self.runcmd("keytool -importcert -alias ca -file %s -keystore %s -storepass %s -storetype JKS -noprompt" % (self.ca_crt_path, self.truststore_path, self.truststore_passwd))

[2020-09-24 07:05:48,161] WARN [ReplicaFetcher replicaId=1, leaderId=5, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=1, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={<topic-name1>-46=(fetchOffset=2710954135, logStartOffset=2710752957, maxBytes=1048576, currentLeaderEpoch=Optional[14]), __consumer_offsets-39=(fetchOffset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[16]), <topic-name2>-0=(fetchOffset=12261749, logStartOffset=10724067, maxBytes=1048576, currentLeaderEpoch=Optional[15]), <topic-name>-6=(fetchOffset=2710929727, logStartOffset=2710706952, maxBytes=1048576, currentLeaderEpoch=Optional[14]), __consumer_offsets-19=(fetchOffset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[15]), <topic-name1>-26=(fetchOffset=2710936619, logStartOffset=2710740353, maxBytes=1048576, currentLeaderEpoch=Optional[14])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=1359199963, epoch=INITIAL), rackId=) (kafka.server.ReplicaFetcherThread)
java.net.SocketTimeoutException: Failed to connect within 30000 ms
    at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:103)
    at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:197)
    at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:286)
    at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:133)
    at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:132)
    at scala.Option.foreach(Option.scala:274)
    at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:132)
    at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:114)
    at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:89)