Skip to content
#

kafka

Here are 5,073 public repositories matching this topic...

flink-learning

flink learning blog. http://www.flink-learning.com 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例,还有 Flink 落地应用的大型项目案例(PVUV、日志存储、百亿数据实时去重、监控告警)分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》

  • Updated Aug 11, 2020
  • Java
jonathanskrz
jonathanskrz commented Aug 24, 2020

Running : CLI v0.11.0, Server v0.11.0
(pulled from confluentinc/ksqldb-server:0.11.0)

Creating a stream with a field named "size" results in the following error :
extraneous input 'size' expecting {'EMIT'

It seems like size is considered a reserved keyword.
Creating the stream with CREATE STREAM trades ( "size" DOUBLE ) works.

Looks similar to https://github.com/confluentinc/ksql/issu

Surging is a micro-service engine that provides a lightweight, high-performance, modular RPC request pipeline. The service engine supports http, TCP, WS,Grpc, Mqtt, UDP, and DNS protocols. It uses ZooKeeper and Consul as a registry, and integrates it. Hash, random, polling, Fair Polling as a load balancing algorithm, built-in service governance to ensure reliable RPC communication, the engine contains Diagnostic, link tracking for protocol and middleware calls, and integration SkyWalking Distributed APM

  • Updated Aug 9, 2020
  • C#
watermill

Improve this page

Add a description, image, and links to the kafka topic page so that developers can more easily learn about it.

Curate this topic

Add this topic to your repo

To associate your repository with the kafka topic, visit your repo's landing page and select "manage topics."

Learn more

You can’t perform that action at this time.