i hava test my kafka programe using kafka-console-producer.sh and
kafka-console-consumer.sh.
setp1 :
[oracle@bd02 bin]$ ./kafka-console-producer.sh --broker-list
133.224.217.175:9092 --topic oggtopic
setp2:
[oracle@bd02 bin]$ ./kafka-console-consumer.sh --zookeeper
133.224.217.
i hava test my kafka programe using kafka-console-producer.sh and
kafka-console-consumer.sh.
Hey,
I want to create a KIP for
https://issues.apache.org/jira/browse/KAFKA-7711
to initiate discussion.
Can someone grant me permission?
Thanks,
Kun
Hi,
I would like to start discussion on KIP-514 that proposes we add a
bounded flush() API to producer.
Link to the KIP:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-514%3A+Add+a+bounded+flush%28%29+API+to+Kafka+Producer
Suggestions and feedback are welcome!
Thanks,
Kun
Looks like it is the same issue as
https://issues.apache.org/jira/browse/KAFKA-8571
And there is a PR for that https://github.com/apache/kafka/pull/7069
Jason Gustafson (Jira) 于2019年11月16日周六 上午9:57写道:
> Jason Gustafson created KAFKA-9198:
> --
>
>
Hi community,
I have clone the most recent Kafka source code (trunk branch), and I do the
following:
1. run ./gradlew
2. open the project in IDEA
3. copy the log4j.properties to the core/src/main/resources folder
4. add config/server.properties to the program arguments
5. add slf4j-api and slf4j-lo
I have figure it out, just add this line to build.gradle:
compile libs.slf4jlog4j
On Sun, Dec 1, 2019 at 10:22 AM Kun Song wrote:
> Hi community,
> I have clone the most recent Kafka source code (trunk branch), and I do
> the following:
> 1. run ./gradlew
> 2. open the proj
Hi Kafka committers, I want to be added to the contributors list, my JIRA
ID is songkun, thank you :)
Rebased the PR based on latest trunk, can we merge the PR?
Kun
radai 于2019年12月13日周五 上午9:26写道:
> i also have a PR :-)
> https://github.com/apache/kafka/pull/7569
>
> On Thu, Dec 12, 2019 at 9:50 PM Gwen Shapira wrote:
> >
> > You got 3 binding votes (Joel, Harsha, Isma
kun du created KAFKA-7711:
-
Summary: Add a bounded flush() API to Kafka Producer
Key: KAFKA-7711
URL: https://issues.apache.org/jira/browse/KAFKA-7711
Project: Kafka
Issue Type: Improvement
10 matches
Mail list logo