-
kafka相关集成+添加到source;注意start from earliest
查看全部 -
kafka常见命令
查看全部 -
nohup相关
查看全部 -
启动zookeeper
查看全部 -
最后结果做一些包装
查看全部 -
register一些东西
查看全部 -
flink sql 课程大纲
查看全部 -
Kafka常用命令
启动zookeepernohup bin/zookeeper-server-start.sh config/zookeeper.properties.&
启动servernohup bin/kafka-server-start.sh sonfig/server.properties&
查看topicbin/kafka-topics.sh-list--zookeeper localhost2181
创建个topic bin/kafka-topics.sh--create--zookeeper localhost2181--replication-factor 1--partitions 1-topic查看全部 -
Kafka执行步骤及相关命令:
查看全部 -
课程大纲:
查看全部 -
kafka常用命令
查看全部 -
udf内容 自定义函数
查看全部 -
flink table 与sql的算子操作
查看全部 -
Flink 1.7.2 开始支持支持 scala2.12,而之前只能支持到 2.11
查看全部 -
Kafka常用命令
启动zookeepernohup bin/zookeeper-server-start.sh config/zookeeper.properties.&
启动servernohup bin/kafka-server-start.sh sonfig/server.properties&
查看topicbin/kafka-topics.sh-list--zookeeper localhost2181
创建个topic bin/kafka-topics.sh--create--zookeeper localhost2181--replication-factor 1--partitions 1-topic
test
发送数据bin/kafka-console-producer.sh--broker-list localhost9092--topic test
消费数据bin/kafka-console-consumer.sh--bootstrap-server locallost:9092-topic test-from-beginning查看全部
举报