fhussonnois / kafkacli

CLI and Go Clients to manage Kafka components (Kafka Connect & SchemaRegistry)

Hi, I'm Florian 👋

I'm a software engineer and I work as Consultant and Apache Kafka Expert for StreamThoughts, the company I founded. I'm a former Consultant from Zenika, a French IT consulting firm where I worked as Data Engineer and Big Data Director. During my career, I've worked on various projects involving the implementation of data integration and processing platforms through the worlds of Hadoop, Spark and Kafka. Passionate about data and distributed systems, I specialized in stream processing and event-driven architectures. Now, I'm focusing on helping compagnies to design and build data-mesh oriented organization by leveraging event streaming technologies.

I'm also co-organizer of the Paris Apache Kafka Meetup, and speak regularly on this topic. Involved in the opensource community, I've contributed to a few KIPs for KafkaStreams and create the Azkarra Streams framework. In 2019, I have been selected to be part of the Confluent Community Catalyst program.

Here are some projects, I'm currently working on 💻 :

• Azkarra Streams
• Connect File Pulse
• Kafka Clients Kotlin
• Kafka Streams CEP
• Jikkou

If you use or think that one of these projects can help you or your team to develop an application based on Kafka? Please 🌟 the repository to support my work!

Find me around the web 🌍 :

• Blogging on Medium and Dev.To
• Sharing updates on LinkedIn and Twitter
• Sharing talk presentations on speakerdeck

kafkacli's Issues

Schema-Registry-Cli : Add command to delete a subject

Add command to support new schema registry API added in Confluent 3.3

CLIs thows panic error when called with command 'help' and no arg

Example : ./kafkaconnectcli help panic: runtime error: index out of range

Errors returned from kafka connect must be properly handled

add the possibilty to override defaults host/port for use by the CLI

kafka-connect-cli : configuration properties with a character = are not supported

display the connector configuration before deleting it

kafka-connect-cli : config update is not implemented

SchemaRegistryCLI - Add option to register schema from url

Add an option schema.url to be able to register a new schema from a given REST endpoint.
For instance, this is useful if schemas are versioned under GIT.