Running a Demo Apache Flink Application With Apache NiFi and Apache Kafka on CDH 6.3
Tags: apacheflink, apachekafka, apachenifi19
Published: 2019-11-27 17:10:01

---
title: Running a Demo Apache Flink Application With Apache NiFi and Apache Kafka on CDH 6.3
published: true
date: 2019-11-05 18:55:00 UTC
tags: apache-flink,apache-kafka,apache-nifi-1.9
canonical_url: 
---

### Running a Demo Apache Flink Application With Apache NiFi and Apache Kafka on CDH 6.3

[![](https://1.bp.blogspot.com/-pL5kT-liGZk/XbsilQq0ErI/AAAAAAAAYvA/Z2pNl_7USp4mw7oNn_XGxG1KAJlHIz9wQCLcBGAsYHQ/s640/changedFlinkExampleCode.png)](https://1.bp.blogspot.com/-pL5kT-liGZk/XbsilQq0ErI/AAAAAAAAYvA/Z2pNl_7USp4mw7oNn_XGxG1KAJlHIz9wQCLcBGAsYHQ/s1600/changedFlinkExampleCode.png)
  

[![](https://1.bp.blogspot.com/-cu418cu0ML8/XbsirANlQcI/AAAAAAAAYvQ/f_YvZsAKWtg588CILRBP9irpWnJfKvIvgCLcBGAsYHQ/s640/flinkAppInYARN.png)](https://1.bp.blogspot.com/-cu418cu0ML8/XbsirANlQcI/AAAAAAAAYvQ/f_YvZsAKWtg588CILRBP9irpWnJfKvIvgCLcBGAsYHQ/s1600/flinkAppInYARN.png)
  

[![](https://1.bp.blogspot.com/--YA0hZai6w0/Xbsiqll3RjI/AAAAAAAAYvM/lOkjbV2ojTcmskDp_g2k4Ix2ZxkZWjYcgCLcBGAsYHQ/s640/FlinkJobRunning.png)](https://1.bp.blogspot.com/--YA0hZai6w0/Xbsiqll3RjI/AAAAAAAAYvM/lOkjbV2ojTcmskDp_g2k4Ix2ZxkZWjYcgCLcBGAsYHQ/s1600/FlinkJobRunning.png)
  

[![](https://1.bp.blogspot.com/-SMbd79untGg/XbsirS0UUoI/AAAAAAAAYvU/Tpv0CG-ZVp00wOA8ohW-0DfOgPr7dTOdwCLcBGAsYHQ/s640/flinkKafkaSMMDataExplorerKafka.png)](https://1.bp.blogspot.com/-SMbd79untGg/XbsirS0UUoI/AAAAAAAAYvU/Tpv0CG-ZVp00wOA8ohW-0DfOgPr7dTOdwCLcBGAsYHQ/s1600/flinkKafkaSMMDataExplorerKafka.png)
  

[![](https://1.bp.blogspot.com/-vkmU0rujRRE/Xbsiqjgn6rI/AAAAAAAAYvI/DejCsTGiyyM9gFSog1qe_OwjzxwXWabbwCLcBGAsYHQ/s640/FlinkKafkaTopicMetrics.png)](https://1.bp.blogspot.com/-vkmU0rujRRE/Xbsiqjgn6rI/AAAAAAAAYvI/DejCsTGiyyM9gFSog1qe_OwjzxwXWabbwCLcBGAsYHQ/s1600/FlinkKafkaTopicMetrics.png)
  

[![](https://1.bp.blogspot.com/-H7pd8WkrO7U/XbsirrN3nqI/AAAAAAAAYvY/olAMXrHCu9sOqDoWd0PxJrnO4Q3O8LUDQCLcBGAsYHQ/s640/flinkSMMKafkaMetrics.png)](https://1.bp.blogspot.com/-H7pd8WkrO7U/XbsirrN3nqI/AAAAAAAAYvY/olAMXrHCu9sOqDoWd0PxJrnO4Q3O8LUDQCLcBGAsYHQ/s1600/flinkSMMKafkaMetrics.png)
  

[![](https://1.bp.blogspot.com/-gCCfA_9XT3k/XbsiqgNwd0I/AAAAAAAAYvE/xkKzzO9vyPcPfvTYG5DgAUSXJ2NPjFVZQCLcBGAsYHQ/s640/NiFiConsumeKafkaFromFlink.png)](https://1.bp.blogspot.com/-gCCfA_9XT3k/XbsiqgNwd0I/AAAAAAAAYvE/xkKzzO9vyPcPfvTYG5DgAUSXJ2NPjFVZQCLcBGAsYHQ/s1600/NiFiConsumeKafkaFromFlink.png)
  

[![](https://1.bp.blogspot.com/-VCuvHPjzv04/Xbsir1iaB1I/AAAAAAAAYvc/wrGxK44X-MwJOefDwL4d_LfGigAGF0vygCLcBGAsYHQ/s640/nifiConsumeMessageFromFlink.png)](https://1.bp.blogspot.com/-VCuvHPjzv04/Xbsir1iaB1I/AAAAAAAAYvc/wrGxK44X-MwJOefDwL4d_LfGigAGF0vygCLcBGAsYHQ/s1600/nifiConsumeMessageFromFlink.png)
  

[![](https://1.bp.blogspot.com/-ByyfDNvnQpg/XbsisFbcuXI/AAAAAAAAYvk/l84Zt6Gfswoegj0BG4X1UW2DZhTffN3XQCLcBGAsYHQ/s640/runFlinkRecordsRunning.png)](https://1.bp.blogspot.com/-ByyfDNvnQpg/XbsisFbcuXI/AAAAAAAAYvk/l84Zt6Gfswoegj0BG4X1UW2DZhTffN3XQCLcBGAsYHQ/s1600/runFlinkRecordsRunning.png)
  

[![](https://1.bp.blogspot.com/-tq3oeS0dBrU/Xbsisl5kckI/AAAAAAAAYvg/_AVmycJP0CcNccjQLfDpEELuZkl5jUFIQCLcBGAsYHQ/s640/smmFilterByTopic.png)](https://1.bp.blogspot.com/-tq3oeS0dBrU/Xbsisl5kckI/AAAAAAAAYvg/_AVmycJP0CcNccjQLfDpEELuZkl5jUFIQCLcBGAsYHQ/s1600/smmFilterByTopic.png)
  

[![](https://1.bp.blogspot.com/-m3toiLGUSuM/XbsitG1GJHI/AAAAAAAAYvo/MjSQ85SOUC4FlsvDYEOjD_Ot85eXvwhFQCLcBGAsYHQ/s640/smmWikiTopic.png)](https://1.bp.blogspot.com/-m3toiLGUSuM/XbsitG1GJHI/AAAAAAAAYvo/MjSQ85SOUC4FlsvDYEOjD_Ot85eXvwhFQCLcBGAsYHQ/s1600/smmWikiTopic.png)
  

[![](https://1.bp.blogspot.com/-kDK8kEY7pyE/XbsitI4J6YI/AAAAAAAAYvs/dMwFdOH1a88jdB92yyqymMg930rRHVolQCLcBGAsYHQ/s640/yarnFlinkAppRunning.png)](https://1.bp.blogspot.com/-kDK8kEY7pyE/XbsitI4J6YI/AAAAAAAAYvs/dMwFdOH1a88jdB92yyqymMg930rRHVolQCLcBGAsYHQ/s1600/yarnFlinkAppRunning.png)
  
  
As a simple first Flink example program, I built the bonus exercise from QuickStart for Apache Flink + Apache Kafka.  
  
[https://ci.apache.org/projects/flink/flink-docs-release-1.9/getting-started/tutorials/datastream\_api.html](https://ci.apache.org/projects/flink/flink-docs-release-1.9/getting-started/tutorials/datastream_api.html)