Output the aggregate result to TiDB

[Ishiihara]

This is a POC to result to TiDB.

Here are the steps to run the example:

1. Follow the instructions in tiup.io to deploy a TiDB cluster.
2. Connect to TiDB
   $mysql --host 127.0.0.1 --port 4000 -u root
3. Create a table under the test database:
   mysql>USE test;
mysql>CREATE TABLE wordcount (word VARCHAR(255) NOT NULL, wordcount BIGINT, PRIMARY KEY (word));
4. Download Kafka, unzip it and in the Kafka directory, start Zookeeper and Kafka
   $bin/zookeeper-server-start.sh config/zookeeper.properties
$bin/kafka-server-start.sh config/server.properties
5. in the Kafka directory, create topics:
   $bin/kafka-topics.sh--create --topic streams-plaintext-input --zookeeper localhost:2181 --partitions 1 --replication-factor 1
$bin/kafka-topics --create --topic streams-wordcount-output --zookeeper localhost:2181 --partitions 1 --replication-factor 1
6. In the kafka-streams-examples directory, build and package the application
   $ mvn -DskipTests=true clean package
7. In the kafka-streams-examples directory, run the application
   $java -cp target/kafka-streams-examples-5.4.1-standalone.jar \ io.confluent.examples.streams.WordCountLambdaExample
8. In the Kafka directory, use the console producer to produce to the input topic
   $bin/kafka-topics.sh --create --topic streams-plaintext-input \ --zookeeper localhost:2181 --partitions 1 --replication-factor 1
9. Inspect the result
   mysql> SELECT * from wordcount;

[ghost]

It looks like @Ishiihara hasn't signed our Contributor License Agreement, yet.

The purpose of a CLA is to ensure that the guardian of a project's outputs has the necessary ownership or grants of rights over all contributions to allow them to distribute under the chosen licence.
Wikipedia

You can read and sign our full Contributor License Agreement here.

Once you've signed reply with [clabot:check] to prove it.

Appreciation of efforts,

clabot

[abbccdda]

Thanks for the PR. But I don't think this has anything to do with TiDB? Any MySQL client could run with it?

[OneCricketeer]

Agreed. It'd be best to use Kafka Connect JDBC sink for such a use case