Да вот и не пойму,  че надо ему. Мало данных в лог при этом пишет. Запущу в контейнере пожалуй ))

Самое простое)))

Нашёл в доке, https://docs.ksqldb.io/en/latest/developer-guide/ksqldb-reference/quick-reference/#emit-final  но оно не работает, говорит что не существует такого, хотя версия последняя. Плюс в  доке по push queries такого нет.. https://docs.ksqldb.io/en/latest/developer-guide/ksqldb-reference/select-push-query/#emit мистика какая-то. Кажется это у них готово но не релизнули пока или только в энтерпрайз версии есть

Нет, в CP Enterprise попадает более младшая версия. ksqlDB вся годнотка идёт сразу в oss

А у них есть какое-то официальное сообщество где можно спросить?

Slack же

Спасибо

Поддерживаю - возьми контейнер. Трахаться ещё с этими самописными systemd скриптами

Умеет, могу скинуть свой, там вроде бы все как обычно, без подводных камней

Так я тут пошуршал. Походу рано доку выкатили.

Klip-10 всё ещё в работе https://github.com/confluentinc/ksql/blob/master/design-proposals/klip-10-suppress.md

Да. Черкни плиз. @gamussa согласен, но спортивный интерес заставляет понять,  что я делаю не так )

Можно. Запускал.

в доке cmak прямо указано, что можно собрать rpm

sbt rpm:packageBin

и если потом его заинсталить, то systemd из пакета будет такой

[Unit]
Description=A tool for managing Apache Kafka
Requires=network.target

[Service]
Type=simple
WorkingDirectory=/usr/share/cmak
EnvironmentFile=/etc/default/cmak
ExecStart=/usr/share/cmak/bin/cmak
ExecReload=/bin/kill -HUP $MAINPID
Restart=always
RestartSec=60
SuccessExitStatus=
TimeoutStopSec=5
User=root
ExecStartPre=/bin/mkdir -p /run/cmak
ExecStartPre=/bin/chown root:root /run/cmak
ExecStartPre=/bin/chmod 755 /run/cmak
PermissionsStartOnly=true
LimitNOFILE=1024

[Install]
WantedBy=multi-user.target

но я бы рекомендовал собрать rpm

И до того как он стал cmak, я запускал как-то так

[Unit]
Description=Kafka Manager
Documentation=https://github.com/yahoo/kafka-manager
Requires=network.target
After=network.target

[Service]
Type=simple
User=root
Group=root
WorkingDirectory=/opt/kafka-manager/kafka-manager-2.0.0.2
ExecStart=/opt/kafka-manager/kafka-manager-2.0.0.2/bin/kafka-manager
Restart=on-failure

[Install]
WantedBy=multi-user.target

Собственно неделю назад поднимал, кроме kafka-manager.service. добавлял еще в директорию conf файл application.ini:

-Dapplication.home=/var/lib/kafka-manager
-Dconfig.file=/var/lib/kafka-manager/conf/application.conf
-Dpidfile.path=/var/lib/kafka-manager/kafka-manager.pid
-Dapplication.log.dir=/var/log/kafka-manager
-Dhttp.port=9000

ну и сам сервис:

[Unit]
Description=Kafka Manager
Documentation=https://github.com/yahoo/kafka-manager
Requires=network.target
After=network.target

[Service]
Type=simple
User=kafka
Group=kafka
WorkingDirectory=/var/lib/kafka-manager
ExecStart=/var/lib/kafka-manager/bin/cmak
StandardOutput=null
Restart=on-failure

[Install]
WantedBy=multi-user.target

Все успешно запускается. Версия - cmak-3.0.0.5

Приветствую!
Работаю с avro. Пытаюсь понять как сериализовать поле у которого тип UNION внутри которого разные объекты (рекорды).
Например, когда у меня простой Record я делаю что-то типа

Schema.Parser parser = new Schema.Parser();
Schema schema = parser.parse(userSchema);
GenericRecord avroRecord = new GenericData.Record(schema);
avroRecord.put("f1", "value1");

а вот как сериализовать UNION схему с рекордами я не понимаю.
Нужно сериализовать, например, такую схему:

    {
      "name": "op",
      "type": [
        {
          "name": "insert_record",
          "type": "record",
          "fields": [
            {
              "name": "insert",
              "type": "boolean"
            }
          ]
        },
        {
          "name": "delete_record",
          "type": "record",
          "fields": [
            {
              "name": "delete",
              "type": "boolean"
            }
          ]
        }
      ]
    }

там теперь FINAL

Я в слак им написал, сказали мол не готово еще и исправили доку

@anton_churkin @SnAnykey Спасибо, через rpm все взлетело. Пропустил чет эту строчку в мане

да реально убрали, хах... Это одна из двух самых необходимый(для удобства чтобы не городишь своих лишних звеньев) фич  для построения хайлоуд архитектур 😉