dhanuka84

Kafka Topics

List existing topics

bin/kafka-topics.sh --zookeeper localhost:2181 --list

Describe a topic

bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic mytopic

Purge a topic

bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic mytopic --config retention.ms=1000

... wait a minute ...

dhanuka84

package com.datastax.spark.demo;

import com.datastax.driver.core.Session;
import com.datastax.spark.connector.cql.CassandraConnector;
import com.google.common.base.Optional;
import org.apache.spark.SparkConf;
import org.apache.spark.api.java.JavaPairRDD;
import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.JavaSparkContext;
import org.apache.spark.api.java.function.FlatMapFunction;

dhanuka84

package com.keepithttps.hibernate.type;

import java.io.IOException;
import java.io.Serializable;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Types;
import java.util.Properties;

dhanuka84

ALTER USER WSO2CARBON_DB QUOTA 100M ON wso2;
GRANT UNLIMITED TABLESPACE TO WSO2CARBON_DB;

ALTER USER WSO2AM_DB QUOTA 100M ON wso2;
GRANT UNLIMITED TABLESPACE TO WSO2AM_DB;

ALTER USER WSO2AM_STAT QUOTA 100M ON wso2;
GRANT UNLIMITED TABLESPACE TO WSO2AM_STAT;

ALTER USER WSO2MB_DB QUOTA 100M ON wso2;