KSQL에서 토픽을 삭제할 수있는 방법이 있습니까? github에 따르면 가능하며 시도했습니다. DROP TOPIC my-topic
DROP TOPIC "my-topic"
DROP TOPIC 'my-topic'
DROP TOPIC `my-topic`
그러나이 명령은 작동하지 않습니다. 나는 메시지를 받는다 Message
--------------
KTABLE의 모든 현재 항목을 쿼리하는 방법이 있습니까? 페이로드로 REST API에 대한 http 요청을 실행하려고합니다. {
"ksql": "SELECT * FROM MY_KTABLE;",
"streamsProperties": {
"auto.offset.reset": "earliest"
}
}
이며 스트림이
카프카 주제는 A입니다. 주제 의 데이터 형식은 다음과 같습니다이 { id : 1, name:stackoverflow, created_at:2017-09-28 22:30:00.000}
{ id : 2, name:confluent, created_at:2017-09-28 22:00:00.000}
{ id : 3, name:kafka, created_at:
유스 케이스 달성을 위해 카프카 스트림을 사용하려고합니다. MySQL에는 사용자 및 계정이라는 두 개의 테이블이 있습니다. 그리고 MySQL에서 Kafka MySQL 커넥터를 사용하여 Kafka로 이벤트를 가져 왔습니다. 카프카 자체에서 계정 내의 모든 사용자 ID를 가져와야합니다. 그래서 MySQL 출력 항목에 KStream을 사용하여 출력을 구성하고이를
어쩌면 이것은 초보자 용 질문 일 수도 있지만 KSQL에서 생성 된 데이터를 읽는 데 권장되는 방법은 무엇입니까? 일부 스트림 처리를 수행하고 데이터를 KSQL 테이블에 기록한다고 가정 해 보겠습니다. 이제 스프링 애플리케이션을 통해이 데이터에 액세스하려고합니다 (예 : 웹 소켓을 통해 일부 실시간 데이터 팬 아웃). 내 첫 번째 추측은 Spring Kaf
GROUP BY을 통해 특정 열의 항목을 계산하는 대신 KSQL을 사용하는 대신 응용 프로그램을 통해 스트리밍되는 모든 항목에 대한 집계를 얻을 수 있습니까? 이 같은 뭔가를 찾고 있어요 : | Count all | Count id1 | count id2 |
| ---245----|----150----|----95-----|
이상 KSQL이 같은 :