Github user tiodollar closed the pull request at:
https://github.com/apache/storm/pull/2181
---
Github user tiodollar commented on the issue:
https://github.com/apache/storm/pull/2181
@srdo tks for this! I'm very busy, and is better that! For me it's ok!
---
Github user tiodollar commented on the issue:
https://github.com/apache/storm/pull/2181
@srdo i'll resolve this issue today! I have been busy, but i reseved some
hour to do this.
---
Github user tiodollar commented on the issue:
https://github.com/apache/storm/pull/2181
@HeartSaVioR i'll fix this merge today!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user tiodollar commented on the issue:
https://github.com/apache/storm/pull/2181
@srdo i'll fix this! Tks!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled
Github user tiodollar commented on the issue:
https://github.com/apache/storm/pull/2181
@hmcl Could I get you to review this?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user tiodollar commented on a diff in the pull request:
https://github.com/apache/storm/pull/2181#discussion_r125533409
--- Diff:
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/OffsetManager.java
---
@@ -96,31 +98,34 @@ public
Github user tiodollar commented on a diff in the pull request:
https://github.com/apache/storm/pull/2181#discussion_r124927995
--- Diff:
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/OffsetManager.java
---
@@ -162,7 +164,7 @@ public long commit
Github user tiodollar commented on a diff in the pull request:
https://github.com/apache/storm/pull/2181#discussion_r124927989
--- Diff:
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/OffsetManager.java
---
@@ -118,6 +118,8 @@ public
Github user tiodollar commented on the issue:
https://github.com/apache/storm/pull/2181
@srdo I'll take look, and try fixing this!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
GitHub user tiodollar opened a pull request:
https://github.com/apache/storm/pull/2181
[STORM-2607] Offset consumer + 1
When i put a message a partition, the storm-kafka-client consume this
message.
But storm-kafka-client commit the offset -1.
storm-kafka-client: 1.1.0
11 matches
Mail list logo