<h1 id="cli">CLI<a aria-hidden="true" class="anchor-heading icon-link" href="#cli"></a></h1>
<p>If you see the documentation after running a command, this means your command is wrong. Scroll up to see details about the error message</p>
<p><code>--zookeeper</code> option is outdated and shouldn't be used</p>
<ul>
<li>Since Kafka v0.10, the consumer is leveraging a Kafka connection string, not Zookeeper. This is due to how consumer offsets are stored.</li>
</ul>
<h2 id="kafka-topics"><code>kafka-topics</code><a aria-hidden="true" class="anchor-heading icon-link" href="#kafka-topics"></a></h2>
<h3 id="create-topic">Create topic<a aria-hidden="true" class="anchor-heading icon-link" href="#create-topic"></a></h3>
<pre class="language-sh"><code class="language-sh">kafka-topics --create \
  --bootstrap-server localhost:9092 \
  --replication-factor 1 \
  --partitions 3 \
  --topic my_topic
</code></pre>
<h3 id="list-topics">List topics<a aria-hidden="true" class="anchor-heading icon-link" href="#list-topics"></a></h3>
<pre class="language-sh"><code class="language-sh">kafka-topics --list --bootstrap-server localhost:9092
</code></pre>
<h3 id="describe-a-topic">Describe a topic<a aria-hidden="true" class="anchor-heading icon-link" href="#describe-a-topic"></a></h3>
<pre class="language-sh"><code class="language-sh">kafka-topics --bootstrap-server localhost:9092 --describe --topic my_topic
</code></pre>
<h3 id="increase--of-partitions-of-a-topic">Increase # of partitions of a topic<a aria-hidden="true" class="anchor-heading icon-link" href="#increase--of-partitions-of-a-topic"></a></h3>
<pre class="language-sh"><code class="language-sh">kafka-topics --bootstrap-server localhost:9092 --alter --topic my_topic --partitions 5
</code></pre>
<h3 id="delete-a-topic">Delete a topic<a aria-hidden="true" class="anchor-heading icon-link" href="#delete-a-topic"></a></h3>
<pre class="language-sh"><code class="language-sh"># You can specify a comma delimited list of topics to delete more than one topic at a time
kafka-topics --bootstrap-server localhost:9092 --delete --topic my_topic
</code></pre>
<h2 id="kafka-console-producer"><code>kafka-console-producer</code><a aria-hidden="true" class="anchor-heading icon-link" href="#kafka-console-producer"></a></h2>
<h3 id="produce-message">Produce message<a aria-hidden="true" class="anchor-heading icon-link" href="#produce-message"></a></h3>
<p>By default messages sent to a Kafka topic will result in messages with <code>null</code> keys. We must use the properties parse.key and key.separator to send the key alongside messages.</p>
<pre class="language-sh"><code class="language-sh">kafka-console-producer --bootstrap-server localhost:9092 --topic my_topic
# any line of text you write after the '>' will be sent to the Kafka topic

# or, pass messages (newline separated) from a file
kafka-console-producer --bootstrap-server localhost:9092 --topic my_topic &#x3C; topic-input.txt
</code></pre>
<h2 id="kafka-console-consumer"><code>kafka-console-consumer</code><a aria-hidden="true" class="anchor-heading icon-link" href="#kafka-console-consumer"></a></h2>
<h3 id="consume-only-future-messages">Consume only future messages<a aria-hidden="true" class="anchor-heading icon-link" href="#consume-only-future-messages"></a></h3>
<pre class="language-sh"><code class="language-sh">kafka-console-consumer --bootstrap-server localhost:9092 --topic my_topic
</code></pre>
<h3 id="consume-all-historical-messages">Consume all historical messages<a aria-hidden="true" class="anchor-heading icon-link" href="#consume-all-historical-messages"></a></h3>
<pre class="language-sh"><code class="language-sh">kafka-console-consumer --bootstrap-server localhost:9092 --topic my_topic --from-beginning
</code></pre>

tech

This Dendron vault of tech knowledge is organized according to domains and their sub-domains, along with specific implementation of those domains.

For instance, Git itself is a domain. Sub-domains of Git would include topics like `commit`,
`tags`, `reflog` etc., while implementations of each of those could be `cli`, `strat`
(strategies), `inner` (inner workings), and so on.

The goal of the wiki is to present data in a manner that is from the perspective
of a querying user. Here, a user is a programmer wanting to get key information
from a specific domain. For instance, if a user wants to use postgres functions
and hasn't done them in a while, they should be able to query
`postgres.functions` to see basic implementations, as well as common patterns
that have been employed in the past.

This wiki has been written with myself in mind. While learning each of these
domains, I have been sensitive to the "aha" moments and have noted down my
insights as they arose. I have refrained from capturing information that I
considered obvious or otherwise non-beneficial to my own understanding.

As a result, I have allowed myself to use potentially arcane concepts to help
explain others. For example, in my note on [[unit testing|testing.method.unit]],
I have made reference to the [[microservices|general.arch.microservice]] note.
The ability to analogize between different concepts captured in different notes
allows an opportunity to build strong generalized understandings. Given that
you'd have to understand microservices to be able to draw that same parallel
that I've already drawn, these links won't work for everyone. Since these notes
are written for myself, I have been fine with taking these liberties and leaning
on them heavily.

What I hope to gain from this wiki is the ability to step away from any
given domain for a long period of time, and be able to be passably useful for
whatever my goals are within a short period of time. Of course this is all
vague sounding, and really depends on the domain along with the ends I am
trying to reach.

To achieve this, the system should be steadfast to:
- be able to put information in relatively easily, without too much thought
	required to its location. While location is important, Dendron makes it easy
	to relocate notes, if it becomes apparent that a different place makes more
	sense.
- be able to extract the information that is needed, meaning there is a
	high-degree in confidence in the location of the information. The idea is
	that information loses a large amount of its value when it is unfindable.
	Therefore, a relatively strict ideology should be used when determining
	where a piece of information belongs.
	- Some concepts might realistically belong to multiple domains. For instance, the concept of *access modifiers* can be found in both `C#` and `Typescript`. Therefore, this note should be abstracted to a common place, such as [[OOP|paradigm.oop]].

This Dendron notebook is the sister vault to the general [Second Brain](https://tech.kyletycholiz.com).

## Tags
Throughout the garden, I have made use of tags, which give semantic meaning to the pieces of information.

- `ex.` - Denotes an *example* of the preceding piece of information
- `spec:` - Specifies that the preceding information has some degree of *speculation* to it, and may not be 100% factual. Ideally this gets clarified over time as my understanding develops. I try to go back after I have better understood the topic and clear out the notes of `spec:` tags
- `anal:` - Denotes an *analogy* of the preceding information. When I can, I attempt to link concepts to others that I have previously learned.
- `mn:` - Denotes a *mnemonic*
- `expl:` - Denotes an *explanation*

## Resources
### UE (Unexamined) Resources
Often, I come across sources of information that I believe to be high-quality. They may be recommendations or found in some other way. No matter their origin, I may be in a position where I don't have the time to fully examine them (and properly extract notes), or I may not require the information at that moment in time. In cases like these, I will add reference to a section of the note called **UE Resources**. The idea is that in the future when I am ready to examine them, I have a list of resources that I can start with. This is an alternative strategy to compiling browser bookmarks, which I've found can quickly become untenable.

### E (Examined) Resources
Once a resource has been thoroughly examined and has been mined for notes, it will be moved from *UE Resources* to *E Resources*. This is to indicate that (in my own estimation), there is nothing more to be gained from the resource that is not already in the note.

### Resources
This heading is for inexhaustible resources. 
- A prime example would be a quality website that continually posts articles.  - Another example would be a tool, such as software that measures frequencies in a room to help acoustically treat it.


CLI

`kafka-topics`

Create topic

List topics

Describe a topic

Increase # of partitions of a topic

Delete a topic

`kafka-console-producer`

Produce message

`kafka-console-consumer`

Consume only future messages

Consume all historical messages