Flavio Junqueira fpj

Organizations

@s4
fpj commented on pull request apache/kafka#178
@fpj

The test failures aren't related to this patch: kafka.api.QuotasTest > testThrottledProducerConsumer kafka.consumer.MetricsTest > testMetricsLeak

fpj commented on pull request apache/kafka#178
@fpj

@guozhangwang you can start reviewing if you have time. I'm primarily interested your opinion about the approach of using a zk handle directly to s…

fpj pushed to 1387 at fpj/kafka
@fpj
  • @fpj f4aa131
    Merge remote-tracking branch 'upstream/trunk' into 1387
  • @SinghAsDev 24da542
    KAFKA-2461; request logger no longer logs extra information in debug …
  • 7 more commits »
fpj pushed to 1387 at fpj/kafka
@fpj
  • @fpj d694fd6
    KAFKA-1387: Re-adding imports removed by mistake.
fpj pushed to 1387 at fpj/kafka
@fpj
fpj pushed to 1387 at fpj/kafka
@fpj
  • @fpj 3a46b28
    KAFKA-1387: Removed messages used for local debugging.
fpj pushed to 1387 at fpj/kafka
@fpj
  • @fpj af28ca1
    KAFKA-1387: Added checker back and other improvements.
fpj commented on pull request apache/kafka#184
@fpj

+1

fpj commented on pull request apache/kafka#178
@fpj

Need to remove this commented code.

fpj commented on pull request apache/kafka#178
@fpj

Need to remove this commented code.

fpj commented on pull request apache/kafka#178
@fpj

Need to remove this commented code.

fpj opened pull request apache/kafka#178
@fpj
KAFKA-1387: Kafka getting stuck creating ephemeral node it has already created when two zookeeper sessions are established in a very short period of time
15 commits with 247 additions and 43 deletions
fpj pushed to 1387 at fpj/kafka
@fpj
fpj commented on pull request apache/kafka#93
@fpj

@Parth-Brahmbhatt thanks for the clarification. Is there going to be any documentation the default behavior and possibly giving recommendations for…

fpj pushed to 1387 at fpj/kafka
@fpj
fpj commented on pull request apache/kafka#93
@fpj

The patch in general looks good. It creates some default acls and adds a parameter to all calls that create znodes. With this patch, however, Consu…

fpj pushed to 1387 at fpj/kafka
@fpj
fpj pushed to trunk at fpj/kafka
@fpj
fpj created branch 1387 at fpj/kafka
fpj pushed to trunk at fpj/kafka
@fpj
  • @hachikuji f6373e4
    KAFKA-2340: Improve KafkaConsumer Fetcher test coverage
  • @hachikuji 006b45c
    KAFKA-2400: Expose heartbeat interval in KafkaConsumer configuration
  • 33 more commits »
fpj commented on pull request apache/kafka#102
@fpj

hi @guozhangwang @ijuma Thanks for reviewing this patch. I have updated it according to your comments. The two main things I have done are to wrap…

fpj pushed to 2300 at fpj/kafka
@fpj
fpj commented on pull request apache/kafka#102
@fpj

I prefer line breaks over long lines, is that alright?

fpj commented on pull request apache/kafka#102
@fpj

it is ready for review, yes.

fpj pushed to 208 at fpj/schema-registry
@fpj
  • @fpj 2bfcbae
    Issue #208: Change fail message to be consistent with the other messa…
@fpj
Issue #208: Several RestApiTest test cases don't test proper exception behavior
3 commits with 34 additions and 5 deletions
fpj pushed to 208 at fpj/schema-registry
@fpj
@fpj
  • @fpj 6335ae9
    Merge pull request #207 from fpj/170
fpj created branch 208 at fpj/schema-registry