Release 92.2: Quotas, Transactional Producers, and KRaft

Toggle dark mode

Release Info

Kpow can be found on Dockerhub

docker pull factorhouse/kpow-ee:92.2

View our Docker quick start guide for help getting started.

Kpow can be found on ArtifactHub

Helm version: 1.0.52

helm repo add kpow https://charts.kpow.io
helm repo update
helm install --namespace factorhouse --create-namespace my-kpow kpow/kpow --version 1.0.52 \
--set env.LICENSE_ID="00000000-0000-0000-0000-000000000001" \
--set env.LICENSE_CODE="KPOW_CREDIT" \
--set env.LICENSEE="Your Corp\, Inc." \
--set env.LICENSE_EXPIRY="2024-01-01" \
--set env.LICENSE_SIGNATURE="638......A51" \
--set env.BOOTSTRAP="127.0.0.1:9092\,127.0.0.1:9093\,127.0.0.1:9094" \
--set env.SECURITY_PROTOCOL="SASL_PLAINTEXT" \
--set env.SASL_MECHANISM="PLAIN" \
--set env.SASL_JAAS_CONFIG="org.apache.kafka.common.security.plain.PlainLoginModule required username=\"user\" password=\"secret\";"
--set env.LICENSE_CREDITS="7"

View our Helm instructions for help getting started.

Kpow can be found on the AWS Marketplace

View our AWS Marketplace documentation for help getting started.

Kpow can be downloaded and installed as a Java JAR file. This JAR is compatible with Java versions 11+.

Download Kpow Java JAR

View our JAR quick start guide for help getting started.

Kpow can be downloaded and installed as a Java JAR file. This JAR is compatible with Java 8.

Download Kpow Java 8 JAR

View our JAR quick start guide for help getting started.

Download VPAT
Factor House publish a VPAT (Voluntary Product Accessibility Template) for each release.

For more information, read the Kpow accessibility documentation.

Release v92.2 introduces new UI for Kafka Quotas, Transactional Producers, and KRaft clusters along with new features for topic and consumer management, and improvements to Flink checkpointing and watermarking in Flex.

This is the first multi-product release by Factor House, you will notice that our Changelog now provides entries for Kpow, Flex, and 'All Products'.

Quota Management

Kpow's new Quota UI allows you to view, edit, create, and delete Kafka Quotas.

Mutation of quotas is controlled by a new QUOTA_EDIT RBAC permission.

See our quota documentation for more information.

Kpow Quota UI

Transactional Producer Management

Kpow provides a complete management interface to Kafka Producers. This allows a user to fence a producer or abort any (possibly hanging) transactions.

Mutation of producers is controlled by a new PRODUCER_EDIT RBAC permission.

See our producer documentation for more information.

Kpow Producer UI

KRaft Management

Kpow's new KRaft UI allows you to view KRaft information and unregister brokers.

Unregistering of brokers is controlled by a new BROKER_UNREGISTER RBAC permission.

See our broker documentation for more information.

Kpow Kraft UI

Topic Leader Election and Alter Replicas

Release v92.2 introduces support for topic leader election and topic alter replicas.

Topic leader election is controlled by a new TOPIC_ELECT_LEADER RBAC permission, TOPIC_ALTER_REPLICAS controls access to the topic alter replicas function.

See our topic replica documentation for more information.

Kpow Topic Leader Election UI

Consumer Group Management

If you have a static consumer group (a consumer group with group.instance.id set) you can use Kpow to remove a member from the group.

This is can be useful as static consumer groups do not send a leave group request when they go offline, and instead rely on session.timeout to trigger a group rebalance.

See our consumer group member documentation for more information.

Topic Client Monitoring

With the introduction of transactional producer management, Kpow now presents more information about topics under a new 'Clients' tab.

This new Client monitoring allows you to view all transactional producer and consumer groups that are connected to a single topic or topics.

Kpow Topic Client UI

Optional RBAC_EVALUATION_STRATEGY

Kpow now allows you to define an RBAC_EVALUATION_STRATEGY environment variable to allow more lenient evaluation of STAGE permissions.

Kpow is naturally conservative in deciding when a user can take an action on resource. By default this extends to setting a users access to STAGE where the user has both STAGE and ALLOW permission defined to a specific resource.

When RBAC_EVALUATION_STRATEGY=STAGE_LENIENT is set a user will set a users access to ALLOW where the user has both permissions defined.

In every case if a user has DENY or no permission set then they are denied access to the action.

Release v92.2 Changelog

See the Factor House Product Roadmap to understand current delivery priorities.

Kpow v92.2 Changelog

See the full Kpow Changelog for information on previous releases

  • Introduce new Quota UI, actions, RBAC, and Tenancy controls
  • Introduce new KRaft UI, actions, RBAC and Tenancy controls
  • Introduce new Transactional Producer UI, actions, RBAC and Tenancy controls
  • Introduce action to allow topic leader election
  • Introduce action to allow topic alter replicas
  • Introduce action to allow removing a member from a consumer group
  • Improve AWS LM integration to be more lenient with rolling restarts
  • Improve Kpow functionality when PERSISTENCE_MODE=none
  • Fix broker topics column name error, 'Replicas' becomes 'Partitions'
  • Fix ACL table column preferences
Flex v92.2 Changelog

See the full Flex Changelog for information on previous releases

  • Improve responsiveness of checkpoint/savepoint mutations
  • Improve timestamp formatting of watermarks and backpressure
All Products v92.2 Changelog
  • Introduce RBAC_EVALUATION_MODE for permissive STAGE/DENY evaluation
  • Improve error message of concurrent bulk-action error
  • Improve table action menu, group item as 'Mutations' or 'Explore'
  • Fix regression in table preferences persistence
Release 94.6: Factor Platform, Ververica Integration, and kJQ Enhancements

The first Factor Platform release candidate is here, a major milestone toward a unified control plane for real-time data streaming technologies. This release also introduces Ververica Platform integration in Flex, plus support for Kafka Clients 4.1 / Confluent 8.0.0 and new kJQ operators for richer stream inspection.

Release 94.5: New Factor House docs, enhanced data inspection and URP & KRaft improvements

This release introduces a new unified documentation hub - Factor House Docs. It also introduces major data inspection enhancements, including comma-separated kJQ Projection expressions, in-browser search, and over 15 new kJQ transforms and functions. Further improvements include more reliable cluster monitoring with improved Under-Replicated Partition (URP) detection, support for KRaft improvements, the flexibility to configure custom serializers per-cluster, and a resolution for a key consumer group offset reset issue.

Release 94.4: Auto SerDes improvements

This minor hotfix release from Factor House resolves a bug when using Auto SerDes without Data policies, and adds support for UTF-8 String Auto SerDes inference.

Start your streaming transformation today.

 Try both Kpow or Flex free for 30 days with a single license - no credit card required.