Comments (5)
Thanks for opening this issue, @solarmosaic-kflorence. I'll add support for this and associated documentation. :-)
from kafka-shell.
I've added support for command_file_extension
on a per-cluster basis in PR #19.
This has been released in 0.1.3
. Documentation can be found here. I've left the default of kafka-shell to be null
, for backwards-compatibility reasons.
Let me know if this helps or if you have any other questions! 😄
from kafka-shell.
Great, I will try that out tomorrow @devshawn.
from kafka-shell.
It works, thanks!
Note for future users that in my use-case (kafka deployed to local Kubernetes via docker stack deploy
), I must also update my config to reference the internal (to docker) addresses, like so:
version: 1
enable:
history: true
save_on_exit: true
auto_complete: true
auto_suggest: true
inline_help: true
fuzzy_search: true
cluster: local
clusters:
local:
bootstrap_servers: kafka1:19092
zookeeper_connect: zookeeper1:2181
ksql_server_url: http://ksql-server:8088
command_file_extension: sh
command_prefix: kubectl exec svc/kafka1 --
And here is the corresponding docker stack configuration file (kafka-stack.yaml
):
version: '3.3'
services:
# https://hub.docker.com/r/bitnami/zookeeper
zookeeper1:
image: bitnami/zookeeper:3.4.13
hostname: zookeeper1
ports:
- "2181:2181"
environment:
ALLOW_ANONYMOUS_LOGIN: "yes"
volumes:
- zookeeper1-data:/bitnami/zookeeper
# https://hub.docker.com/r/bitnami/kafka
kafka1:
image: bitnami/kafka:2.2.1
hostname: kafka1
ports:
- "9092:9092"
environment:
ALLOW_ANONYMOUS_LOGIN: "yes"
ALLOW_PLAINTEXT_LISTENER: "yes"
KAFKA_CFG_ADVERTISED_LISTENERS: INTERNAL://kafka1:19092,EXTERNAL://${DOCKER_HOST_IP:-127.0.0.1}:9092
KAFKA_CFG_INTER_BROKER_LISTENER_NAME: INTERNAL
KAFKA_CFG_LISTENERS: INTERNAL://0.0.0.0:19092,EXTERNAL://0.0.0.0:9092
KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP: INTERNAL:PLAINTEXT,EXTERNAL:PLAINTEXT
KAFKA_CFG_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
KAFKA_CFG_ZOOKEEPER_CONNECT: "zookeeper1:2181"
volumes:
- kafka1-data:/bitnami/kafka
which can be deployed like so: docker stack deploy --orchestrator kubernetes -c kafka-stack.yaml kafka-stack
.
Hopefully this saves someone some time.
from kafka-shell.
Happy to hear it is working!
from kafka-shell.
Related Issues (15)
- Add command: kafka-reassign-partitions
- config.yml removed once sing off HOT 2
- Configuration file validation should evaluate environment variables HOT 3
- Add additional docs for working with kafka in docker HOT 9
- cannot launch kafka-shell HOT 6
- More config/properties auto-completions HOT 1
- Add command: kafka-replica-verification
- How to add my own custom kafka commands into this? HOT 4
- Connect to Remote kafka cluster HOT 4
- Add command: kafka-preferred-replica-election
- Plzzz Add more Easter eggs
- Allow for commands to be piped
- Auto fill `--command-config` for commands
- Does it support ACL HOT 5
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from kafka-shell.