[
https://issues.apache.org/jira/browse/KAFKA-854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13941580#comment-13941580
]
Michael Noll commented on KAFKA-854:
Now that one year has passed since the last update
[
https://issues.apache.org/jira/browse/KAFKA-1314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13941786#comment-13941786
]
Jun Rao commented on KAFKA-1314:
When mytopic is unavailable? Are there any errors in the
[
https://issues.apache.org/jira/browse/KAFKA-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13941831#comment-13941831
]
Jun Rao commented on KAFKA-1297:
We can use the following workaround. Then, we don't need
[
https://issues.apache.org/jira/browse/KAFKA-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-1297.
Resolution: Fixed
Fix Version/s: 0.8.2
Assignee: Jun Rao
Committed to trunk.
1) The new producer and consumer is being designed to take care of
auto balancing between partitions. Right ?
That's correct.
2) with the current available producer and consumer, is my current
setup(pls see attached file) a good design in terms of scalability.
Your Kafka setup seems reasonable
[
https://issues.apache.org/jira/browse/KAFKA-1314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13941968#comment-13941968
]
alex kamil commented on KAFKA-1314:
---
it seems to be back online now
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/19388/#review37843
---
[
https://issues.apache.org/jira/browse/KAFKA-1312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timothy Chen closed KAFKA-1312.
---
Update gitignore to ignore IDE generated files
--
[
https://issues.apache.org/jira/browse/KAFKA-1312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13942065#comment-13942065
]
Timothy Chen commented on KAFKA-1312:
-
Updated reviewboard against branch
[
https://issues.apache.org/jira/browse/KAFKA-1312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timothy Chen updated KAFKA-1312:
Attachment: KAFKA-1312_2014-03-20_11:00:17.patch
Update gitignore to ignore IDE generated files
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/19388/#review37926
---
Issue Subscription
Filter: outstanding kafka patches (86 issues)
The list of outstanding kafka patches
Subscriber: kafka-mailing-list
Key Summary
KAFKA-1300 Added WaitForReplaction admin tool.
https://issues.apache.org/jira/browse/KAFKA-1300
KAFKA-1264 Make ConsoleProducer
Brent Bradbury created KAFKA-1317:
-
Summary: KafkaServer 0.8.1 not responding to .shutdown() cleanly,
possibly related to TopicDeletionManager or MetricsMeter state
Key: KAFKA-1317
URL:
[
https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Brent Bradbury updated KAFKA-1317:
--
Attachment: threaddump.txt
Thread dump of hung process
KafkaServer 0.8.1 not responding to
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/19490/
---
Review request for kafka.
Bugs: KAFKA-1315
[
https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13942194#comment-13942194
]
Brent Bradbury commented on KAFKA-1317:
---
Maybe related to KAFKA-1298 ?
KafkaServer
[
https://issues.apache.org/jira/browse/KAFKA-1315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13942196#comment-13942196
]
Timothy Chen commented on KAFKA-1315:
-
Created reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timothy Chen updated KAFKA-1315:
Attachment: KAFKA-1315.patch
log.dirs property in KafkaServer intolerant of trailing slash
[
https://issues.apache.org/jira/browse/KAFKA-1315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-1315:
-
Priority: Blocker (was: Major)
log.dirs property in KafkaServer intolerant of trailing slash
[
https://issues.apache.org/jira/browse/KAFKA-1315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-1315:
-
Fix Version/s: 0.8.1.1
log.dirs property in KafkaServer intolerant of trailing slash
[
https://issues.apache.org/jira/browse/KAFKA-1315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-1315:
-
Labels: newbie (was: )
log.dirs property in KafkaServer intolerant of trailing slash
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/19490/#review37961
---
Thanks for the quick patch, Tim!
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/17263/#review37833
---
One general comment: can we refactor the structure of
On March 20, 2014, 8:20 p.m., Neha Narkhede wrote:
core/src/main/scala/kafka/cluster/Partition.scala, line 93
https://reviews.apache.org/r/19490/diff/1/?file=530482#file530482line93
This creates new File objects on every single getOrCreateReplica.
During leader changes, that
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/19490/
---
(Updated March 20, 2014, 8:28 p.m.)
Review request for kafka.
Bugs:
[
https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13942233#comment-13942233
]
Neha Narkhede commented on KAFKA-1317:
--
Thanks for filing the bug. I wonder why I
[
https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-1317:
-
Priority: Blocker (was: Major)
KafkaServer 0.8.1 not responding to .shutdown() cleanly,
[
https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-1317:
-
Fix Version/s: 0.8.1.1
KafkaServer 0.8.1 not responding to .shutdown() cleanly, possibly
[
https://issues.apache.org/jira/browse/KAFKA-1315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timothy Chen updated KAFKA-1315:
Attachment: KAFKA-1315_2014-03-20_13:28:06.patch
log.dirs property in KafkaServer intolerant of
[
https://issues.apache.org/jira/browse/KAFKA-1315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13942236#comment-13942236
]
Timothy Chen commented on KAFKA-1315:
-
Updated reviewboard
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/19490/#review37964
---
Almost ready for checkin. 2 minor comments after which we can check
[
https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13942233#comment-13942233
]
Neha Narkhede edited comment on KAFKA-1317 at 3/20/14 8:37 PM:
[
https://issues.apache.org/jira/browse/KAFKA-1315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-1315:
-
Assignee: Timothy Chen
log.dirs property in KafkaServer intolerant of trailing slash
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/19490/#review37967
---
core/src/main/scala/kafka/cluster/Partition.scala
On March 20, 2014, 8:41 p.m., Guozhang Wang wrote:
Actually, I think all we need is FileSystem.getFileSystem().normalize(pathname).
- Guozhang
---
This is an automatically generated e-mail. To reply, visit:
[
https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13942247#comment-13942247
]
Brent Bradbury commented on KAFKA-1317:
---
Ah, sorry not to make that clear Neha. I
[
https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13942263#comment-13942263
]
Brent Bradbury commented on KAFKA-1317:
---
I should add- I call awaitShutdown() as
On March 20, 2014, 8:41 p.m., Guozhang Wang wrote:
core/src/main/scala/kafka/cluster/Partition.scala, line 93
https://reviews.apache.org/r/19490/diff/2/?file=530513#file530513line93
Don't you still need to change this place?
Don't need to change this as getAbsolutePath matches the
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/19490/
---
(Updated March 20, 2014, 9:03 p.m.)
Review request for kafka.
Bugs:
[
https://issues.apache.org/jira/browse/KAFKA-1315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13942273#comment-13942273
]
Timothy Chen commented on KAFKA-1315:
-
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13942270#comment-13942270
]
Neha Narkhede commented on KAFKA-1317:
--
This is a bug, a lot of our threads for some
[
https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-1317:
-
Labels: newbie (was: )
KafkaServer 0.8.1 not responding to .shutdown() cleanly, possibly
[
https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-1317:
-
Assignee: Timothy Chen
KafkaServer 0.8.1 not responding to .shutdown() cleanly, possibly
[
https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13942287#comment-13942287
]
Brent Bradbury commented on KAFKA-1317:
---
Simplest way is to create a KafkaServer
[
https://issues.apache.org/jira/browse/KAFKA-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timothy Chen updated KAFKA-1:
-
Comment: was deleted
(was: Updated reviewboard against branch origin/trunk)
The log4j appender still
[
https://issues.apache.org/jira/browse/KAFKA-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timothy Chen updated KAFKA-1:
-
Attachment: (was: KAFKA-1_2014-03-19_13:38:39.patch)
The log4j appender still uses the SyncProducer
[
https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13942322#comment-13942322
]
Jay Kreps commented on KAFKA-1317:
--
Gotcha.
KafkaServer 0.8.1 not responding to
[
https://issues.apache.org/jira/browse/KAFKA-821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13942338#comment-13942338
]
Jay Kreps commented on KAFKA-821:
-
[~nehanarkhede] Does this bug still exist?
specifying
[
https://issues.apache.org/jira/browse/KAFKA-649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-649:
Resolution: Fixed
Status: Resolved (was: Patch Available)
Closing as it looks like this was
[
https://issues.apache.org/jira/browse/KAFKA-535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-535.
-
Resolution: Fixed
I don't think this is a bug and is in any way fixed in the new producer.
Significant
[
https://issues.apache.org/jira/browse/KAFKA-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13942349#comment-13942349
]
Jay Kreps commented on KAFKA-308:
-
[~nehanarkhede] If no updates perhaps we should close
[
https://issues.apache.org/jira/browse/KAFKA-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13942351#comment-13942351
]
Neha Narkhede commented on KAFKA-308:
-
Yes, agree.
Corrupted message stored in log
[
https://issues.apache.org/jira/browse/KAFKA-308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede resolved KAFKA-308.
-
Resolution: Cannot Reproduce
Corrupted message stored in log segment on disk
[
https://issues.apache.org/jira/browse/KAFKA-891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-891.
-
Resolution: Fixed
The idea of the client id is really to identify an application. The host/port
should
[
https://issues.apache.org/jira/browse/KAFKA-910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-910.
-
Resolution: Duplicate
Randomize the backoff in the clients to avoid all clients from sending
metadata
[
https://issues.apache.org/jira/browse/KAFKA-683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-683.
-
Resolution: Fixed
Closing since everyone ignored my code quality pleas :-)
Fix correlation ids in all
[
https://issues.apache.org/jira/browse/KAFKA-327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-327.
-
Resolution: Fixed
Seems done.
Monitoring and tooling for Kafka replication
[
https://issues.apache.org/jira/browse/KAFKA-1241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-1241.
--
Resolution: Fixed
I believe this is fixed.
Cryptic serde error messages in new producer
[
https://issues.apache.org/jira/browse/KAFKA-1155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13942365#comment-13942365
]
Jay Kreps commented on KAFKA-1155:
--
[~nehanarkhede] Is this still open? I think this is
[
https://issues.apache.org/jira/browse/KAFKA-1023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-1023.
--
Resolution: Won't Fix
Allow Injectable LogManager
---
Key:
[
https://issues.apache.org/jira/browse/KAFKA-979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13942375#comment-13942375
]
Jay Kreps commented on KAFKA-979:
-
KAFKA-615 isn't quite suffient. We still do fsync on log
[
https://issues.apache.org/jira/browse/KAFKA-979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-979:
Labels: newbie (was: )
Add jitter for time based rolling
-
[
https://issues.apache.org/jira/browse/KAFKA-924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-924:
Labels: newbie (was: )
Specify console consumer properties via a single --property command line
[
https://issues.apache.org/jira/browse/KAFKA-970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-970.
-
Resolution: Fixed
./sbt +package rebuilds the Hadoop consumer jar N times with the same output
file
[
https://issues.apache.org/jira/browse/KAFKA-855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-855.
-
Resolution: Fixed
We ended up doing gradle.
Ant+Ivy build for Kafka
---
[
https://issues.apache.org/jira/browse/KAFKA-1114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-1114.
--
Resolution: Fixed
Done.
Add documentation for 0.8.1
---
[
https://issues.apache.org/jira/browse/KAFKA-1057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-1057:
-
Labels: newbie (was: )
Trim whitespaces from user specified configs
[
https://issues.apache.org/jira/browse/KAFKA-190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-190.
-
Resolution: Won't Fix
I think this is less relevant with the new fsync management and replication
code.
[
https://issues.apache.org/jira/browse/KAFKA-1311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-1311:
-
Priority: Blocker (was: Major)
Add a flag to turn off delete topic until it is stable
Joe,
I'm unable to take
patcheshttps://issues.apache.org/jira/browse/KAFKA/fixforversion/12326539/?selectedTab=com.atlassian.jira.jira-projects-plugin:version-summary-panelon
0.8.1 and the reason is probably that 0.8.1 is tag, not a branch.
Should
we create a branch and rename the tag to
[
https://issues.apache.org/jira/browse/KAFKA-1311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-1311:
-
Fix Version/s: 0.8.1.1
Add a flag to turn off delete topic until it is stable
[
https://issues.apache.org/jira/browse/KAFKA-1155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13942403#comment-13942403
]
Neha Narkhede commented on KAFKA-1155:
--
[~jkreps] Yes, that is how zookeeper works
0.8.1 is a branch (also)
after a clean git clone you should be able to-do
git checkout -b 0.8.1
git checkout 0.8.1 would put you on the tag
agreed though we need a better name for tags moving forward or even now,
about to board a plane but how about if you change/retag the last commit as
[
https://issues.apache.org/jira/browse/KAFKA-1251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13942454#comment-13942454
]
Jay Kreps commented on KAFKA-1251:
--
Guozhong,
1. No idea. I did a comparison between a
On March 19, 2014, 3:17 a.m., Jay Kreps wrote:
clients/src/main/java/org/apache/kafka/common/record/CompressionFactory.java,
line 46
https://reviews.apache.org/r/18299/diff/14/?file=526586#file526586line46
I don't think this is needed. Inside an if statement you should be able
git checkout -b 0.8.1
Didn't work. This just checks out trunk on a local branch called 0.8.1. I'd
like to checkout the branch origin/0.8.1 and push the patch to the branch.
For some reason, that doesn't work for me. Joel also tried and didn't work
for him. I wonder if I'm missing something
Right, wasn't thinking... Rushing to board. So remove 0.8.1 tag and retag the
branch as 0.8.1.0 ( I should have done that in the first place )?
/***
Joe Stein
Founder, Principal Consultant
Big Data Open Source Security LLC
http://www.stealth.ly
[
https://issues.apache.org/jira/browse/KAFKA-1251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13942477#comment-13942477
]
Guozhang Wang commented on KAFKA-1251:
--
Cool, looks good for me now.
Add metrics to
On March 20, 2014, 10:08 p.m., Guozhang Wang wrote:
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordBatch.java,
line 65
https://reviews.apache.org/r/19388/diff/4/?file=528766#file528766line65
sizeInBytes does not work for compression, we could just use
On March 20, 2014, 10:08 p.m., Guozhang Wang wrote:
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordBatch.java,
line 65
https://reviews.apache.org/r/19388/diff/4/?file=528766#file528766line65
sizeInBytes does not work for compression, we could just use
[
https://issues.apache.org/jira/browse/KAFKA-1315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede resolved KAFKA-1315.
--
Resolution: Fixed
Thanks for the patch! Committed to 0.8.1 and trunk.
log.dirs property in
The tag was the problem. I renamed the tag to 0.8.1.0 and kept the branch
as 0.8.1. That allowed me to push to the 0.8.1 branch.
Thanks,
Neha
On Thu, Mar 20, 2014 at 4:02 PM, Joe Stein joe.st...@stealth.ly wrote:
Right, wasn't thinking... Rushing to board. So remove 0.8.1 tag and retag
the
Jun Rao created KAFKA-1318:
--
Summary: waiting for producer to stop is not reliable in system
tests
Key: KAFKA-1318
URL: https://issues.apache.org/jira/browse/KAFKA-1318
Project: Kafka
Issue Type:
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/19510/
---
Review request for kafka.
Bugs: KAFKA-1318
[
https://issues.apache.org/jira/browse/KAFKA-1318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13942616#comment-13942616
]
Jun Rao commented on KAFKA-1318:
Created reviewboard https://reviews.apache.org/r/19510/
[
https://issues.apache.org/jira/browse/KAFKA-1318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-1318:
---
Attachment: KAFKA-1318.patch
waiting for producer to stop is not reliable in system tests
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/19511/
---
Review request for kafka.
Bugs: KAFKA-1319
Jun Rao created KAFKA-1319:
--
Summary: kafka jar doesn't depend on metrics-annotation any more
Key: KAFKA-1319
URL: https://issues.apache.org/jira/browse/KAFKA-1319
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-1319:
---
Attachment: KAFKA-1319.patch
kafka jar doesn't depend on metrics-annotation any more
[
https://issues.apache.org/jira/browse/KAFKA-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13942620#comment-13942620
]
Jun Rao commented on KAFKA-1319:
If we do want to release 0.8.1.1, we probably should
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/19510/#review38028
---
Ship it!
system_test/utils/kafka_system_test_utils.py
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/19511/#review38029
---
Ship it!
Ship It!
- Guozhang Wang
On March 21, 2014, 1:04 a.m.,
[
https://issues.apache.org/jira/browse/KAFKA-891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13942633#comment-13942633
]
Neha Narkhede commented on KAFKA-891:
-
Right, the idea of client id is to identify the
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/19511/#review38049
---
Ship it!
Ship It!
- Neha Narkhede
On March 21, 2014, 1:04 a.m.,
94 matches
Mail list logo
